Documentation
¶
Index ¶
- Variables
- func RegisterAtomicBroadcastServer(s *grpc.Server, srv AtomicBroadcastServer)
- func RegisterClusterServer(s *grpc.Server, srv ClusterServer)
- 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 ClusterClient
- type ClusterServer
- type Cluster_SubmitClient
- type Cluster_SubmitServer
- 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 (ct *ConsensusType) VariablyOpaqueFieldProto(name string) (proto.Message, error)
- func (ct *ConsensusType) VariablyOpaqueFields() []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 ConsensusTypeMetadataFactory
- 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 DynamicOrdererConfigValue
- type DynamicOrdererGroup
- type DynamicOrdererGroupFactory
- type DynamicOrdererOrgConfigValue
- type DynamicOrdererOrgGroup
- 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 KafkaMessage
- func (*KafkaMessage) Descriptor() ([]byte, []int)
- func (m *KafkaMessage) GetConnect() *KafkaMessageConnect
- func (m *KafkaMessage) GetRegular() *KafkaMessageRegular
- func (m *KafkaMessage) GetTimeToCut() *KafkaMessageTimeToCut
- func (m *KafkaMessage) GetType() isKafkaMessage_Type
- func (*KafkaMessage) ProtoMessage()
- func (m *KafkaMessage) Reset()
- func (m *KafkaMessage) String() string
- func (m *KafkaMessage) XXX_DiscardUnknown()
- func (m *KafkaMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *KafkaMessage) XXX_Merge(src proto.Message)
- func (*KafkaMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *KafkaMessage) XXX_Size() int
- func (m *KafkaMessage) XXX_Unmarshal(b []byte) error
- type KafkaMessageConnect
- func (*KafkaMessageConnect) Descriptor() ([]byte, []int)
- func (m *KafkaMessageConnect) GetPayload() []byte
- func (*KafkaMessageConnect) ProtoMessage()
- func (m *KafkaMessageConnect) Reset()
- func (m *KafkaMessageConnect) String() string
- func (m *KafkaMessageConnect) XXX_DiscardUnknown()
- func (m *KafkaMessageConnect) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *KafkaMessageConnect) XXX_Merge(src proto.Message)
- func (m *KafkaMessageConnect) XXX_Size() int
- func (m *KafkaMessageConnect) XXX_Unmarshal(b []byte) error
- type KafkaMessageRegular
- func (*KafkaMessageRegular) Descriptor() ([]byte, []int)
- func (m *KafkaMessageRegular) GetClass() KafkaMessageRegular_Class
- func (m *KafkaMessageRegular) GetConfigSeq() uint64
- func (m *KafkaMessageRegular) GetOriginalOffset() int64
- func (m *KafkaMessageRegular) GetPayload() []byte
- func (*KafkaMessageRegular) ProtoMessage()
- func (m *KafkaMessageRegular) Reset()
- func (m *KafkaMessageRegular) String() string
- func (m *KafkaMessageRegular) XXX_DiscardUnknown()
- func (m *KafkaMessageRegular) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *KafkaMessageRegular) XXX_Merge(src proto.Message)
- func (m *KafkaMessageRegular) XXX_Size() int
- func (m *KafkaMessageRegular) XXX_Unmarshal(b []byte) error
- type KafkaMessageRegular_Class
- type KafkaMessageTimeToCut
- func (*KafkaMessageTimeToCut) Descriptor() ([]byte, []int)
- func (m *KafkaMessageTimeToCut) GetBlockNumber() uint64
- func (*KafkaMessageTimeToCut) ProtoMessage()
- func (m *KafkaMessageTimeToCut) Reset()
- func (m *KafkaMessageTimeToCut) String() string
- func (m *KafkaMessageTimeToCut) XXX_DiscardUnknown()
- func (m *KafkaMessageTimeToCut) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *KafkaMessageTimeToCut) XXX_Merge(src proto.Message)
- func (m *KafkaMessageTimeToCut) XXX_Size() int
- func (m *KafkaMessageTimeToCut) XXX_Unmarshal(b []byte) error
- type KafkaMessage_Connect
- type KafkaMessage_Regular
- type KafkaMessage_TimeToCut
- type KafkaMetadata
- func (*KafkaMetadata) Descriptor() ([]byte, []int)
- func (m *KafkaMetadata) GetLastOffsetPersisted() int64
- func (m *KafkaMetadata) GetLastOriginalOffsetProcessed() int64
- func (m *KafkaMetadata) GetLastResubmittedConfigOffset() int64
- func (*KafkaMetadata) ProtoMessage()
- func (m *KafkaMetadata) Reset()
- func (m *KafkaMetadata) String() string
- func (m *KafkaMetadata) XXX_DiscardUnknown()
- func (m *KafkaMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *KafkaMetadata) XXX_Merge(src proto.Message)
- func (m *KafkaMetadata) XXX_Size() int
- func (m *KafkaMetadata) 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
- type StepRequest
- func (*StepRequest) Descriptor() ([]byte, []int)
- func (m *StepRequest) GetChannel() string
- func (m *StepRequest) GetPayload() []byte
- func (*StepRequest) ProtoMessage()
- func (m *StepRequest) Reset()
- func (m *StepRequest) String() string
- func (m *StepRequest) XXX_DiscardUnknown()
- func (m *StepRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StepRequest) XXX_Merge(src proto.Message)
- func (m *StepRequest) XXX_Size() int
- func (m *StepRequest) XXX_Unmarshal(b []byte) error
- type StepResponse
- func (*StepResponse) Descriptor() ([]byte, []int)
- func (m *StepResponse) GetPayload() []byte
- func (*StepResponse) ProtoMessage()
- func (m *StepResponse) Reset()
- func (m *StepResponse) String() string
- func (m *StepResponse) XXX_DiscardUnknown()
- func (m *StepResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StepResponse) XXX_Merge(src proto.Message)
- func (m *StepResponse) XXX_Size() int
- func (m *StepResponse) XXX_Unmarshal(b []byte) error
- type SubmitRequest
- func (*SubmitRequest) Descriptor() ([]byte, []int)
- func (m *SubmitRequest) GetChannel() string
- func (m *SubmitRequest) GetContent() *common.Envelope
- func (m *SubmitRequest) GetLastValidationSeq() uint64
- func (*SubmitRequest) ProtoMessage()
- func (m *SubmitRequest) Reset()
- func (m *SubmitRequest) String() string
- func (m *SubmitRequest) XXX_DiscardUnknown()
- func (m *SubmitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SubmitRequest) XXX_Merge(src proto.Message)
- func (m *SubmitRequest) XXX_Size() int
- func (m *SubmitRequest) XXX_Unmarshal(b []byte) error
- type SubmitResponse
- func (*SubmitResponse) Descriptor() ([]byte, []int)
- func (m *SubmitResponse) GetInfo() string
- func (m *SubmitResponse) GetStatus() common.Status
- func (*SubmitResponse) ProtoMessage()
- func (m *SubmitResponse) Reset()
- func (m *SubmitResponse) String() string
- func (m *SubmitResponse) XXX_DiscardUnknown()
- func (m *SubmitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SubmitResponse) XXX_Merge(src proto.Message)
- func (m *SubmitResponse) XXX_Size() int
- func (m *SubmitResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ConsensusTypeMetadataMap = map[string]ConsensusTypeMetadataFactory{}
ConsensuTypeMetadataMap should have consensus implementations register their metadata message factories
var KafkaMessageRegular_Class_name = map[int32]string{
0: "UNKNOWN",
1: "NORMAL",
2: "CONFIG",
}
var KafkaMessageRegular_Class_value = map[string]int32{
"UNKNOWN": 0,
"NORMAL": 1,
"CONFIG": 2,
}
var SeekInfo_SeekBehavior_name = map[int32]string{
0: "BLOCK_UNTIL_READY",
1: "FAIL_IF_NOT_READY",
}
var SeekInfo_SeekBehavior_value = map[string]int32{
"BLOCK_UNTIL_READY": 0,
"FAIL_IF_NOT_READY": 1,
}
Functions ¶
func RegisterAtomicBroadcastServer ¶
func RegisterAtomicBroadcastServer(s *grpc.Server, srv AtomicBroadcastServer)
func RegisterClusterServer ¶
func RegisterClusterServer(s *grpc.Server, srv ClusterServer)
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) }
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 }
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" 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" 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" json:"preferred_max_bytes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BatchSize) Descriptor ¶
func (*BatchSize) GetAbsoluteMaxBytes ¶
func (*BatchSize) GetMaxMessageCount ¶
func (*BatchSize) GetPreferredMaxBytes ¶
func (*BatchSize) ProtoMessage ¶
func (*BatchSize) ProtoMessage()
func (*BatchSize) XXX_DiscardUnknown ¶
func (m *BatchSize) XXX_DiscardUnknown()
func (*BatchSize) XXX_Marshal ¶
func (*BatchSize) XXX_Unmarshal ¶
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" 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,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" 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" 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 ClusterClient ¶
type ClusterClient interface { // Submit submits transactions to a cluster member Submit(ctx context.Context, opts ...grpc.CallOption) (Cluster_SubmitClient, error) // Step passes an implementation-specific message to another cluster member. Step(ctx context.Context, in *StepRequest, opts ...grpc.CallOption) (*StepResponse, error) }
func NewClusterClient ¶
func NewClusterClient(cc *grpc.ClientConn) ClusterClient
type ClusterServer ¶
type ClusterServer interface { // Submit submits transactions to a cluster member Submit(Cluster_SubmitServer) error // Step passes an implementation-specific message to another cluster member. Step(context.Context, *StepRequest) (*StepResponse, error) }
type Cluster_SubmitClient ¶
type Cluster_SubmitClient interface { Send(*SubmitRequest) error Recv() (*SubmitResponse, error) grpc.ClientStream }
type Cluster_SubmitServer ¶
type Cluster_SubmitServer interface { Send(*SubmitResponse) error Recv() (*SubmitRequest, error) grpc.ServerStream }
type ConsensusType ¶
type ConsensusType struct { Type string `protobuf:"bytes,1,opt,name=type" 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) VariablyOpaqueFieldProto ¶
func (ct *ConsensusType) VariablyOpaqueFieldProto(name string) (proto.Message, error)
func (*ConsensusType) VariablyOpaqueFields ¶
func (ct *ConsensusType) VariablyOpaqueFields() []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 DynamicOrdererConfigValue ¶
type DynamicOrdererConfigValue struct { *common.ConfigValue // contains filtered or unexported fields }
func (*DynamicOrdererConfigValue) VariablyOpaqueFieldProto ¶
func (docv *DynamicOrdererConfigValue) VariablyOpaqueFieldProto(name string) (proto.Message, error)
type DynamicOrdererGroup ¶
type DynamicOrdererGroup struct {
*common.ConfigGroup
}
func (*DynamicOrdererGroup) DynamicMapFieldProto ¶
type DynamicOrdererGroupFactory ¶
type DynamicOrdererGroupFactory struct{}
func (DynamicOrdererGroupFactory) DynamicConfigGroup ¶
func (dogf DynamicOrdererGroupFactory) DynamicConfigGroup(cg *common.ConfigGroup) proto.Message
type DynamicOrdererOrgConfigValue ¶
type DynamicOrdererOrgConfigValue struct { *common.ConfigValue // contains filtered or unexported fields }
func (*DynamicOrdererOrgConfigValue) VariablyOpaqueFieldProto ¶
func (doocv *DynamicOrdererOrgConfigValue) VariablyOpaqueFieldProto(name string) (proto.Message, error)
type DynamicOrdererOrgGroup ¶
type DynamicOrdererOrgGroup struct {
*common.ConfigGroup
}
func (*DynamicOrdererOrgGroup) DynamicMapFieldProto ¶
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" 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 KafkaMessage ¶
type KafkaMessage struct { // Types that are valid to be assigned to Type: // *KafkaMessage_Regular // *KafkaMessage_TimeToCut // *KafkaMessage_Connect Type isKafkaMessage_Type `protobuf_oneof:"Type"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KafkaMessage is a wrapper type for the messages that the Kafka-based orderer deals with.
func (*KafkaMessage) Descriptor ¶
func (*KafkaMessage) Descriptor() ([]byte, []int)
func (*KafkaMessage) GetConnect ¶
func (m *KafkaMessage) GetConnect() *KafkaMessageConnect
func (*KafkaMessage) GetRegular ¶
func (m *KafkaMessage) GetRegular() *KafkaMessageRegular
func (*KafkaMessage) GetTimeToCut ¶
func (m *KafkaMessage) GetTimeToCut() *KafkaMessageTimeToCut
func (*KafkaMessage) GetType ¶
func (m *KafkaMessage) GetType() isKafkaMessage_Type
func (*KafkaMessage) ProtoMessage ¶
func (*KafkaMessage) ProtoMessage()
func (*KafkaMessage) Reset ¶
func (m *KafkaMessage) Reset()
func (*KafkaMessage) String ¶
func (m *KafkaMessage) String() string
func (*KafkaMessage) XXX_DiscardUnknown ¶
func (m *KafkaMessage) XXX_DiscardUnknown()
func (*KafkaMessage) XXX_Marshal ¶
func (m *KafkaMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KafkaMessage) XXX_Merge ¶
func (dst *KafkaMessage) XXX_Merge(src proto.Message)
func (*KafkaMessage) XXX_OneofFuncs ¶
func (*KafkaMessage) 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 (*KafkaMessage) XXX_Size ¶
func (m *KafkaMessage) XXX_Size() int
func (*KafkaMessage) XXX_Unmarshal ¶
func (m *KafkaMessage) XXX_Unmarshal(b []byte) error
type KafkaMessageConnect ¶
type KafkaMessageConnect struct { Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KafkaMessageConnect is posted by an orderer upon booting up. It is used to prevent the panic that would be caused if we were to consume an empty partition. It is ignored by all orderers when processing the partition.
func (*KafkaMessageConnect) Descriptor ¶
func (*KafkaMessageConnect) Descriptor() ([]byte, []int)
func (*KafkaMessageConnect) GetPayload ¶
func (m *KafkaMessageConnect) GetPayload() []byte
func (*KafkaMessageConnect) ProtoMessage ¶
func (*KafkaMessageConnect) ProtoMessage()
func (*KafkaMessageConnect) Reset ¶
func (m *KafkaMessageConnect) Reset()
func (*KafkaMessageConnect) String ¶
func (m *KafkaMessageConnect) String() string
func (*KafkaMessageConnect) XXX_DiscardUnknown ¶
func (m *KafkaMessageConnect) XXX_DiscardUnknown()
func (*KafkaMessageConnect) XXX_Marshal ¶
func (m *KafkaMessageConnect) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KafkaMessageConnect) XXX_Merge ¶
func (dst *KafkaMessageConnect) XXX_Merge(src proto.Message)
func (*KafkaMessageConnect) XXX_Size ¶
func (m *KafkaMessageConnect) XXX_Size() int
func (*KafkaMessageConnect) XXX_Unmarshal ¶
func (m *KafkaMessageConnect) XXX_Unmarshal(b []byte) error
type KafkaMessageRegular ¶
type KafkaMessageRegular struct { Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` ConfigSeq uint64 `protobuf:"varint,2,opt,name=config_seq,json=configSeq" json:"config_seq,omitempty"` Class KafkaMessageRegular_Class `protobuf:"varint,3,opt,name=class,enum=orderer.KafkaMessageRegular_Class" json:"class,omitempty"` OriginalOffset int64 `protobuf:"varint,4,opt,name=original_offset,json=originalOffset" json:"original_offset,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KafkaMessageRegular wraps a marshalled envelope.
func (*KafkaMessageRegular) Descriptor ¶
func (*KafkaMessageRegular) Descriptor() ([]byte, []int)
func (*KafkaMessageRegular) GetClass ¶
func (m *KafkaMessageRegular) GetClass() KafkaMessageRegular_Class
func (*KafkaMessageRegular) GetConfigSeq ¶
func (m *KafkaMessageRegular) GetConfigSeq() uint64
func (*KafkaMessageRegular) GetOriginalOffset ¶
func (m *KafkaMessageRegular) GetOriginalOffset() int64
func (*KafkaMessageRegular) GetPayload ¶
func (m *KafkaMessageRegular) GetPayload() []byte
func (*KafkaMessageRegular) ProtoMessage ¶
func (*KafkaMessageRegular) ProtoMessage()
func (*KafkaMessageRegular) Reset ¶
func (m *KafkaMessageRegular) Reset()
func (*KafkaMessageRegular) String ¶
func (m *KafkaMessageRegular) String() string
func (*KafkaMessageRegular) XXX_DiscardUnknown ¶
func (m *KafkaMessageRegular) XXX_DiscardUnknown()
func (*KafkaMessageRegular) XXX_Marshal ¶
func (m *KafkaMessageRegular) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KafkaMessageRegular) XXX_Merge ¶
func (dst *KafkaMessageRegular) XXX_Merge(src proto.Message)
func (*KafkaMessageRegular) XXX_Size ¶
func (m *KafkaMessageRegular) XXX_Size() int
func (*KafkaMessageRegular) XXX_Unmarshal ¶
func (m *KafkaMessageRegular) XXX_Unmarshal(b []byte) error
type KafkaMessageRegular_Class ¶
type KafkaMessageRegular_Class int32
const ( KafkaMessageRegular_UNKNOWN KafkaMessageRegular_Class = 0 KafkaMessageRegular_NORMAL KafkaMessageRegular_Class = 1 KafkaMessageRegular_CONFIG KafkaMessageRegular_Class = 2 )
func (KafkaMessageRegular_Class) EnumDescriptor ¶
func (KafkaMessageRegular_Class) EnumDescriptor() ([]byte, []int)
func (KafkaMessageRegular_Class) String ¶
func (x KafkaMessageRegular_Class) String() string
type KafkaMessageTimeToCut ¶
type KafkaMessageTimeToCut struct { BlockNumber uint64 `protobuf:"varint,1,opt,name=block_number,json=blockNumber" json:"block_number,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KafkaMessageTimeToCut is used to signal to the orderers that it is time to cut block <block_number>.
func (*KafkaMessageTimeToCut) Descriptor ¶
func (*KafkaMessageTimeToCut) Descriptor() ([]byte, []int)
func (*KafkaMessageTimeToCut) GetBlockNumber ¶
func (m *KafkaMessageTimeToCut) GetBlockNumber() uint64
func (*KafkaMessageTimeToCut) ProtoMessage ¶
func (*KafkaMessageTimeToCut) ProtoMessage()
func (*KafkaMessageTimeToCut) Reset ¶
func (m *KafkaMessageTimeToCut) Reset()
func (*KafkaMessageTimeToCut) String ¶
func (m *KafkaMessageTimeToCut) String() string
func (*KafkaMessageTimeToCut) XXX_DiscardUnknown ¶
func (m *KafkaMessageTimeToCut) XXX_DiscardUnknown()
func (*KafkaMessageTimeToCut) XXX_Marshal ¶
func (m *KafkaMessageTimeToCut) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KafkaMessageTimeToCut) XXX_Merge ¶
func (dst *KafkaMessageTimeToCut) XXX_Merge(src proto.Message)
func (*KafkaMessageTimeToCut) XXX_Size ¶
func (m *KafkaMessageTimeToCut) XXX_Size() int
func (*KafkaMessageTimeToCut) XXX_Unmarshal ¶
func (m *KafkaMessageTimeToCut) XXX_Unmarshal(b []byte) error
type KafkaMessage_Connect ¶
type KafkaMessage_Connect struct {
Connect *KafkaMessageConnect `protobuf:"bytes,3,opt,name=connect,oneof"`
}
type KafkaMessage_Regular ¶
type KafkaMessage_Regular struct {
Regular *KafkaMessageRegular `protobuf:"bytes,1,opt,name=regular,oneof"`
}
type KafkaMessage_TimeToCut ¶
type KafkaMessage_TimeToCut struct {
TimeToCut *KafkaMessageTimeToCut `protobuf:"bytes,2,opt,name=time_to_cut,json=timeToCut,oneof"`
}
type KafkaMetadata ¶
type KafkaMetadata struct { // LastOffsetPersisted is the encoded value for the Metadata message // which is encoded in the ORDERER block metadata index for the case // of the Kafka-based orderer. LastOffsetPersisted int64 `protobuf:"varint,1,opt,name=last_offset_persisted,json=lastOffsetPersisted" json:"last_offset_persisted,omitempty"` // LastOriginalOffsetProcessed is used to keep track of the newest // offset processed if a message is re-validated and re-ordered. // This value is used to deduplicate re-submitted messages from // multiple orderer so that we don't bother re-processing it again. LastOriginalOffsetProcessed int64 `` /* 140-byte string literal not displayed */ // LastResubmittedConfigOffset is used to capture the newest offset of // CONFIG kafka message, which is revalidated and resubmitted. By comparing // this with LastOriginalOffsetProcessed, we could detemine whether there // are still CONFIG messages that have been resubmitted but NOT processed // yet. It's used as condition to block ingress messages, so we could reduce // the overhead of repeatedly resubmitting messages as config seq keeps // advancing. LastResubmittedConfigOffset int64 `` /* 140-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KafkaMetadata is encoded into the ORDERER block to keep track of Kafka-related metadata associated with this block.
func (*KafkaMetadata) Descriptor ¶
func (*KafkaMetadata) Descriptor() ([]byte, []int)
func (*KafkaMetadata) GetLastOffsetPersisted ¶
func (m *KafkaMetadata) GetLastOffsetPersisted() int64
func (*KafkaMetadata) GetLastOriginalOffsetProcessed ¶
func (m *KafkaMetadata) GetLastOriginalOffsetProcessed() int64
func (*KafkaMetadata) GetLastResubmittedConfigOffset ¶
func (m *KafkaMetadata) GetLastResubmittedConfigOffset() int64
func (*KafkaMetadata) ProtoMessage ¶
func (*KafkaMetadata) ProtoMessage()
func (*KafkaMetadata) Reset ¶
func (m *KafkaMetadata) Reset()
func (*KafkaMetadata) String ¶
func (m *KafkaMetadata) String() string
func (*KafkaMetadata) XXX_DiscardUnknown ¶
func (m *KafkaMetadata) XXX_DiscardUnknown()
func (*KafkaMetadata) XXX_Marshal ¶
func (m *KafkaMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KafkaMetadata) XXX_Merge ¶
func (dst *KafkaMetadata) XXX_Merge(src proto.Message)
func (*KafkaMetadata) XXX_Size ¶
func (m *KafkaMetadata) XXX_Size() int
func (*KafkaMetadata) XXX_Unmarshal ¶
func (m *KafkaMetadata) XXX_Unmarshal(b []byte) error
type SeekInfo ¶
type SeekInfo struct { Start *SeekPosition `protobuf:"bytes,1,opt,name=start" json:"start,omitempty"` Stop *SeekPosition `protobuf:"bytes,2,opt,name=stop" json:"stop,omitempty"` Behavior SeekInfo_SeekBehavior `protobuf:"varint,3,opt,name=behavior,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) Descriptor ¶
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) ProtoMessage ¶
func (*SeekInfo) ProtoMessage()
func (*SeekInfo) XXX_DiscardUnknown ¶
func (m *SeekInfo) XXX_DiscardUnknown()
func (*SeekInfo) XXX_Marshal ¶
func (*SeekInfo) XXX_Unmarshal ¶
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,oneof"`
}
type SeekPosition_Oldest ¶
type SeekPosition_Oldest struct {
Oldest *SeekOldest `protobuf:"bytes,2,opt,name=oldest,oneof"`
}
type SeekPosition_Specified ¶
type SeekPosition_Specified struct {
Specified *SeekSpecified `protobuf:"bytes,3,opt,name=specified,oneof"`
}
type SeekSpecified ¶
type SeekSpecified struct { Number uint64 `protobuf:"varint,1,opt,name=number" 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
type StepRequest ¶
type StepRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel" json:"channel,omitempty"` Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
StepRequest wraps a consensus implementation specific message that is sent to a cluster member
func (*StepRequest) Descriptor ¶
func (*StepRequest) Descriptor() ([]byte, []int)
func (*StepRequest) GetChannel ¶
func (m *StepRequest) GetChannel() string
func (*StepRequest) GetPayload ¶
func (m *StepRequest) GetPayload() []byte
func (*StepRequest) ProtoMessage ¶
func (*StepRequest) ProtoMessage()
func (*StepRequest) Reset ¶
func (m *StepRequest) Reset()
func (*StepRequest) String ¶
func (m *StepRequest) String() string
func (*StepRequest) XXX_DiscardUnknown ¶
func (m *StepRequest) XXX_DiscardUnknown()
func (*StepRequest) XXX_Marshal ¶
func (m *StepRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StepRequest) XXX_Merge ¶
func (dst *StepRequest) XXX_Merge(src proto.Message)
func (*StepRequest) XXX_Size ¶
func (m *StepRequest) XXX_Size() int
func (*StepRequest) XXX_Unmarshal ¶
func (m *StepRequest) XXX_Unmarshal(b []byte) error
type StepResponse ¶
type StepResponse struct { Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
StepResponse wraps a consensus implementation specific message that is received from a cluster member as a response to a StepRequest
func (*StepResponse) Descriptor ¶
func (*StepResponse) Descriptor() ([]byte, []int)
func (*StepResponse) GetPayload ¶
func (m *StepResponse) GetPayload() []byte
func (*StepResponse) ProtoMessage ¶
func (*StepResponse) ProtoMessage()
func (*StepResponse) Reset ¶
func (m *StepResponse) Reset()
func (*StepResponse) String ¶
func (m *StepResponse) String() string
func (*StepResponse) XXX_DiscardUnknown ¶
func (m *StepResponse) XXX_DiscardUnknown()
func (*StepResponse) XXX_Marshal ¶
func (m *StepResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StepResponse) XXX_Merge ¶
func (dst *StepResponse) XXX_Merge(src proto.Message)
func (*StepResponse) XXX_Size ¶
func (m *StepResponse) XXX_Size() int
func (*StepResponse) XXX_Unmarshal ¶
func (m *StepResponse) XXX_Unmarshal(b []byte) error
type SubmitRequest ¶
type SubmitRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel" json:"channel,omitempty"` // last_validation_seq denotes the last // configuration sequence at which the // sender validated this message LastValidationSeq uint64 `protobuf:"varint,2,opt,name=last_validation_seq,json=lastValidationSeq" json:"last_validation_seq,omitempty"` // content is the fabric transaction // that is forwarded to the cluster member Content *common.Envelope `protobuf:"bytes,3,opt,name=content" json:"content,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SubmitRequest wraps a transaction to be sent for ordering
func (*SubmitRequest) Descriptor ¶
func (*SubmitRequest) Descriptor() ([]byte, []int)
func (*SubmitRequest) GetChannel ¶
func (m *SubmitRequest) GetChannel() string
func (*SubmitRequest) GetContent ¶
func (m *SubmitRequest) GetContent() *common.Envelope
func (*SubmitRequest) GetLastValidationSeq ¶
func (m *SubmitRequest) GetLastValidationSeq() uint64
func (*SubmitRequest) ProtoMessage ¶
func (*SubmitRequest) ProtoMessage()
func (*SubmitRequest) Reset ¶
func (m *SubmitRequest) Reset()
func (*SubmitRequest) String ¶
func (m *SubmitRequest) String() string
func (*SubmitRequest) XXX_DiscardUnknown ¶
func (m *SubmitRequest) XXX_DiscardUnknown()
func (*SubmitRequest) XXX_Marshal ¶
func (m *SubmitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubmitRequest) XXX_Merge ¶
func (dst *SubmitRequest) XXX_Merge(src proto.Message)
func (*SubmitRequest) XXX_Size ¶
func (m *SubmitRequest) XXX_Size() int
func (*SubmitRequest) XXX_Unmarshal ¶
func (m *SubmitRequest) XXX_Unmarshal(b []byte) error
type SubmitResponse ¶
type SubmitResponse struct { // Status code, which may be used to programatically respond to success/failure Status common.Status `protobuf:"varint,1,opt,name=status,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" json:"info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SubmitResponse returns a success or failure status to the sender
func (*SubmitResponse) Descriptor ¶
func (*SubmitResponse) Descriptor() ([]byte, []int)
func (*SubmitResponse) GetInfo ¶
func (m *SubmitResponse) GetInfo() string
func (*SubmitResponse) GetStatus ¶
func (m *SubmitResponse) GetStatus() common.Status
func (*SubmitResponse) ProtoMessage ¶
func (*SubmitResponse) ProtoMessage()
func (*SubmitResponse) Reset ¶
func (m *SubmitResponse) Reset()
func (*SubmitResponse) String ¶
func (m *SubmitResponse) String() string
func (*SubmitResponse) XXX_DiscardUnknown ¶
func (m *SubmitResponse) XXX_DiscardUnknown()
func (*SubmitResponse) XXX_Marshal ¶
func (m *SubmitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubmitResponse) XXX_Merge ¶
func (dst *SubmitResponse) XXX_Merge(src proto.Message)
func (*SubmitResponse) XXX_Size ¶
func (m *SubmitResponse) XXX_Size() int
func (*SubmitResponse) XXX_Unmarshal ¶
func (m *SubmitResponse) XXX_Unmarshal(b []byte) error