atomix-api: github.com/atomix/atomix-api/proto/atomix/headers Index | Files

package headers

import "github.com/atomix/atomix-api/proto/atomix/headers"

Index

Package Files

headers.pb.go

Variables

var (
    ErrInvalidLengthHeaders        = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowHeaders          = fmt.Errorf("proto: integer overflow")
    ErrUnexpectedEndOfGroupHeaders = fmt.Errorf("proto: unexpected end of group")
)
var ResponseStatus_name = map[int32]string{
    0:  "OK",
    1:  "ERROR",
    2:  "NOT_LEADER",
}
var ResponseStatus_value = map[string]int32{
    "OK":         0,
    "ERROR":      1,
    "NOT_LEADER": 2,
}
var ResponseType_name = map[int32]string{
    0:  "RESPONSE",
    1:  "OPEN_STREAM",
    2:  "CLOSE_STREAM",
}
var ResponseType_value = map[string]int32{
    "RESPONSE":     0,
    "OPEN_STREAM":  1,
    "CLOSE_STREAM": 2,
}

type RequestHeader Uses

type RequestHeader struct {
    Partition int32           `protobuf:"varint,6,opt,name=partition,proto3" json:"partition,omitempty"`
    Name      *primitive.Name `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    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,omitempty"`
}

func (*RequestHeader) Descriptor Uses

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

func (*RequestHeader) GetIndex Uses

func (m *RequestHeader) GetIndex() uint64

func (*RequestHeader) GetName Uses

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

func (*RequestHeader) GetPartition Uses

func (m *RequestHeader) GetPartition() int32

func (*RequestHeader) GetRequestID Uses

func (m *RequestHeader) GetRequestID() uint64

func (*RequestHeader) GetSessionID Uses

func (m *RequestHeader) GetSessionID() uint64

func (*RequestHeader) GetStreams Uses

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

func (*RequestHeader) Marshal Uses

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

func (*RequestHeader) MarshalTo Uses

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

func (*RequestHeader) MarshalToSizedBuffer Uses

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

func (*RequestHeader) ProtoMessage Uses

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) Reset Uses

func (m *RequestHeader) Reset()

func (*RequestHeader) Size Uses

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

func (*RequestHeader) String Uses

func (m *RequestHeader) String() string

func (*RequestHeader) Unmarshal Uses

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

func (*RequestHeader) XXX_DiscardUnknown Uses

func (m *RequestHeader) XXX_DiscardUnknown()

func (*RequestHeader) XXX_Marshal Uses

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

func (*RequestHeader) XXX_Merge Uses

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

func (*RequestHeader) XXX_Size Uses

func (m *RequestHeader) XXX_Size() int

func (*RequestHeader) XXX_Unmarshal Uses

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

type ResponseHeader Uses

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"`
}

func (*ResponseHeader) Descriptor Uses

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

func (*ResponseHeader) GetIndex Uses

func (m *ResponseHeader) GetIndex() uint64

func (*ResponseHeader) GetLeader Uses

func (m *ResponseHeader) GetLeader() string

func (*ResponseHeader) GetResponseID Uses

func (m *ResponseHeader) GetResponseID() uint64

func (*ResponseHeader) GetSessionID Uses

func (m *ResponseHeader) GetSessionID() uint64

func (*ResponseHeader) GetStatus Uses

func (m *ResponseHeader) GetStatus() ResponseStatus

func (*ResponseHeader) GetStreamID Uses

func (m *ResponseHeader) GetStreamID() uint64

func (*ResponseHeader) GetType Uses

func (m *ResponseHeader) GetType() ResponseType

func (*ResponseHeader) Marshal Uses

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

func (*ResponseHeader) MarshalTo Uses

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

func (*ResponseHeader) MarshalToSizedBuffer Uses

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

func (*ResponseHeader) ProtoMessage Uses

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) Reset Uses

func (m *ResponseHeader) Reset()

func (*ResponseHeader) Size Uses

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

func (*ResponseHeader) String Uses

func (m *ResponseHeader) String() string

func (*ResponseHeader) Unmarshal Uses

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

func (*ResponseHeader) XXX_DiscardUnknown Uses

func (m *ResponseHeader) XXX_DiscardUnknown()

func (*ResponseHeader) XXX_Marshal Uses

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

func (*ResponseHeader) XXX_Merge Uses

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

func (*ResponseHeader) XXX_Size Uses

func (m *ResponseHeader) XXX_Size() int

func (*ResponseHeader) XXX_Unmarshal Uses

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

type ResponseStatus Uses

type ResponseStatus int32
const (
    ResponseStatus_OK         ResponseStatus = 0
    ResponseStatus_ERROR      ResponseStatus = 1
    ResponseStatus_NOT_LEADER ResponseStatus = 2
)

func (ResponseStatus) EnumDescriptor Uses

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

func (ResponseStatus) String Uses

func (x ResponseStatus) String() string

type ResponseType Uses

type ResponseType int32
const (
    ResponseType_RESPONSE     ResponseType = 0
    ResponseType_OPEN_STREAM  ResponseType = 1
    ResponseType_CLOSE_STREAM ResponseType = 2
)

func (ResponseType) EnumDescriptor Uses

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

func (ResponseType) String Uses

func (x ResponseType) String() string

type StreamHeader Uses

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 Uses

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

func (*StreamHeader) GetResponseID Uses

func (m *StreamHeader) GetResponseID() uint64

func (*StreamHeader) GetStreamID Uses

func (m *StreamHeader) GetStreamID() uint64

func (*StreamHeader) Marshal Uses

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

func (*StreamHeader) MarshalTo Uses

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

func (*StreamHeader) MarshalToSizedBuffer Uses

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

func (*StreamHeader) ProtoMessage Uses

func (*StreamHeader) ProtoMessage()

func (*StreamHeader) Reset Uses

func (m *StreamHeader) Reset()

func (*StreamHeader) Size Uses

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

func (*StreamHeader) String Uses

func (m *StreamHeader) String() string

func (*StreamHeader) Unmarshal Uses

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

func (*StreamHeader) XXX_DiscardUnknown Uses

func (m *StreamHeader) XXX_DiscardUnknown()

func (*StreamHeader) XXX_Marshal Uses

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

func (*StreamHeader) XXX_Merge Uses

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

func (*StreamHeader) XXX_Size Uses

func (m *StreamHeader) XXX_Size() int

func (*StreamHeader) XXX_Unmarshal Uses

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

Package headers imports 7 packages (graph) and is imported by 3 packages. Updated 2020-02-21. Refresh now. Tools for package owners.