Documentation ¶
Index ¶
- Variables
- func RegisterAtomicBroadcastServer(s *grpc.Server, srv AtomicBroadcastServer)
- type AtomicBroadcastClient
- type AtomicBroadcastServer
- type AtomicBroadcast_BroadcastClient
- type AtomicBroadcast_BroadcastServer
- type AtomicBroadcast_DeliverClient
- type AtomicBroadcast_DeliverServer
- type BatchSize
- func (*BatchSize) Descriptor() ([]byte, []int)
- func (m *BatchSize) GetAbsoluteMaxBytes() uint32
- func (m *BatchSize) GetMaxMessageCount() uint32
- func (m *BatchSize) GetPreferredMaxBytes() uint32
- func (*BatchSize) ProtoMessage()
- func (m *BatchSize) Reset()
- func (m *BatchSize) String() string
- func (m *BatchSize) XXX_DiscardUnknown()
- func (m *BatchSize) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *BatchSize) XXX_Merge(src proto.Message)
- func (m *BatchSize) XXX_Size() int
- func (m *BatchSize) XXX_Unmarshal(b []byte) error
- type BatchTimeout
- func (*BatchTimeout) Descriptor() ([]byte, []int)
- func (m *BatchTimeout) GetTimeout() string
- func (*BatchTimeout) ProtoMessage()
- func (m *BatchTimeout) Reset()
- func (m *BatchTimeout) String() string
- func (m *BatchTimeout) XXX_DiscardUnknown()
- func (m *BatchTimeout) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *BatchTimeout) XXX_Merge(src proto.Message)
- func (m *BatchTimeout) XXX_Size() int
- func (m *BatchTimeout) XXX_Unmarshal(b []byte) error
- type BroadcastResponse
- func (*BroadcastResponse) Descriptor() ([]byte, []int)
- func (m *BroadcastResponse) GetInfo() string
- func (m *BroadcastResponse) GetStatus() common.Status
- func (*BroadcastResponse) ProtoMessage()
- func (m *BroadcastResponse) Reset()
- func (m *BroadcastResponse) String() string
- func (m *BroadcastResponse) XXX_DiscardUnknown()
- func (m *BroadcastResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *BroadcastResponse) XXX_Merge(src proto.Message)
- func (m *BroadcastResponse) XXX_Size() int
- func (m *BroadcastResponse) XXX_Unmarshal(b []byte) error
- type ChannelRestrictions
- func (*ChannelRestrictions) Descriptor() ([]byte, []int)
- func (m *ChannelRestrictions) GetMaxCount() uint64
- func (*ChannelRestrictions) ProtoMessage()
- func (m *ChannelRestrictions) Reset()
- func (m *ChannelRestrictions) String() string
- func (m *ChannelRestrictions) XXX_DiscardUnknown()
- func (m *ChannelRestrictions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ChannelRestrictions) XXX_Merge(src proto.Message)
- func (m *ChannelRestrictions) XXX_Size() int
- func (m *ChannelRestrictions) XXX_Unmarshal(b []byte) error
- type ConsensusType
- func (*ConsensusType) Descriptor() ([]byte, []int)
- func (m *ConsensusType) GetMetadata() []byte
- func (m *ConsensusType) GetType() string
- func (*ConsensusType) ProtoMessage()
- func (m *ConsensusType) Reset()
- func (m *ConsensusType) String() string
- func (m *ConsensusType) XXX_DiscardUnknown()
- func (m *ConsensusType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ConsensusType) XXX_Merge(src proto.Message)
- func (m *ConsensusType) XXX_Size() int
- func (m *ConsensusType) XXX_Unmarshal(b []byte) error
- type DeliverResponse
- func (*DeliverResponse) Descriptor() ([]byte, []int)
- func (m *DeliverResponse) GetBlock() *common.Block
- func (m *DeliverResponse) GetStatus() common.Status
- func (m *DeliverResponse) GetType() isDeliverResponse_Type
- func (*DeliverResponse) ProtoMessage()
- func (m *DeliverResponse) Reset()
- func (m *DeliverResponse) String() string
- func (m *DeliverResponse) XXX_DiscardUnknown()
- func (m *DeliverResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DeliverResponse) XXX_Merge(src proto.Message)
- func (*DeliverResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *DeliverResponse) XXX_Size() int
- func (m *DeliverResponse) XXX_Unmarshal(b []byte) error
- type DeliverResponse_Block
- type DeliverResponse_Status
- type KafkaBrokers
- func (*KafkaBrokers) Descriptor() ([]byte, []int)
- func (m *KafkaBrokers) GetBrokers() []string
- func (*KafkaBrokers) ProtoMessage()
- func (m *KafkaBrokers) Reset()
- func (m *KafkaBrokers) String() string
- func (m *KafkaBrokers) XXX_DiscardUnknown()
- func (m *KafkaBrokers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *KafkaBrokers) XXX_Merge(src proto.Message)
- func (m *KafkaBrokers) XXX_Size() int
- func (m *KafkaBrokers) XXX_Unmarshal(b []byte) error
- type SeekInfo
- func (*SeekInfo) Descriptor() ([]byte, []int)
- func (m *SeekInfo) GetBehavior() SeekInfo_SeekBehavior
- func (m *SeekInfo) GetStart() *SeekPosition
- func (m *SeekInfo) GetStop() *SeekPosition
- func (*SeekInfo) ProtoMessage()
- func (m *SeekInfo) Reset()
- func (m *SeekInfo) String() string
- func (m *SeekInfo) XXX_DiscardUnknown()
- func (m *SeekInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SeekInfo) XXX_Merge(src proto.Message)
- func (m *SeekInfo) XXX_Size() int
- func (m *SeekInfo) XXX_Unmarshal(b []byte) error
- type SeekInfo_SeekBehavior
- type SeekNewest
- func (*SeekNewest) Descriptor() ([]byte, []int)
- func (*SeekNewest) ProtoMessage()
- func (m *SeekNewest) Reset()
- func (m *SeekNewest) String() string
- func (m *SeekNewest) XXX_DiscardUnknown()
- func (m *SeekNewest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SeekNewest) XXX_Merge(src proto.Message)
- func (m *SeekNewest) XXX_Size() int
- func (m *SeekNewest) XXX_Unmarshal(b []byte) error
- type SeekOldest
- func (*SeekOldest) Descriptor() ([]byte, []int)
- func (*SeekOldest) ProtoMessage()
- func (m *SeekOldest) Reset()
- func (m *SeekOldest) String() string
- func (m *SeekOldest) XXX_DiscardUnknown()
- func (m *SeekOldest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SeekOldest) XXX_Merge(src proto.Message)
- func (m *SeekOldest) XXX_Size() int
- func (m *SeekOldest) XXX_Unmarshal(b []byte) error
- type SeekPosition
- func (*SeekPosition) Descriptor() ([]byte, []int)
- func (m *SeekPosition) GetNewest() *SeekNewest
- func (m *SeekPosition) GetOldest() *SeekOldest
- func (m *SeekPosition) GetSpecified() *SeekSpecified
- func (m *SeekPosition) GetType() isSeekPosition_Type
- func (*SeekPosition) ProtoMessage()
- func (m *SeekPosition) Reset()
- func (m *SeekPosition) String() string
- func (m *SeekPosition) XXX_DiscardUnknown()
- func (m *SeekPosition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SeekPosition) XXX_Merge(src proto.Message)
- func (*SeekPosition) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *SeekPosition) XXX_Size() int
- func (m *SeekPosition) XXX_Unmarshal(b []byte) error
- type SeekPosition_Newest
- type SeekPosition_Oldest
- type SeekPosition_Specified
- type SeekSpecified
- func (*SeekSpecified) Descriptor() ([]byte, []int)
- func (m *SeekSpecified) GetNumber() uint64
- func (*SeekSpecified) ProtoMessage()
- func (m *SeekSpecified) Reset()
- func (m *SeekSpecified) String() string
- func (m *SeekSpecified) XXX_DiscardUnknown()
- func (m *SeekSpecified) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SeekSpecified) XXX_Merge(src proto.Message)
- func (m *SeekSpecified) XXX_Size() int
- func (m *SeekSpecified) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func RegisterAtomicBroadcastServer ¶
func RegisterAtomicBroadcastServer(s *grpc.Server, srv AtomicBroadcastServer)
Types ¶
type AtomicBroadcastClient ¶
type AtomicBroadcastClient interface { // broadcast receives a reply of Acknowledgement for each common.Envelope in order, indicating success or type of failure Broadcast(ctx context.Context, opts ...grpc.CallOption) (AtomicBroadcast_BroadcastClient, error) // deliver first requires an Envelope of type DELIVER_SEEK_INFO with Payload data as a mashaled SeekInfo message, then a stream of block replies is received. Deliver(ctx context.Context, opts ...grpc.CallOption) (AtomicBroadcast_DeliverClient, error) }
AtomicBroadcastClient is the client API for AtomicBroadcast service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAtomicBroadcastClient ¶
func NewAtomicBroadcastClient(cc *grpc.ClientConn) AtomicBroadcastClient
type AtomicBroadcastServer ¶
type AtomicBroadcastServer interface { // broadcast receives a reply of Acknowledgement for each common.Envelope in order, indicating success or type of failure Broadcast(AtomicBroadcast_BroadcastServer) error // deliver first requires an Envelope of type DELIVER_SEEK_INFO with Payload data as a mashaled SeekInfo message, then a stream of block replies is received. Deliver(AtomicBroadcast_DeliverServer) error }
AtomicBroadcastServer is the server API for AtomicBroadcast service.
type AtomicBroadcast_BroadcastClient ¶
type AtomicBroadcast_BroadcastClient interface { Send(*common.Envelope) error Recv() (*BroadcastResponse, error) grpc.ClientStream }
type AtomicBroadcast_BroadcastServer ¶
type AtomicBroadcast_BroadcastServer interface { Send(*BroadcastResponse) error Recv() (*common.Envelope, error) grpc.ServerStream }
type AtomicBroadcast_DeliverClient ¶
type AtomicBroadcast_DeliverClient interface { Send(*common.Envelope) error Recv() (*DeliverResponse, error) grpc.ClientStream }
type AtomicBroadcast_DeliverServer ¶
type AtomicBroadcast_DeliverServer interface { Send(*DeliverResponse) error Recv() (*common.Envelope, error) grpc.ServerStream }
type BatchSize ¶
type BatchSize struct { // Simply specified as number of messages for now, in the future // we may want to allow this to be specified by size in bytes MaxMessageCount uint32 `protobuf:"varint,1,opt,name=max_message_count,json=maxMessageCount,proto3" json:"max_message_count,omitempty"` // The byte count of the serialized messages in a batch cannot // exceed this value. AbsoluteMaxBytes uint32 `protobuf:"varint,2,opt,name=absolute_max_bytes,json=absoluteMaxBytes,proto3" json:"absolute_max_bytes,omitempty"` // The byte count of the serialized messages in a batch should not // exceed this value. PreferredMaxBytes uint32 `protobuf:"varint,3,opt,name=preferred_max_bytes,json=preferredMaxBytes,proto3" json:"preferred_max_bytes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BatchSize) XXX_Marshal ¶
type BatchTimeout ¶
type BatchTimeout struct { // Any duration string parseable by ParseDuration(): // https://golang.org/pkg/time/#ParseDuration Timeout string `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BatchTimeout) Descriptor ¶
func (*BatchTimeout) Descriptor() ([]byte, []int)
func (*BatchTimeout) GetTimeout ¶
func (m *BatchTimeout) GetTimeout() string
func (*BatchTimeout) ProtoMessage ¶
func (*BatchTimeout) ProtoMessage()
func (*BatchTimeout) Reset ¶
func (m *BatchTimeout) Reset()
func (*BatchTimeout) String ¶
func (m *BatchTimeout) String() string
func (*BatchTimeout) XXX_DiscardUnknown ¶
func (m *BatchTimeout) XXX_DiscardUnknown()
func (*BatchTimeout) XXX_Marshal ¶
func (m *BatchTimeout) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BatchTimeout) XXX_Merge ¶
func (dst *BatchTimeout) XXX_Merge(src proto.Message)
func (*BatchTimeout) XXX_Size ¶
func (m *BatchTimeout) XXX_Size() int
func (*BatchTimeout) XXX_Unmarshal ¶
func (m *BatchTimeout) XXX_Unmarshal(b []byte) error
type BroadcastResponse ¶
type BroadcastResponse struct { // Status code, which may be used to programatically respond to success/failure Status common.Status `protobuf:"varint,1,opt,name=status,proto3,enum=common.Status" json:"status,omitempty"` // Info string which may contain additional information about the status returned Info string `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BroadcastResponse) Descriptor ¶
func (*BroadcastResponse) Descriptor() ([]byte, []int)
func (*BroadcastResponse) GetInfo ¶
func (m *BroadcastResponse) GetInfo() string
func (*BroadcastResponse) GetStatus ¶
func (m *BroadcastResponse) GetStatus() common.Status
func (*BroadcastResponse) ProtoMessage ¶
func (*BroadcastResponse) ProtoMessage()
func (*BroadcastResponse) Reset ¶
func (m *BroadcastResponse) Reset()
func (*BroadcastResponse) String ¶
func (m *BroadcastResponse) String() string
func (*BroadcastResponse) XXX_DiscardUnknown ¶
func (m *BroadcastResponse) XXX_DiscardUnknown()
func (*BroadcastResponse) XXX_Marshal ¶
func (m *BroadcastResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BroadcastResponse) XXX_Merge ¶
func (dst *BroadcastResponse) XXX_Merge(src proto.Message)
func (*BroadcastResponse) XXX_Size ¶
func (m *BroadcastResponse) XXX_Size() int
func (*BroadcastResponse) XXX_Unmarshal ¶
func (m *BroadcastResponse) XXX_Unmarshal(b []byte) error
type ChannelRestrictions ¶
type ChannelRestrictions struct { MaxCount uint64 `protobuf:"varint,1,opt,name=max_count,json=maxCount,proto3" json:"max_count,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ChannelRestrictions is the mssage which conveys restrictions on channel creation for an orderer
func (*ChannelRestrictions) Descriptor ¶
func (*ChannelRestrictions) Descriptor() ([]byte, []int)
func (*ChannelRestrictions) GetMaxCount ¶
func (m *ChannelRestrictions) GetMaxCount() uint64
func (*ChannelRestrictions) ProtoMessage ¶
func (*ChannelRestrictions) ProtoMessage()
func (*ChannelRestrictions) Reset ¶
func (m *ChannelRestrictions) Reset()
func (*ChannelRestrictions) String ¶
func (m *ChannelRestrictions) String() string
func (*ChannelRestrictions) XXX_DiscardUnknown ¶
func (m *ChannelRestrictions) XXX_DiscardUnknown()
func (*ChannelRestrictions) XXX_Marshal ¶
func (m *ChannelRestrictions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelRestrictions) XXX_Merge ¶
func (dst *ChannelRestrictions) XXX_Merge(src proto.Message)
func (*ChannelRestrictions) XXX_Size ¶
func (m *ChannelRestrictions) XXX_Size() int
func (*ChannelRestrictions) XXX_Unmarshal ¶
func (m *ChannelRestrictions) XXX_Unmarshal(b []byte) error
type ConsensusType ¶
type ConsensusType struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` // Opaque metadata, dependent on the consensus type. Metadata []byte `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConsensusType) Descriptor ¶
func (*ConsensusType) Descriptor() ([]byte, []int)
func (*ConsensusType) GetMetadata ¶
func (m *ConsensusType) GetMetadata() []byte
func (*ConsensusType) GetType ¶
func (m *ConsensusType) GetType() string
func (*ConsensusType) ProtoMessage ¶
func (*ConsensusType) ProtoMessage()
func (*ConsensusType) Reset ¶
func (m *ConsensusType) Reset()
func (*ConsensusType) String ¶
func (m *ConsensusType) String() string
func (*ConsensusType) XXX_DiscardUnknown ¶
func (m *ConsensusType) XXX_DiscardUnknown()
func (*ConsensusType) XXX_Marshal ¶
func (m *ConsensusType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConsensusType) XXX_Merge ¶
func (dst *ConsensusType) XXX_Merge(src proto.Message)
func (*ConsensusType) XXX_Size ¶
func (m *ConsensusType) XXX_Size() int
func (*ConsensusType) XXX_Unmarshal ¶
func (m *ConsensusType) XXX_Unmarshal(b []byte) error
type DeliverResponse ¶
type DeliverResponse struct { // Types that are valid to be assigned to Type: // *DeliverResponse_Status // *DeliverResponse_Block Type isDeliverResponse_Type `protobuf_oneof:"Type"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeliverResponse) Descriptor ¶
func (*DeliverResponse) Descriptor() ([]byte, []int)
func (*DeliverResponse) GetBlock ¶
func (m *DeliverResponse) GetBlock() *common.Block
func (*DeliverResponse) GetStatus ¶
func (m *DeliverResponse) GetStatus() common.Status
func (*DeliverResponse) GetType ¶
func (m *DeliverResponse) GetType() isDeliverResponse_Type
func (*DeliverResponse) ProtoMessage ¶
func (*DeliverResponse) ProtoMessage()
func (*DeliverResponse) Reset ¶
func (m *DeliverResponse) Reset()
func (*DeliverResponse) String ¶
func (m *DeliverResponse) String() string
func (*DeliverResponse) XXX_DiscardUnknown ¶
func (m *DeliverResponse) XXX_DiscardUnknown()
func (*DeliverResponse) XXX_Marshal ¶
func (m *DeliverResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeliverResponse) XXX_Merge ¶
func (dst *DeliverResponse) XXX_Merge(src proto.Message)
func (*DeliverResponse) XXX_OneofFuncs ¶
func (*DeliverResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*DeliverResponse) XXX_Size ¶
func (m *DeliverResponse) XXX_Size() int
func (*DeliverResponse) XXX_Unmarshal ¶
func (m *DeliverResponse) XXX_Unmarshal(b []byte) error
type DeliverResponse_Block ¶
type DeliverResponse_Status ¶
type KafkaBrokers ¶
type KafkaBrokers struct { // Each broker here should be identified using the (IP|host):port notation, // e.g. 127.0.0.1:7050, or localhost:7050 are valid entries Brokers []string `protobuf:"bytes,1,rep,name=brokers,proto3" json:"brokers,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Carries a list of bootstrap brokers, i.e. this is not the exclusive set of brokers an ordering service
func (*KafkaBrokers) Descriptor ¶
func (*KafkaBrokers) Descriptor() ([]byte, []int)
func (*KafkaBrokers) GetBrokers ¶
func (m *KafkaBrokers) GetBrokers() []string
func (*KafkaBrokers) ProtoMessage ¶
func (*KafkaBrokers) ProtoMessage()
func (*KafkaBrokers) Reset ¶
func (m *KafkaBrokers) Reset()
func (*KafkaBrokers) String ¶
func (m *KafkaBrokers) String() string
func (*KafkaBrokers) XXX_DiscardUnknown ¶
func (m *KafkaBrokers) XXX_DiscardUnknown()
func (*KafkaBrokers) XXX_Marshal ¶
func (m *KafkaBrokers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KafkaBrokers) XXX_Merge ¶
func (dst *KafkaBrokers) XXX_Merge(src proto.Message)
func (*KafkaBrokers) XXX_Size ¶
func (m *KafkaBrokers) XXX_Size() int
func (*KafkaBrokers) XXX_Unmarshal ¶
func (m *KafkaBrokers) XXX_Unmarshal(b []byte) error
type SeekInfo ¶
type SeekInfo struct { Start *SeekPosition `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"` Stop *SeekPosition `protobuf:"bytes,2,opt,name=stop,proto3" json:"stop,omitempty"` Behavior SeekInfo_SeekBehavior `protobuf:"varint,3,opt,name=behavior,proto3,enum=orderer.SeekInfo_SeekBehavior" json:"behavior,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SeekInfo specifies the range of requested blocks to return If the start position is not found, an error is immediately returned Otherwise, blocks are returned until a missing block is encountered, then behavior is dictated by the SeekBehavior specified. If BLOCK_UNTIL_READY is specified, the reply will block until the requested blocks are available, if FAIL_IF_NOT_READY is specified, the reply will return an error indicating that the block is not found. To request that all blocks be returned indefinitely as they are created, behavior should be set to BLOCK_UNTIL_READY and the stop should be set to specified with a number of MAX_UINT64
func (*SeekInfo) GetBehavior ¶
func (m *SeekInfo) GetBehavior() SeekInfo_SeekBehavior
func (*SeekInfo) GetStart ¶
func (m *SeekInfo) GetStart() *SeekPosition
func (*SeekInfo) GetStop ¶
func (m *SeekInfo) GetStop() *SeekPosition
func (*SeekInfo) XXX_Marshal ¶
type SeekInfo_SeekBehavior ¶
type SeekInfo_SeekBehavior int32
const ( SeekInfo_BLOCK_UNTIL_READY SeekInfo_SeekBehavior = 0 SeekInfo_FAIL_IF_NOT_READY SeekInfo_SeekBehavior = 1 )
func (SeekInfo_SeekBehavior) EnumDescriptor ¶
func (SeekInfo_SeekBehavior) EnumDescriptor() ([]byte, []int)
func (SeekInfo_SeekBehavior) String ¶
func (x SeekInfo_SeekBehavior) String() string
type SeekNewest ¶
type SeekNewest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SeekNewest) Descriptor ¶
func (*SeekNewest) Descriptor() ([]byte, []int)
func (*SeekNewest) ProtoMessage ¶
func (*SeekNewest) ProtoMessage()
func (*SeekNewest) Reset ¶
func (m *SeekNewest) Reset()
func (*SeekNewest) String ¶
func (m *SeekNewest) String() string
func (*SeekNewest) XXX_DiscardUnknown ¶
func (m *SeekNewest) XXX_DiscardUnknown()
func (*SeekNewest) XXX_Marshal ¶
func (m *SeekNewest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SeekNewest) XXX_Merge ¶
func (dst *SeekNewest) XXX_Merge(src proto.Message)
func (*SeekNewest) XXX_Size ¶
func (m *SeekNewest) XXX_Size() int
func (*SeekNewest) XXX_Unmarshal ¶
func (m *SeekNewest) XXX_Unmarshal(b []byte) error
type SeekOldest ¶
type SeekOldest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SeekOldest) Descriptor ¶
func (*SeekOldest) Descriptor() ([]byte, []int)
func (*SeekOldest) ProtoMessage ¶
func (*SeekOldest) ProtoMessage()
func (*SeekOldest) Reset ¶
func (m *SeekOldest) Reset()
func (*SeekOldest) String ¶
func (m *SeekOldest) String() string
func (*SeekOldest) XXX_DiscardUnknown ¶
func (m *SeekOldest) XXX_DiscardUnknown()
func (*SeekOldest) XXX_Marshal ¶
func (m *SeekOldest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SeekOldest) XXX_Merge ¶
func (dst *SeekOldest) XXX_Merge(src proto.Message)
func (*SeekOldest) XXX_Size ¶
func (m *SeekOldest) XXX_Size() int
func (*SeekOldest) XXX_Unmarshal ¶
func (m *SeekOldest) XXX_Unmarshal(b []byte) error
type SeekPosition ¶
type SeekPosition struct { // Types that are valid to be assigned to Type: // *SeekPosition_Newest // *SeekPosition_Oldest // *SeekPosition_Specified Type isSeekPosition_Type `protobuf_oneof:"Type"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SeekPosition) Descriptor ¶
func (*SeekPosition) Descriptor() ([]byte, []int)
func (*SeekPosition) GetNewest ¶
func (m *SeekPosition) GetNewest() *SeekNewest
func (*SeekPosition) GetOldest ¶
func (m *SeekPosition) GetOldest() *SeekOldest
func (*SeekPosition) GetSpecified ¶
func (m *SeekPosition) GetSpecified() *SeekSpecified
func (*SeekPosition) GetType ¶
func (m *SeekPosition) GetType() isSeekPosition_Type
func (*SeekPosition) ProtoMessage ¶
func (*SeekPosition) ProtoMessage()
func (*SeekPosition) Reset ¶
func (m *SeekPosition) Reset()
func (*SeekPosition) String ¶
func (m *SeekPosition) String() string
func (*SeekPosition) XXX_DiscardUnknown ¶
func (m *SeekPosition) XXX_DiscardUnknown()
func (*SeekPosition) XXX_Marshal ¶
func (m *SeekPosition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SeekPosition) XXX_Merge ¶
func (dst *SeekPosition) XXX_Merge(src proto.Message)
func (*SeekPosition) XXX_OneofFuncs ¶
func (*SeekPosition) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*SeekPosition) XXX_Size ¶
func (m *SeekPosition) XXX_Size() int
func (*SeekPosition) XXX_Unmarshal ¶
func (m *SeekPosition) XXX_Unmarshal(b []byte) error
type SeekPosition_Newest ¶
type SeekPosition_Newest struct {
Newest *SeekNewest `protobuf:"bytes,1,opt,name=newest,proto3,oneof"`
}
type SeekPosition_Oldest ¶
type SeekPosition_Oldest struct {
Oldest *SeekOldest `protobuf:"bytes,2,opt,name=oldest,proto3,oneof"`
}
type SeekPosition_Specified ¶
type SeekPosition_Specified struct {
Specified *SeekSpecified `protobuf:"bytes,3,opt,name=specified,proto3,oneof"`
}
type SeekSpecified ¶
type SeekSpecified struct { Number uint64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SeekSpecified) Descriptor ¶
func (*SeekSpecified) Descriptor() ([]byte, []int)
func (*SeekSpecified) GetNumber ¶
func (m *SeekSpecified) GetNumber() uint64
func (*SeekSpecified) ProtoMessage ¶
func (*SeekSpecified) ProtoMessage()
func (*SeekSpecified) Reset ¶
func (m *SeekSpecified) Reset()
func (*SeekSpecified) String ¶
func (m *SeekSpecified) String() string
func (*SeekSpecified) XXX_DiscardUnknown ¶
func (m *SeekSpecified) XXX_DiscardUnknown()
func (*SeekSpecified) XXX_Marshal ¶
func (m *SeekSpecified) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SeekSpecified) XXX_Merge ¶
func (dst *SeekSpecified) XXX_Merge(src proto.Message)
func (*SeekSpecified) XXX_Size ¶
func (m *SeekSpecified) XXX_Size() int
func (*SeekSpecified) XXX_Unmarshal ¶
func (m *SeekSpecified) XXX_Unmarshal(b []byte) error