headers

package
v0.3.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 17, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

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) MarshalTo 

func (m *RequestHeader) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *StreamHeader) MarshalTo(dAtA []byte) (int, 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.