headers

package
v0.0.0-...-4e5fb1c Latest Latest
Warning

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

 Go to latest Published: Jan 23, 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",
}
View Source 
var ResponseStatus_value = map[string]int32{
	"OK":         0,
	"ERROR":      1,
	"NOT_LEADER": 2,
}
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 {
	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 

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

func (*RequestHeader) GetIndex 

func (m *RequestHeader) GetIndex() uint64

func (*RequestHeader) GetName 

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

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

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

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.