Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

orderer

package

Go to main page

Versions in this module

v0

v0.3.4

Jun 12, 2024

v0.3.3

Jan 21, 2024

v0.3.2

Dec 21, 2023

v0.3.1

Sep 28, 2023

v0.3.0

Nov 17, 2022

Changes in this version

+ var SeekInfo_SeekContentType_name = map[int32]string

+ var SeekInfo_SeekContentType_value = map[string]int32

+ func RegisterBlockAttestationsServer(s *grpc.Server, srv BlockAttestationsServer)

+ func RegisterClusterNodeServiceServer(s *grpc.Server, srv ClusterNodeServiceServer)

+ type BlockAttestation struct

+ Header *common.BlockHeader

+ Metadata *common.BlockMetadata

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BlockAttestation) Descriptor() ([]byte, []int)

+ func (*BlockAttestation) ProtoMessage()

+ func (m *BlockAttestation) GetHeader() *common.BlockHeader

+ func (m *BlockAttestation) GetMetadata() *common.BlockMetadata

+ func (m *BlockAttestation) Reset()

+ func (m *BlockAttestation) String() string

+ func (m *BlockAttestation) XXX_DiscardUnknown()

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

+ func (m *BlockAttestation) XXX_Merge(src proto.Message)

+ func (m *BlockAttestation) XXX_Size() int

+ func (m *BlockAttestation) XXX_Unmarshal(b []byte) error

+ type BlockAttestationResponse struct

+ Type isBlockAttestationResponse_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BlockAttestationResponse) Descriptor() ([]byte, []int)

+ func (*BlockAttestationResponse) ProtoMessage()

+ func (*BlockAttestationResponse) XXX_OneofWrappers() []interface{}

+ func (m *BlockAttestationResponse) GetBlockAttestation() *BlockAttestation

+ func (m *BlockAttestationResponse) GetStatus() common.Status

+ func (m *BlockAttestationResponse) GetType() isBlockAttestationResponse_Type

+ func (m *BlockAttestationResponse) Reset()

+ func (m *BlockAttestationResponse) String() string

+ func (m *BlockAttestationResponse) XXX_DiscardUnknown()

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

+ func (m *BlockAttestationResponse) XXX_Merge(src proto.Message)

+ func (m *BlockAttestationResponse) XXX_Size() int

+ func (m *BlockAttestationResponse) XXX_Unmarshal(b []byte) error

+ type BlockAttestationResponse_BlockAttestation struct

+ BlockAttestation *BlockAttestation

+ type BlockAttestationResponse_Status struct

+ Status common.Status

+ type BlockAttestationsClient interface

+ BlockAttestations func(ctx context.Context, in *common.Envelope, opts ...grpc.CallOption) (BlockAttestations_BlockAttestationsClient, error)

+ func NewBlockAttestationsClient(cc *grpc.ClientConn) BlockAttestationsClient

+ type BlockAttestationsServer interface

+ BlockAttestations func(*common.Envelope, BlockAttestations_BlockAttestationsServer) error

+ type BlockAttestations_BlockAttestationsClient interface

+ Recv func() (*BlockAttestationResponse, error)

+ type BlockAttestations_BlockAttestationsServer interface

+ Send func(*BlockAttestationResponse) error

+ type ClusterNodeServiceClient interface

+ Step func(ctx context.Context, opts ...grpc.CallOption) (ClusterNodeService_StepClient, error)

+ func NewClusterNodeServiceClient(cc *grpc.ClientConn) ClusterNodeServiceClient

+ type ClusterNodeServiceServer interface

+ Step func(ClusterNodeService_StepServer) error

+ type ClusterNodeServiceStepRequest struct

+ Payload isClusterNodeServiceStepRequest_Payload

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClusterNodeServiceStepRequest) Descriptor() ([]byte, []int)

+ func (*ClusterNodeServiceStepRequest) ProtoMessage()

+ func (*ClusterNodeServiceStepRequest) XXX_OneofWrappers() []interface{}

+ func (m *ClusterNodeServiceStepRequest) GetNodeAuthrequest() *NodeAuthRequest

+ func (m *ClusterNodeServiceStepRequest) GetNodeConrequest() *NodeConsensusRequest

+ func (m *ClusterNodeServiceStepRequest) GetNodeTranrequest() *NodeTransactionOrderRequest

+ func (m *ClusterNodeServiceStepRequest) GetPayload() isClusterNodeServiceStepRequest_Payload

+ func (m *ClusterNodeServiceStepRequest) Reset()

+ func (m *ClusterNodeServiceStepRequest) String() string

+ func (m *ClusterNodeServiceStepRequest) XXX_DiscardUnknown()

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

+ func (m *ClusterNodeServiceStepRequest) XXX_Merge(src proto.Message)

+ func (m *ClusterNodeServiceStepRequest) XXX_Size() int

+ func (m *ClusterNodeServiceStepRequest) XXX_Unmarshal(b []byte) error

+ type ClusterNodeServiceStepRequest_NodeAuthrequest struct

+ NodeAuthrequest *NodeAuthRequest

+ type ClusterNodeServiceStepRequest_NodeConrequest struct

+ NodeConrequest *NodeConsensusRequest

+ type ClusterNodeServiceStepRequest_NodeTranrequest struct

+ NodeTranrequest *NodeTransactionOrderRequest

+ type ClusterNodeServiceStepResponse struct

+ Payload isClusterNodeServiceStepResponse_Payload

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClusterNodeServiceStepResponse) Descriptor() ([]byte, []int)

+ func (*ClusterNodeServiceStepResponse) ProtoMessage()

+ func (*ClusterNodeServiceStepResponse) XXX_OneofWrappers() []interface{}

+ func (m *ClusterNodeServiceStepResponse) GetPayload() isClusterNodeServiceStepResponse_Payload

+ func (m *ClusterNodeServiceStepResponse) GetTranorderRes() *TransactionOrderResponse

+ func (m *ClusterNodeServiceStepResponse) Reset()

+ func (m *ClusterNodeServiceStepResponse) String() string

+ func (m *ClusterNodeServiceStepResponse) XXX_DiscardUnknown()

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

+ func (m *ClusterNodeServiceStepResponse) XXX_Merge(src proto.Message)

+ func (m *ClusterNodeServiceStepResponse) XXX_Size() int

+ func (m *ClusterNodeServiceStepResponse) XXX_Unmarshal(b []byte) error

+ type ClusterNodeServiceStepResponse_TranorderRes struct

+ TranorderRes *TransactionOrderResponse

+ type ClusterNodeService_StepClient interface

+ Recv func() (*ClusterNodeServiceStepResponse, error)

+ Send func(*ClusterNodeServiceStepRequest) error

+ type ClusterNodeService_StepServer interface

+ Recv func() (*ClusterNodeServiceStepRequest, error)

+ Send func(*ClusterNodeServiceStepResponse) error

+ type NodeAuthRequest struct

+ Channel string

+ FromId uint64

+ SessionBinding []byte

+ Signature []byte

+ Timestamp *timestamppb.Timestamp

+ ToId uint64

+ Version uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeAuthRequest) Descriptor() ([]byte, []int)

+ func (*NodeAuthRequest) ProtoMessage()

+ func (m *NodeAuthRequest) GetChannel() string

+ func (m *NodeAuthRequest) GetFromId() uint64

+ func (m *NodeAuthRequest) GetSessionBinding() []byte

+ func (m *NodeAuthRequest) GetSignature() []byte

+ func (m *NodeAuthRequest) GetTimestamp() *timestamppb.Timestamp

+ func (m *NodeAuthRequest) GetToId() uint64

+ func (m *NodeAuthRequest) GetVersion() uint32

+ func (m *NodeAuthRequest) Reset()

+ func (m *NodeAuthRequest) String() string

+ func (m *NodeAuthRequest) XXX_DiscardUnknown()

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

+ func (m *NodeAuthRequest) XXX_Merge(src proto.Message)

+ func (m *NodeAuthRequest) XXX_Size() int

+ func (m *NodeAuthRequest) XXX_Unmarshal(b []byte) error

+ type NodeConsensusRequest struct

+ Metadata []byte

+ Payload []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeConsensusRequest) Descriptor() ([]byte, []int)

+ func (*NodeConsensusRequest) ProtoMessage()

+ func (m *NodeConsensusRequest) GetMetadata() []byte

+ func (m *NodeConsensusRequest) GetPayload() []byte

+ func (m *NodeConsensusRequest) Reset()

+ func (m *NodeConsensusRequest) String() string

+ func (m *NodeConsensusRequest) XXX_DiscardUnknown()

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

+ func (m *NodeConsensusRequest) XXX_Merge(src proto.Message)

+ func (m *NodeConsensusRequest) XXX_Size() int

+ func (m *NodeConsensusRequest) XXX_Unmarshal(b []byte) error

+ type NodeTransactionOrderRequest struct

+ LastValidationSeq uint64

+ Payload *common.Envelope

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeTransactionOrderRequest) Descriptor() ([]byte, []int)

+ func (*NodeTransactionOrderRequest) ProtoMessage()

+ func (m *NodeTransactionOrderRequest) GetLastValidationSeq() uint64

+ func (m *NodeTransactionOrderRequest) GetPayload() *common.Envelope

+ func (m *NodeTransactionOrderRequest) Reset()

+ func (m *NodeTransactionOrderRequest) String() string

+ func (m *NodeTransactionOrderRequest) XXX_DiscardUnknown()

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

+ func (m *NodeTransactionOrderRequest) XXX_Merge(src proto.Message)

+ func (m *NodeTransactionOrderRequest) XXX_Size() int

+ func (m *NodeTransactionOrderRequest) XXX_Unmarshal(b []byte) error

type SeekInfo

+ ContentType SeekInfo_SeekContentType

+ func (m *SeekInfo) GetContentType() SeekInfo_SeekContentType

+ type SeekInfo_SeekContentType int32

+ const SeekInfo_BLOCK

+ const SeekInfo_HEADER_WITH_SIG

+ func (SeekInfo_SeekContentType) EnumDescriptor() ([]byte, []int)

+ func (x SeekInfo_SeekContentType) String() string

+ type TransactionOrderResponse struct

+ Channel string

+ Info string

+ Status common.Status

+ TxId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TransactionOrderResponse) Descriptor() ([]byte, []int)

+ func (*TransactionOrderResponse) ProtoMessage()

+ func (m *TransactionOrderResponse) GetChannel() string

+ func (m *TransactionOrderResponse) GetInfo() string

+ func (m *TransactionOrderResponse) GetStatus() common.Status

+ func (m *TransactionOrderResponse) GetTxId() string

+ func (m *TransactionOrderResponse) Reset()

+ func (m *TransactionOrderResponse) String() string

+ func (m *TransactionOrderResponse) XXX_DiscardUnknown()

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

+ func (m *TransactionOrderResponse) XXX_Merge(src proto.Message)

+ func (m *TransactionOrderResponse) XXX_Size() int

+ func (m *TransactionOrderResponse) XXX_Unmarshal(b []byte) error

+ type UnimplementedBlockAttestationsServer struct

+ func (*UnimplementedBlockAttestationsServer) BlockAttestations(req *common.Envelope, srv BlockAttestations_BlockAttestationsServer) error

+ type UnimplementedClusterNodeServiceServer struct

+ func (*UnimplementedClusterNodeServiceServer) Step(srv ClusterNodeService_StepServer) error

v0.2.2

Jun 12, 2024

v0.2.1

Mar 27, 2023

v0.2.0

Nov 21, 2022

v0.1.6

Nov 22, 2022

Changes in this version

+ var ConsensusType_State_name = map[int32]string

+ var ConsensusType_State_value = map[string]int32

+ var KafkaMessageRegular_Class_name = map[int32]string

+ var KafkaMessageRegular_Class_value = map[string]int32

+ var SeekInfo_SeekBehavior_name = map[int32]string

+ var SeekInfo_SeekBehavior_value = map[string]int32

+ var SeekInfo_SeekErrorResponse_name = map[int32]string

+ var SeekInfo_SeekErrorResponse_value = map[string]int32

+ func RegisterAtomicBroadcastServer(s *grpc.Server, srv AtomicBroadcastServer)

+ func RegisterClusterServer(s *grpc.Server, srv ClusterServer)

+ type AtomicBroadcastClient interface

+ Broadcast func(ctx context.Context, opts ...grpc.CallOption) (AtomicBroadcast_BroadcastClient, error)

+ Deliver func(ctx context.Context, opts ...grpc.CallOption) (AtomicBroadcast_DeliverClient, error)

+ func NewAtomicBroadcastClient(cc *grpc.ClientConn) AtomicBroadcastClient

+ type AtomicBroadcastServer interface

+ Broadcast func(AtomicBroadcast_BroadcastServer) error

+ Deliver func(AtomicBroadcast_DeliverServer) error

+ type AtomicBroadcast_BroadcastClient interface

+ Recv func() (*BroadcastResponse, error)

+ Send func(*common.Envelope) error

+ type AtomicBroadcast_BroadcastServer interface

+ Recv func() (*common.Envelope, error)

+ Send func(*BroadcastResponse) error

+ type AtomicBroadcast_DeliverClient interface

+ Recv func() (*DeliverResponse, error)

+ Send func(*common.Envelope) error

+ type AtomicBroadcast_DeliverServer interface

+ Recv func() (*common.Envelope, error)

+ Send func(*DeliverResponse) error

+ type BatchSize struct

+ AbsoluteMaxBytes uint32

+ MaxMessageCount uint32

+ PreferredMaxBytes uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BatchSize) Descriptor() ([]byte, []int)

+ func (*BatchSize) ProtoMessage()

+ func (m *BatchSize) GetAbsoluteMaxBytes() uint32

+ func (m *BatchSize) GetMaxMessageCount() uint32

+ func (m *BatchSize) GetPreferredMaxBytes() uint32

+ 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 (m *BatchSize) XXX_Merge(src proto.Message)

+ func (m *BatchSize) XXX_Size() int

+ func (m *BatchSize) XXX_Unmarshal(b []byte) error

+ type BatchTimeout struct

+ Timeout string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BatchTimeout) Descriptor() ([]byte, []int)

+ func (*BatchTimeout) ProtoMessage()

+ func (m *BatchTimeout) GetTimeout() string

+ 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 (m *BatchTimeout) XXX_Merge(src proto.Message)

+ func (m *BatchTimeout) XXX_Size() int

+ func (m *BatchTimeout) XXX_Unmarshal(b []byte) error

+ type BroadcastResponse struct

+ Info string

+ Status common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BroadcastResponse) Descriptor() ([]byte, []int)

+ func (*BroadcastResponse) ProtoMessage()

+ func (m *BroadcastResponse) GetInfo() string

+ func (m *BroadcastResponse) GetStatus() common.Status

+ 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 (m *BroadcastResponse) XXX_Merge(src proto.Message)

+ func (m *BroadcastResponse) XXX_Size() int

+ func (m *BroadcastResponse) XXX_Unmarshal(b []byte) error

+ type ChannelRestrictions struct

+ MaxCount uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ChannelRestrictions) Descriptor() ([]byte, []int)

+ func (*ChannelRestrictions) ProtoMessage()

+ func (m *ChannelRestrictions) GetMaxCount() uint64

+ 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 (m *ChannelRestrictions) XXX_Merge(src proto.Message)

+ func (m *ChannelRestrictions) XXX_Size() int

+ func (m *ChannelRestrictions) XXX_Unmarshal(b []byte) error

+ type ClusterClient interface

+ Step func(ctx context.Context, opts ...grpc.CallOption) (Cluster_StepClient, error)

+ func NewClusterClient(cc *grpc.ClientConn) ClusterClient

+ type ClusterServer interface

+ Step func(Cluster_StepServer) error

+ type Cluster_StepClient interface

+ Recv func() (*StepResponse, error)

+ Send func(*StepRequest) error

+ type Cluster_StepServer interface

+ Recv func() (*StepRequest, error)

+ Send func(*StepResponse) error

+ type ConsensusRequest struct

+ Channel string

+ Metadata []byte

+ Payload []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ConsensusRequest) Descriptor() ([]byte, []int)

+ func (*ConsensusRequest) ProtoMessage()

+ func (m *ConsensusRequest) GetChannel() string

+ func (m *ConsensusRequest) GetMetadata() []byte

+ func (m *ConsensusRequest) GetPayload() []byte

+ func (m *ConsensusRequest) Reset()

+ func (m *ConsensusRequest) String() string

+ func (m *ConsensusRequest) XXX_DiscardUnknown()

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

+ func (m *ConsensusRequest) XXX_Merge(src proto.Message)

+ func (m *ConsensusRequest) XXX_Size() int

+ func (m *ConsensusRequest) XXX_Unmarshal(b []byte) error

+ type ConsensusType struct

+ Metadata []byte

+ State ConsensusType_State

+ Type string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ConsensusType) Descriptor() ([]byte, []int)

+ func (*ConsensusType) ProtoMessage()

+ func (m *ConsensusType) GetMetadata() []byte

+ func (m *ConsensusType) GetState() ConsensusType_State

+ func (m *ConsensusType) GetType() string

+ 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 (m *ConsensusType) XXX_Merge(src proto.Message)

+ func (m *ConsensusType) XXX_Size() int

+ func (m *ConsensusType) XXX_Unmarshal(b []byte) error

+ type ConsensusType_State int32

+ const ConsensusType_STATE_MAINTENANCE

+ const ConsensusType_STATE_NORMAL

+ func (ConsensusType_State) EnumDescriptor() ([]byte, []int)

+ func (x ConsensusType_State) String() string

+ type DeliverResponse struct

+ Type isDeliverResponse_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeliverResponse) Descriptor() ([]byte, []int)

+ func (*DeliverResponse) ProtoMessage()

+ func (*DeliverResponse) XXX_OneofWrappers() []interface{}

+ func (m *DeliverResponse) GetBlock() *common.Block

+ func (m *DeliverResponse) GetStatus() common.Status

+ func (m *DeliverResponse) GetType() isDeliverResponse_Type

+ 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 (m *DeliverResponse) XXX_Merge(src proto.Message)

+ func (m *DeliverResponse) XXX_Size() int

+ func (m *DeliverResponse) XXX_Unmarshal(b []byte) error

+ type DeliverResponse_Block struct

+ Block *common.Block

+ type DeliverResponse_Status struct

+ Status common.Status

+ type KafkaBrokers struct

+ Brokers []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*KafkaBrokers) Descriptor() ([]byte, []int)

+ func (*KafkaBrokers) ProtoMessage()

+ func (m *KafkaBrokers) GetBrokers() []string

+ 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 (m *KafkaBrokers) XXX_Merge(src proto.Message)

+ func (m *KafkaBrokers) XXX_Size() int

+ func (m *KafkaBrokers) XXX_Unmarshal(b []byte) error

+ type KafkaMessage struct

+ Type isKafkaMessage_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*KafkaMessage) Descriptor() ([]byte, []int)

+ func (*KafkaMessage) ProtoMessage()

+ func (*KafkaMessage) XXX_OneofWrappers() []interface{}

+ func (m *KafkaMessage) GetConnect() *KafkaMessageConnect

+ func (m *KafkaMessage) GetRegular() *KafkaMessageRegular

+ func (m *KafkaMessage) GetTimeToCut() *KafkaMessageTimeToCut

+ func (m *KafkaMessage) GetType() isKafkaMessage_Type

+ 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 (m *KafkaMessage) XXX_Merge(src proto.Message)

+ func (m *KafkaMessage) XXX_Size() int

+ func (m *KafkaMessage) XXX_Unmarshal(b []byte) error

+ type KafkaMessageConnect struct

+ Payload []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*KafkaMessageConnect) Descriptor() ([]byte, []int)

+ func (*KafkaMessageConnect) ProtoMessage()

+ func (m *KafkaMessageConnect) GetPayload() []byte

+ 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 (m *KafkaMessageConnect) XXX_Merge(src proto.Message)

+ func (m *KafkaMessageConnect) XXX_Size() int

+ func (m *KafkaMessageConnect) XXX_Unmarshal(b []byte) error

+ type KafkaMessageRegular struct

+ Class KafkaMessageRegular_Class

+ ConfigSeq uint64

+ OriginalOffset int64

+ Payload []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*KafkaMessageRegular) Descriptor() ([]byte, []int)

+ func (*KafkaMessageRegular) ProtoMessage()

+ func (m *KafkaMessageRegular) GetClass() KafkaMessageRegular_Class

+ func (m *KafkaMessageRegular) GetConfigSeq() uint64

+ func (m *KafkaMessageRegular) GetOriginalOffset() int64

+ func (m *KafkaMessageRegular) GetPayload() []byte

+ 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 (m *KafkaMessageRegular) XXX_Merge(src proto.Message)

+ func (m *KafkaMessageRegular) XXX_Size() int

+ func (m *KafkaMessageRegular) XXX_Unmarshal(b []byte) error

+ type KafkaMessageRegular_Class int32

+ const KafkaMessageRegular_CONFIG

+ const KafkaMessageRegular_NORMAL

+ const KafkaMessageRegular_UNKNOWN

+ func (KafkaMessageRegular_Class) EnumDescriptor() ([]byte, []int)

+ func (x KafkaMessageRegular_Class) String() string

+ type KafkaMessageTimeToCut struct

+ BlockNumber uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*KafkaMessageTimeToCut) Descriptor() ([]byte, []int)

+ func (*KafkaMessageTimeToCut) ProtoMessage()

+ func (m *KafkaMessageTimeToCut) GetBlockNumber() uint64

+ 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 (m *KafkaMessageTimeToCut) XXX_Merge(src proto.Message)

+ func (m *KafkaMessageTimeToCut) XXX_Size() int

+ func (m *KafkaMessageTimeToCut) XXX_Unmarshal(b []byte) error

+ type KafkaMessage_Connect struct

+ Connect *KafkaMessageConnect

+ type KafkaMessage_Regular struct

+ Regular *KafkaMessageRegular

+ type KafkaMessage_TimeToCut struct

+ TimeToCut *KafkaMessageTimeToCut

+ type KafkaMetadata struct

+ LastOffsetPersisted int64

+ LastOriginalOffsetProcessed int64

+ LastResubmittedConfigOffset int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*KafkaMetadata) Descriptor() ([]byte, []int)

+ func (*KafkaMetadata) ProtoMessage()

+ func (m *KafkaMetadata) GetLastOffsetPersisted() int64

+ func (m *KafkaMetadata) GetLastOriginalOffsetProcessed() int64

+ func (m *KafkaMetadata) GetLastResubmittedConfigOffset() int64

+ 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 (m *KafkaMetadata) XXX_Merge(src proto.Message)

+ func (m *KafkaMetadata) XXX_Size() int

+ func (m *KafkaMetadata) XXX_Unmarshal(b []byte) error

+ type SeekInfo struct

+ Behavior SeekInfo_SeekBehavior

+ ErrorResponse SeekInfo_SeekErrorResponse

+ Start *SeekPosition

+ Stop *SeekPosition

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SeekInfo) Descriptor() ([]byte, []int)

+ func (*SeekInfo) ProtoMessage()

+ func (m *SeekInfo) GetBehavior() SeekInfo_SeekBehavior

+ func (m *SeekInfo) GetErrorResponse() SeekInfo_SeekErrorResponse

+ func (m *SeekInfo) GetStart() *SeekPosition

+ func (m *SeekInfo) GetStop() *SeekPosition

+ 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 (m *SeekInfo) XXX_Merge(src proto.Message)

+ func (m *SeekInfo) XXX_Size() int

+ func (m *SeekInfo) XXX_Unmarshal(b []byte) error

+ type SeekInfo_SeekBehavior int32

+ const SeekInfo_BLOCK_UNTIL_READY

+ const SeekInfo_FAIL_IF_NOT_READY

+ func (SeekInfo_SeekBehavior) EnumDescriptor() ([]byte, []int)

+ func (x SeekInfo_SeekBehavior) String() string

+ type SeekInfo_SeekErrorResponse int32

+ const SeekInfo_BEST_EFFORT

+ const SeekInfo_STRICT

+ func (SeekInfo_SeekErrorResponse) EnumDescriptor() ([]byte, []int)

+ func (x SeekInfo_SeekErrorResponse) String() string

+ type SeekNewest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 (m *SeekNewest) XXX_Merge(src proto.Message)

+ func (m *SeekNewest) XXX_Size() int

+ func (m *SeekNewest) XXX_Unmarshal(b []byte) error

+ type SeekNextCommit struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SeekNextCommit) Descriptor() ([]byte, []int)

+ func (*SeekNextCommit) ProtoMessage()

+ func (m *SeekNextCommit) Reset()

+ func (m *SeekNextCommit) String() string

+ func (m *SeekNextCommit) XXX_DiscardUnknown()

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

+ func (m *SeekNextCommit) XXX_Merge(src proto.Message)

+ func (m *SeekNextCommit) XXX_Size() int

+ func (m *SeekNextCommit) XXX_Unmarshal(b []byte) error

+ type SeekOldest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 (m *SeekOldest) XXX_Merge(src proto.Message)

+ func (m *SeekOldest) XXX_Size() int

+ func (m *SeekOldest) XXX_Unmarshal(b []byte) error

+ type SeekPosition struct

+ Type isSeekPosition_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SeekPosition) Descriptor() ([]byte, []int)

+ func (*SeekPosition) ProtoMessage()

+ func (*SeekPosition) XXX_OneofWrappers() []interface{}

+ func (m *SeekPosition) GetNewest() *SeekNewest

+ func (m *SeekPosition) GetNextCommit() *SeekNextCommit

+ func (m *SeekPosition) GetOldest() *SeekOldest

+ func (m *SeekPosition) GetSpecified() *SeekSpecified

+ func (m *SeekPosition) GetType() isSeekPosition_Type

+ 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 (m *SeekPosition) XXX_Merge(src proto.Message)

+ func (m *SeekPosition) XXX_Size() int

+ func (m *SeekPosition) XXX_Unmarshal(b []byte) error

+ type SeekPosition_Newest struct

+ Newest *SeekNewest

+ type SeekPosition_NextCommit struct

+ NextCommit *SeekNextCommit

+ type SeekPosition_Oldest struct

+ Oldest *SeekOldest

+ type SeekPosition_Specified struct

+ Specified *SeekSpecified

+ type SeekSpecified struct

+ Number uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SeekSpecified) Descriptor() ([]byte, []int)

+ func (*SeekSpecified) ProtoMessage()

+ func (m *SeekSpecified) GetNumber() uint64

+ 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 (m *SeekSpecified) XXX_Merge(src proto.Message)

+ func (m *SeekSpecified) XXX_Size() int

+ func (m *SeekSpecified) XXX_Unmarshal(b []byte) error

+ type StepRequest struct

+ Payload isStepRequest_Payload

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StepRequest) Descriptor() ([]byte, []int)

+ func (*StepRequest) ProtoMessage()

+ func (*StepRequest) XXX_OneofWrappers() []interface{}

+ func (m *StepRequest) GetConsensusRequest() *ConsensusRequest

+ func (m *StepRequest) GetPayload() isStepRequest_Payload

+ func (m *StepRequest) GetSubmitRequest() *SubmitRequest

+ 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 (m *StepRequest) XXX_Merge(src proto.Message)

+ func (m *StepRequest) XXX_Size() int

+ func (m *StepRequest) XXX_Unmarshal(b []byte) error

+ type StepRequest_ConsensusRequest struct

+ ConsensusRequest *ConsensusRequest

+ type StepRequest_SubmitRequest struct

+ SubmitRequest *SubmitRequest

+ type StepResponse struct

+ Payload isStepResponse_Payload

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StepResponse) Descriptor() ([]byte, []int)

+ func (*StepResponse) ProtoMessage()

+ func (*StepResponse) XXX_OneofWrappers() []interface{}

+ func (m *StepResponse) GetPayload() isStepResponse_Payload

+ func (m *StepResponse) GetSubmitRes() *SubmitResponse

+ 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 (m *StepResponse) XXX_Merge(src proto.Message)

+ func (m *StepResponse) XXX_Size() int

+ func (m *StepResponse) XXX_Unmarshal(b []byte) error

+ type StepResponse_SubmitRes struct

+ SubmitRes *SubmitResponse

+ type SubmitRequest struct

+ Channel string

+ LastValidationSeq uint64

+ Payload *common.Envelope

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SubmitRequest) Descriptor() ([]byte, []int)

+ func (*SubmitRequest) ProtoMessage()

+ func (m *SubmitRequest) GetChannel() string

+ func (m *SubmitRequest) GetLastValidationSeq() uint64

+ func (m *SubmitRequest) GetPayload() *common.Envelope

+ 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 (m *SubmitRequest) XXX_Merge(src proto.Message)

+ func (m *SubmitRequest) XXX_Size() int

+ func (m *SubmitRequest) XXX_Unmarshal(b []byte) error

+ type SubmitResponse struct

+ Channel string

+ Info string

+ Status common.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SubmitResponse) Descriptor() ([]byte, []int)

+ func (*SubmitResponse) ProtoMessage()

+ func (m *SubmitResponse) GetChannel() string

+ func (m *SubmitResponse) GetInfo() string

+ func (m *SubmitResponse) GetStatus() common.Status

+ 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 (m *SubmitResponse) XXX_Merge(src proto.Message)

+ func (m *SubmitResponse) XXX_Size() int

+ func (m *SubmitResponse) XXX_Unmarshal(b []byte) error

+ type UnimplementedAtomicBroadcastServer struct

+ func (*UnimplementedAtomicBroadcastServer) Broadcast(srv AtomicBroadcast_BroadcastServer) error

+ func (*UnimplementedAtomicBroadcastServer) Deliver(srv AtomicBroadcast_DeliverServer) error

+ type UnimplementedClusterServer struct

+ func (*UnimplementedClusterServer) Step(srv Cluster_StepServer) error