headers

package

Go to main page

Versions in this module

v0

v0.3.3

Nov 17, 2020

Changes in this version

type ResponseHeader

+ Message string

+ func (m *ResponseHeader) GetMessage() string

v0.3.2

Nov 17, 2020

Changes in this version

type ResponseStatus

+ const ResponseStatus_ALREADY_EXISTS

+ const ResponseStatus_CANCELED

+ const ResponseStatus_CONFLICT

+ const ResponseStatus_FORBIDDEN

+ const ResponseStatus_INTERNAL

+ const ResponseStatus_INVALID

+ const ResponseStatus_NOT_FOUND

+ const ResponseStatus_NOT_SUPPORTED

+ const ResponseStatus_TIMEOUT

+ const ResponseStatus_UNAUTHORIZED

+ const ResponseStatus_UNAVAILABLE

+ const ResponseStatus_UNKNOWN

v0.3.1

Oct 12, 2020

v0.3.0

Oct 12, 2020

v0.2.0

May 21, 2020

Changes in this version

type RequestHeader

+ Primitive primitive.PrimitiveId

+ func (m *RequestHeader) GetPrimitive() primitive.PrimitiveId

v0.1.0

Mar 11, 2020

Changes in this version

+ var ErrIntOverflowHeaders = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthHeaders = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupHeaders = fmt.Errorf("proto: unexpected end of group")

+ var ResponseStatus_name = map[int32]string

+ var ResponseStatus_value = map[string]int32

+ var ResponseType_name = map[int32]string

+ var ResponseType_value = map[string]int32

+ type RequestHeader struct

+ Index uint64

+ Name *primitive.Name

+ Partition int32

+ RequestID uint64

+ SessionID uint64

+ Streams []*StreamHeader

+ func (*RequestHeader) Descriptor() ([]byte, []int)

+ func (*RequestHeader) ProtoMessage()

+ func (m *RequestHeader) GetIndex() uint64

+ func (m *RequestHeader) GetName() *primitive.Name

+ func (m *RequestHeader) GetPartition() int32

+ func (m *RequestHeader) GetRequestID() uint64

+ func (m *RequestHeader) GetSessionID() uint64

+ func (m *RequestHeader) GetStreams() []*StreamHeader

+ func (m *RequestHeader) Marshal() (dAtA []byte, err error)

+ func (m *RequestHeader) MarshalTo(dAtA []byte) (int, error)

+ func (m *RequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RequestHeader) Reset()

+ func (m *RequestHeader) Size() (n int)

+ func (m *RequestHeader) String() string

+ func (m *RequestHeader) Unmarshal(dAtA []byte) error

+ func (m *RequestHeader) XXX_DiscardUnknown()

+ func (m *RequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RequestHeader) XXX_Merge(src proto.Message)

+ func (m *RequestHeader) XXX_Size() int

+ func (m *RequestHeader) XXX_Unmarshal(b []byte) error

+ type ResponseHeader struct

+ Index uint64

+ Leader string

+ ResponseID uint64

+ SessionID uint64

+ Status ResponseStatus

+ StreamID uint64

+ Type ResponseType

+ func (*ResponseHeader) Descriptor() ([]byte, []int)

+ func (*ResponseHeader) ProtoMessage()

+ func (m *ResponseHeader) GetIndex() uint64

+ func (m *ResponseHeader) GetLeader() string

+ func (m *ResponseHeader) GetResponseID() uint64

+ func (m *ResponseHeader) GetSessionID() uint64

+ func (m *ResponseHeader) GetStatus() ResponseStatus

+ func (m *ResponseHeader) GetStreamID() uint64

+ func (m *ResponseHeader) GetType() ResponseType

+ func (m *ResponseHeader) Marshal() (dAtA []byte, err error)

+ func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ResponseHeader) Reset()

+ func (m *ResponseHeader) Size() (n int)

+ func (m *ResponseHeader) String() string

+ func (m *ResponseHeader) Unmarshal(dAtA []byte) error

+ func (m *ResponseHeader) XXX_DiscardUnknown()

+ func (m *ResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ResponseHeader) XXX_Merge(src proto.Message)

+ func (m *ResponseHeader) XXX_Size() int

+ func (m *ResponseHeader) XXX_Unmarshal(b []byte) error

+ type ResponseStatus int32

+ const ResponseStatus_ERROR

+ const ResponseStatus_NOT_LEADER

+ const ResponseStatus_OK

+ func (ResponseStatus) EnumDescriptor() ([]byte, []int)

+ func (x ResponseStatus) String() string

+ type ResponseType int32

+ const ResponseType_CLOSE_STREAM

+ const ResponseType_OPEN_STREAM

+ const ResponseType_RESPONSE

+ func (ResponseType) EnumDescriptor() ([]byte, []int)

+ func (x ResponseType) String() string

+ type StreamHeader struct

+ ResponseID uint64

+ StreamID uint64

+ func (*StreamHeader) Descriptor() ([]byte, []int)

+ func (*StreamHeader) ProtoMessage()

+ func (m *StreamHeader) GetResponseID() uint64

+ func (m *StreamHeader) GetStreamID() uint64

+ func (m *StreamHeader) Marshal() (dAtA []byte, err error)

+ func (m *StreamHeader) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamHeader) Reset()

+ func (m *StreamHeader) Size() (n int)

+ func (m *StreamHeader) String() string

+ func (m *StreamHeader) Unmarshal(dAtA []byte) error

+ func (m *StreamHeader) XXX_DiscardUnknown()

+ func (m *StreamHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StreamHeader) XXX_Merge(src proto.Message)

+ func (m *StreamHeader) XXX_Size() int

+ func (m *StreamHeader) XXX_Unmarshal(b []byte) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL