Versions in this module Expand all Collapse all v1 v1.0.0 Jul 11, 2017 Changes in this version + var SeekInfo_SeekBehavior_name = map[int32]string + var SeekInfo_SeekBehavior_value = map[string]int32 + func RegisterAtomicBroadcastServer(s *grpc.Server, srv AtomicBroadcastServer) + 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 + 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 + type BatchTimeout struct + Timeout string + func (*BatchTimeout) Descriptor() ([]byte, []int) + func (*BatchTimeout) ProtoMessage() + func (m *BatchTimeout) GetTimeout() string + func (m *BatchTimeout) Reset() + func (m *BatchTimeout) String() string + type BroadcastResponse struct + Status common.Status + func (*BroadcastResponse) Descriptor() ([]byte, []int) + func (*BroadcastResponse) ProtoMessage() + func (m *BroadcastResponse) GetStatus() common.Status + func (m *BroadcastResponse) Reset() + func (m *BroadcastResponse) String() string + type ChannelRestrictions struct + MaxCount uint64 + func (*ChannelRestrictions) Descriptor() ([]byte, []int) + func (*ChannelRestrictions) ProtoMessage() + func (m *ChannelRestrictions) GetMaxCount() uint64 + func (m *ChannelRestrictions) Reset() + func (m *ChannelRestrictions) String() string + type ConsensusType struct + Type string + func (*ConsensusType) Descriptor() ([]byte, []int) + func (*ConsensusType) ProtoMessage() + func (m *ConsensusType) GetType() string + func (m *ConsensusType) Reset() + func (m *ConsensusType) String() string + type DeliverResponse struct + Type isDeliverResponse_Type + func (*DeliverResponse) Descriptor() ([]byte, []int) + func (*DeliverResponse) ProtoMessage() + func (*DeliverResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + 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 + type DeliverResponse_Block struct + Block *common.Block + type DeliverResponse_Status struct + Status common.Status + type DynamicOrdererConfigValue struct + func (docv *DynamicOrdererConfigValue) VariablyOpaqueFieldProto(name string) (proto.Message, error) + type DynamicOrdererGroup struct + func (dcg *DynamicOrdererGroup) DynamicMapFieldProto(name string, key string, base proto.Message) (proto.Message, error) + type DynamicOrdererGroupFactory struct + func (dogf DynamicOrdererGroupFactory) DynamicConfigGroup(cg *common.ConfigGroup) proto.Message + type DynamicOrdererOrgConfigValue struct + func (doocv *DynamicOrdererOrgConfigValue) VariablyOpaqueFieldProto(name string) (proto.Message, error) + type DynamicOrdererOrgGroup struct + func (dcg *DynamicOrdererOrgGroup) DynamicMapFieldProto(name string, key string, base proto.Message) (proto.Message, error) + type KafkaBrokers struct + Brokers []string + func (*KafkaBrokers) Descriptor() ([]byte, []int) + func (*KafkaBrokers) ProtoMessage() + func (m *KafkaBrokers) GetBrokers() []string + func (m *KafkaBrokers) Reset() + func (m *KafkaBrokers) String() string + type KafkaMessage struct + Type isKafkaMessage_Type + func (*KafkaMessage) Descriptor() ([]byte, []int) + func (*KafkaMessage) ProtoMessage() + func (*KafkaMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + 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 + type KafkaMessageConnect struct + Payload []byte + func (*KafkaMessageConnect) Descriptor() ([]byte, []int) + func (*KafkaMessageConnect) ProtoMessage() + func (m *KafkaMessageConnect) GetPayload() []byte + func (m *KafkaMessageConnect) Reset() + func (m *KafkaMessageConnect) String() string + type KafkaMessageRegular struct + Payload []byte + func (*KafkaMessageRegular) Descriptor() ([]byte, []int) + func (*KafkaMessageRegular) ProtoMessage() + func (m *KafkaMessageRegular) GetPayload() []byte + func (m *KafkaMessageRegular) Reset() + func (m *KafkaMessageRegular) String() string + type KafkaMessageTimeToCut struct + BlockNumber uint64 + func (*KafkaMessageTimeToCut) Descriptor() ([]byte, []int) + func (*KafkaMessageTimeToCut) ProtoMessage() + func (m *KafkaMessageTimeToCut) GetBlockNumber() uint64 + func (m *KafkaMessageTimeToCut) Reset() + func (m *KafkaMessageTimeToCut) String() string + type KafkaMessage_Connect struct + Connect *KafkaMessageConnect + type KafkaMessage_Regular struct + Regular *KafkaMessageRegular + type KafkaMessage_TimeToCut struct + TimeToCut *KafkaMessageTimeToCut + type KafkaMetadata struct + LastOffsetPersisted int64 + func (*KafkaMetadata) Descriptor() ([]byte, []int) + func (*KafkaMetadata) ProtoMessage() + func (m *KafkaMetadata) GetLastOffsetPersisted() int64 + func (m *KafkaMetadata) Reset() + func (m *KafkaMetadata) String() string + type SeekInfo struct + Behavior SeekInfo_SeekBehavior + Start *SeekPosition + Stop *SeekPosition + func (*SeekInfo) Descriptor() ([]byte, []int) + func (*SeekInfo) ProtoMessage() + func (m *SeekInfo) GetBehavior() SeekInfo_SeekBehavior + func (m *SeekInfo) GetStart() *SeekPosition + func (m *SeekInfo) GetStop() *SeekPosition + func (m *SeekInfo) Reset() + func (m *SeekInfo) String() string + 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 SeekNewest struct + func (*SeekNewest) Descriptor() ([]byte, []int) + func (*SeekNewest) ProtoMessage() + func (m *SeekNewest) Reset() + func (m *SeekNewest) String() string + type SeekOldest struct + func (*SeekOldest) Descriptor() ([]byte, []int) + func (*SeekOldest) ProtoMessage() + func (m *SeekOldest) Reset() + func (m *SeekOldest) String() string + type SeekPosition struct + Type isSeekPosition_Type + func (*SeekPosition) Descriptor() ([]byte, []int) + func (*SeekPosition) ProtoMessage() + func (*SeekPosition) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *SeekPosition) GetNewest() *SeekNewest + 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 + type SeekPosition_Newest struct + Newest *SeekNewest + type SeekPosition_Oldest struct + Oldest *SeekOldest + type SeekPosition_Specified struct + Specified *SeekSpecified + type SeekSpecified struct + Number uint64 + func (*SeekSpecified) Descriptor() ([]byte, []int) + func (*SeekSpecified) ProtoMessage() + func (m *SeekSpecified) GetNumber() uint64 + func (m *SeekSpecified) Reset() + func (m *SeekSpecified) String() string
Go to main page