Versions in this module Expand all Collapse all v1 v1.7.1 Jan 29, 2021 v1.7.0 Dec 8, 2020 Changes in this version + var ErrIntOverflowMessage = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group") + var FetchResponse_StatusCode_name = map[int32]string + var FetchResponse_StatusCode_value = map[string]int32 + type FetchRequest struct + Identifier string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FetchRequest) Descriptor() ([]byte, []int) + func (*FetchRequest) ProtoMessage() + func (m *FetchRequest) GetIdentifier() string + func (m *FetchRequest) Marshal() (dAtA []byte, err error) + func (m *FetchRequest) MarshalTo(dAtA []byte) (int, error) + func (m *FetchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FetchRequest) Reset() + func (m *FetchRequest) Size() (n int) + func (m *FetchRequest) String() string + func (m *FetchRequest) Unmarshal(dAtA []byte) error + func (m *FetchRequest) XXX_DiscardUnknown() + func (m *FetchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FetchRequest) XXX_Merge(src proto.Message) + func (m *FetchRequest) XXX_Size() int + func (m *FetchRequest) XXX_Unmarshal(b []byte) error + type FetchResponse struct + Data []byte + Status FetchResponse_StatusCode + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FetchResponse) Descriptor() ([]byte, []int) + func (*FetchResponse) ProtoMessage() + func (m *FetchResponse) GetData() []byte + func (m *FetchResponse) GetStatus() FetchResponse_StatusCode + func (m *FetchResponse) Marshal() (dAtA []byte, err error) + func (m *FetchResponse) MarshalTo(dAtA []byte) (int, error) + func (m *FetchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FetchResponse) Reset() + func (m *FetchResponse) Size() (n int) + func (m *FetchResponse) String() string + func (m *FetchResponse) Unmarshal(dAtA []byte) error + func (m *FetchResponse) XXX_DiscardUnknown() + func (m *FetchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FetchResponse) XXX_Merge(src proto.Message) + func (m *FetchResponse) XXX_Size() int + func (m *FetchResponse) XXX_Unmarshal(b []byte) error + type FetchResponse_StatusCode int32 + const FetchResponse_ERROR + const FetchResponse_NOT_FOUND + const FetchResponse_OK + func (FetchResponse_StatusCode) EnumDescriptor() ([]byte, []int) + func (x FetchResponse_StatusCode) String() string