Documentation ¶
Index ¶
- Variables
- type RequestHeader
- func (*RequestHeader) Descriptor() ([]byte, []int)
- func (m *RequestHeader) GetIndex() uint64
- func (m *RequestHeader) GetPartition() uint32
- func (m *RequestHeader) GetPrimitive() primitive.PrimitiveId
- 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 (*RequestHeader) ProtoMessage()
- 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
- func (*ResponseHeader) Descriptor() ([]byte, []int)
- func (m *ResponseHeader) GetIndex() uint64
- func (m *ResponseHeader) GetLeader() string
- func (m *ResponseHeader) GetMessage() 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 (*ResponseHeader) ProtoMessage()
- 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
- type ResponseType
- type StreamHeader
- func (*StreamHeader) Descriptor() ([]byte, []int)
- 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 (*StreamHeader) ProtoMessage()
- 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
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthHeaders = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowHeaders = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupHeaders = fmt.Errorf("proto: unexpected end of group") )
View Source
var ResponseStatus_name = map[int32]string{
0: "OK",
1: "ERROR",
2: "NOT_LEADER",
3: "UNKNOWN",
4: "CANCELED",
5: "NOT_FOUND",
6: "ALREADY_EXISTS",
7: "UNAUTHORIZED",
8: "FORBIDDEN",
9: "CONFLICT",
10: "INVALID",
11: "UNAVAILABLE",
12: "NOT_SUPPORTED",
13: "TIMEOUT",
14: "INTERNAL",
}
View Source
var ResponseStatus_value = map[string]int32{
"OK": 0,
"ERROR": 1,
"NOT_LEADER": 2,
"UNKNOWN": 3,
"CANCELED": 4,
"NOT_FOUND": 5,
"ALREADY_EXISTS": 6,
"UNAUTHORIZED": 7,
"FORBIDDEN": 8,
"CONFLICT": 9,
"INVALID": 10,
"UNAVAILABLE": 11,
"NOT_SUPPORTED": 12,
"TIMEOUT": 13,
"INTERNAL": 14,
}
View Source
var ResponseType_name = map[int32]string{
0: "RESPONSE",
1: "OPEN_STREAM",
2: "CLOSE_STREAM",
}
View Source
var ResponseType_value = map[string]int32{
"RESPONSE": 0,
"OPEN_STREAM": 1,
"CLOSE_STREAM": 2,
}
Functions ¶
This section is empty.
Types ¶
type RequestHeader ¶
type RequestHeader struct { Partition uint32 `protobuf:"varint,6,opt,name=partition,proto3" json:"partition,omitempty"` Primitive primitive.PrimitiveId `protobuf:"bytes,1,opt,name=primitive,proto3" json:"primitive"` SessionID uint64 `protobuf:"varint,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` RequestID uint64 `protobuf:"varint,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` Index uint64 `protobuf:"varint,4,opt,name=index,proto3" json:"index,omitempty"` Streams []StreamHeader `protobuf:"bytes,5,rep,name=streams,proto3" json:"streams"` }
func (*RequestHeader) Descriptor ¶
func (*RequestHeader) Descriptor() ([]byte, []int)
func (*RequestHeader) GetIndex ¶
func (m *RequestHeader) GetIndex() uint64
func (*RequestHeader) GetPartition ¶
func (m *RequestHeader) GetPartition() uint32
func (*RequestHeader) GetPrimitive ¶ added in v0.2.0
func (m *RequestHeader) GetPrimitive() primitive.PrimitiveId
func (*RequestHeader) GetRequestID ¶
func (m *RequestHeader) GetRequestID() uint64
func (*RequestHeader) GetSessionID ¶
func (m *RequestHeader) GetSessionID() uint64
func (*RequestHeader) GetStreams ¶
func (m *RequestHeader) GetStreams() []StreamHeader
func (*RequestHeader) Marshal ¶
func (m *RequestHeader) Marshal() (dAtA []byte, err error)
func (*RequestHeader) MarshalToSizedBuffer ¶
func (m *RequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RequestHeader) ProtoMessage ¶
func (*RequestHeader) ProtoMessage()
func (*RequestHeader) Reset ¶
func (m *RequestHeader) Reset()
func (*RequestHeader) Size ¶
func (m *RequestHeader) Size() (n int)
func (*RequestHeader) String ¶
func (m *RequestHeader) String() string
func (*RequestHeader) Unmarshal ¶
func (m *RequestHeader) Unmarshal(dAtA []byte) error
func (*RequestHeader) XXX_DiscardUnknown ¶
func (m *RequestHeader) XXX_DiscardUnknown()
func (*RequestHeader) XXX_Marshal ¶
func (m *RequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequestHeader) XXX_Merge ¶
func (m *RequestHeader) XXX_Merge(src proto.Message)
func (*RequestHeader) XXX_Size ¶
func (m *RequestHeader) XXX_Size() int
func (*RequestHeader) XXX_Unmarshal ¶
func (m *RequestHeader) XXX_Unmarshal(b []byte) error
type ResponseHeader ¶
type ResponseHeader struct { SessionID uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` StreamID uint64 `protobuf:"varint,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` ResponseID uint64 `protobuf:"varint,3,opt,name=response_id,json=responseId,proto3" json:"response_id,omitempty"` Index uint64 `protobuf:"varint,4,opt,name=index,proto3" json:"index,omitempty"` Leader string `protobuf:"bytes,5,opt,name=leader,proto3" json:"leader,omitempty"` Status ResponseStatus `protobuf:"varint,6,opt,name=status,proto3,enum=atomix.headers.ResponseStatus" json:"status,omitempty"` Type ResponseType `protobuf:"varint,7,opt,name=type,proto3,enum=atomix.headers.ResponseType" json:"type,omitempty"` Message string `protobuf:"bytes,8,opt,name=message,proto3" json:"message,omitempty"` }
func (*ResponseHeader) Descriptor ¶
func (*ResponseHeader) Descriptor() ([]byte, []int)
func (*ResponseHeader) GetIndex ¶
func (m *ResponseHeader) GetIndex() uint64
func (*ResponseHeader) GetLeader ¶
func (m *ResponseHeader) GetLeader() string
func (*ResponseHeader) GetMessage ¶ added in v0.3.3
func (m *ResponseHeader) GetMessage() string
func (*ResponseHeader) GetResponseID ¶
func (m *ResponseHeader) GetResponseID() uint64
func (*ResponseHeader) GetSessionID ¶
func (m *ResponseHeader) GetSessionID() uint64
func (*ResponseHeader) GetStatus ¶
func (m *ResponseHeader) GetStatus() ResponseStatus
func (*ResponseHeader) GetStreamID ¶
func (m *ResponseHeader) GetStreamID() uint64
func (*ResponseHeader) GetType ¶
func (m *ResponseHeader) GetType() ResponseType
func (*ResponseHeader) Marshal ¶
func (m *ResponseHeader) Marshal() (dAtA []byte, err error)
func (*ResponseHeader) MarshalToSizedBuffer ¶
func (m *ResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResponseHeader) ProtoMessage ¶
func (*ResponseHeader) ProtoMessage()
func (*ResponseHeader) Reset ¶
func (m *ResponseHeader) Reset()
func (*ResponseHeader) Size ¶
func (m *ResponseHeader) Size() (n int)
func (*ResponseHeader) String ¶
func (m *ResponseHeader) String() string
func (*ResponseHeader) Unmarshal ¶
func (m *ResponseHeader) Unmarshal(dAtA []byte) error
func (*ResponseHeader) XXX_DiscardUnknown ¶
func (m *ResponseHeader) XXX_DiscardUnknown()
func (*ResponseHeader) XXX_Marshal ¶
func (m *ResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResponseHeader) XXX_Merge ¶
func (m *ResponseHeader) XXX_Merge(src proto.Message)
func (*ResponseHeader) XXX_Size ¶
func (m *ResponseHeader) XXX_Size() int
func (*ResponseHeader) XXX_Unmarshal ¶
func (m *ResponseHeader) XXX_Unmarshal(b []byte) error
type ResponseStatus ¶
type ResponseStatus int32
const ( ResponseStatus_OK ResponseStatus = 0 ResponseStatus_ERROR ResponseStatus = 1 ResponseStatus_NOT_LEADER ResponseStatus = 2 ResponseStatus_UNKNOWN ResponseStatus = 3 ResponseStatus_CANCELED ResponseStatus = 4 ResponseStatus_NOT_FOUND ResponseStatus = 5 ResponseStatus_ALREADY_EXISTS ResponseStatus = 6 ResponseStatus_UNAUTHORIZED ResponseStatus = 7 ResponseStatus_FORBIDDEN ResponseStatus = 8 ResponseStatus_CONFLICT ResponseStatus = 9 ResponseStatus_INVALID ResponseStatus = 10 ResponseStatus_UNAVAILABLE ResponseStatus = 11 ResponseStatus_NOT_SUPPORTED ResponseStatus = 12 ResponseStatus_TIMEOUT ResponseStatus = 13 ResponseStatus_INTERNAL ResponseStatus = 14 )
func (ResponseStatus) EnumDescriptor ¶
func (ResponseStatus) EnumDescriptor() ([]byte, []int)
func (ResponseStatus) String ¶
func (x ResponseStatus) String() string
type ResponseType ¶
type ResponseType int32
const ( ResponseType_RESPONSE ResponseType = 0 ResponseType_OPEN_STREAM ResponseType = 1 ResponseType_CLOSE_STREAM ResponseType = 2 )
func (ResponseType) EnumDescriptor ¶
func (ResponseType) EnumDescriptor() ([]byte, []int)
func (ResponseType) String ¶
func (x ResponseType) String() string
type StreamHeader ¶
type StreamHeader struct { StreamID uint64 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` ResponseID uint64 `protobuf:"varint,2,opt,name=response_id,json=responseId,proto3" json:"response_id,omitempty"` }
func (*StreamHeader) Descriptor ¶
func (*StreamHeader) Descriptor() ([]byte, []int)
func (*StreamHeader) GetResponseID ¶
func (m *StreamHeader) GetResponseID() uint64
func (*StreamHeader) GetStreamID ¶
func (m *StreamHeader) GetStreamID() uint64
func (*StreamHeader) Marshal ¶
func (m *StreamHeader) Marshal() (dAtA []byte, err error)
func (*StreamHeader) MarshalToSizedBuffer ¶
func (m *StreamHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StreamHeader) ProtoMessage ¶
func (*StreamHeader) ProtoMessage()
func (*StreamHeader) Reset ¶
func (m *StreamHeader) Reset()
func (*StreamHeader) Size ¶
func (m *StreamHeader) Size() (n int)
func (*StreamHeader) String ¶
func (m *StreamHeader) String() string
func (*StreamHeader) Unmarshal ¶
func (m *StreamHeader) Unmarshal(dAtA []byte) error
func (*StreamHeader) XXX_DiscardUnknown ¶
func (m *StreamHeader) XXX_DiscardUnknown()
func (*StreamHeader) XXX_Marshal ¶
func (m *StreamHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamHeader) XXX_Merge ¶
func (m *StreamHeader) XXX_Merge(src proto.Message)
func (*StreamHeader) XXX_Size ¶
func (m *StreamHeader) XXX_Size() int
func (*StreamHeader) XXX_Unmarshal ¶
func (m *StreamHeader) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.