orderer

package
v0.0.0-...-95b87ed Latest Latest
Warning

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

 Go to latest Published: Sep 16, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ConsensusTypeMetadataMap = map[string]ConsensusTypeMetadataFactory{}
View Source 
var ConsensusType_State_name = map[int32]string{
	0: "STATE_NORMAL",
	1: "STATE_MAINTENANCE",
}
View Source 
var ConsensusType_State_value = map[string]int32{
	"STATE_NORMAL":      0,
	"STATE_MAINTENANCE": 1,
}
View Source 
var KafkaMessageRegular_Class_name = map[int32]string{
	0: "UNKNOWN",
	1: "NORMAL",
	2: "CONFIG",
}
View Source 
var KafkaMessageRegular_Class_value = map[string]int32{
	"UNKNOWN": 0,
	"NORMAL":  1,
	"CONFIG":  2,
}
View Source 
var SeekInfo_SeekBehavior_name = map[int32]string{
	0: "BLOCK_UNTIL_READY",
	1: "FAIL_IF_NOT_READY",
}
View Source 
var SeekInfo_SeekBehavior_value = map[string]int32{
	"BLOCK_UNTIL_READY": 0,
	"FAIL_IF_NOT_READY": 1,
}
View Source 
var SeekInfo_SeekErrorResponse_name = map[int32]string{
	0: "STRICT",
	1: "BEST_EFFORT",
}
View Source 
var SeekInfo_SeekErrorResponse_value = map[string]int32{
	"STRICT":      0,
	"BEST_EFFORT": 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(ctx context.Context, opts ...grpc.CallOption) (AtomicBroadcast_BroadcastClient, error)

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

func NewAtomicBroadcastClient 

func NewAtomicBroadcastClient(cc *grpc.ClientConn) AtomicBroadcastClient

type AtomicBroadcastServer 

type AtomicBroadcastServer interface {
	Broadcast(AtomicBroadcast_BroadcastServer) error

	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 {
	MaxMessageCount uint32 `protobuf:"varint,1,opt,name=max_message_count,json=maxMessageCount,proto3" json:"max_message_count,omitempty"`

	AbsoluteMaxBytes uint32 `protobuf:"varint,2,opt,name=absolute_max_bytes,json=absoluteMaxBytes,proto3" json:"absolute_max_bytes,omitempty"`

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

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

func (*BatchSize) GetAbsoluteMaxBytes 

func (m *BatchSize) GetAbsoluteMaxBytes() uint32

func (*BatchSize) GetMaxMessageCount 

func (m *BatchSize) GetMaxMessageCount() uint32

func (*BatchSize) GetPreferredMaxBytes 

func (m *BatchSize) GetPreferredMaxBytes() uint32

func (*BatchSize) ProtoMessage 

func (*BatchSize) ProtoMessage()

func (*BatchSize) Reset 

func (m *BatchSize) Reset()

func (*BatchSize) String 

func (m *BatchSize) String() string

func (*BatchSize) XXX_DiscardUnknown 

func (m *BatchSize) XXX_DiscardUnknown()

func (*BatchSize) XXX_Marshal 

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

func (*BatchSize) XXX_Merge 

func (m *BatchSize) XXX_Merge(src proto.Message)

func (*BatchSize) XXX_Size 

func (m *BatchSize) XXX_Size() int

func (*BatchSize) XXX_Unmarshal 

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

type BatchTimeout 

type BatchTimeout struct {
	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 (m *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 common.Status `protobuf:"varint,1,opt,name=status,proto3,enum=common.Status" json:"status,omitempty"`

	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 (m *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:"-"`
}

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 (m *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 {
	Step(ctx context.Context, opts ...grpc.CallOption) (Cluster_StepClient, error)
}

func NewClusterClient 

func NewClusterClient(cc *grpc.ClientConn) ClusterClient

type ClusterServer 

type ClusterServer interface {
	Step(Cluster_StepServer) error
}

type Cluster_StepClient 

type Cluster_StepClient interface {
	Send(*StepRequest) error
	Recv() (*StepResponse, error)
	grpc.ClientStream
}

type Cluster_StepServer 

type Cluster_StepServer interface {
	Send(*StepResponse) error
	Recv() (*StepRequest, error)
	grpc.ServerStream
}

type ConsensusRequest 

type ConsensusRequest struct {
	Channel              string   `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Payload              []byte   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Metadata             []byte   `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConsensusRequest) Descriptor 

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

func (*ConsensusRequest) GetChannel 

func (m *ConsensusRequest) GetChannel() string

func (*ConsensusRequest) GetMetadata 

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

func (*ConsensusRequest) GetPayload 

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

func (*ConsensusRequest) ProtoMessage 

func (*ConsensusRequest) ProtoMessage()

func (*ConsensusRequest) Reset 

func (m *ConsensusRequest) Reset()

func (*ConsensusRequest) String 

func (m *ConsensusRequest) String() string

func (*ConsensusRequest) XXX_DiscardUnknown 

func (m *ConsensusRequest) XXX_DiscardUnknown()

func (*ConsensusRequest) XXX_Marshal 

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

func (*ConsensusRequest) XXX_Merge 

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

func (*ConsensusRequest) XXX_Size 

func (m *ConsensusRequest) XXX_Size() int

func (*ConsensusRequest) XXX_Unmarshal 

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

type ConsensusType 

type ConsensusType struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`

	Metadata []byte `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`

	State                ConsensusType_State `protobuf:"varint,3,opt,name=state,proto3,enum=orderer.ConsensusType_State" json:"state,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) GetState 

func (m *ConsensusType) GetState() ConsensusType_State

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 (m *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 ConsensusTypeMetadataFactory 

type ConsensusTypeMetadataFactory interface {
	NewMessage() proto.Message
}

type ConsensusType_State 

type ConsensusType_State int32
const (
	ConsensusType_STATE_NORMAL      ConsensusType_State = 0
	ConsensusType_STATE_MAINTENANCE ConsensusType_State = 1
)

func (ConsensusType_State) EnumDescriptor 

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

func (ConsensusType_State) String 

func (x ConsensusType_State) String() string

type DeliverResponse 

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

func (*DeliverResponse) XXX_OneofWrappers 

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

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_Block struct {
	Block *common.Block `protobuf:"bytes,2,opt,name=block,proto3,oneof"`
}

type DeliverResponse_Status 

type DeliverResponse_Status struct {
	Status common.Status `protobuf:"varint,1,opt,name=status,proto3,enum=common.Status,oneof"`
}

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 

func (dcg *DynamicOrdererGroup) DynamicMapFieldProto(name string, key string, base proto.Message) (proto.Message, error)

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 

func (dcg *DynamicOrdererOrgGroup) DynamicMapFieldProto(name string, key string, base proto.Message) (proto.Message, error)

type KafkaBrokers 

type KafkaBrokers struct {
	Brokers              []string `protobuf:"bytes,1,rep,name=brokers,proto3" json:"brokers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 (m *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 {
	Type                 isKafkaMessage_Type `protobuf_oneof:"Type"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

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

func (*KafkaMessage) XXX_OneofWrappers 

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

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

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 (m *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,proto3" json:"config_seq,omitempty"`
	Class                KafkaMessageRegular_Class `protobuf:"varint,3,opt,name=class,proto3,enum=orderer.KafkaMessageRegular_Class" json:"class,omitempty"`
	OriginalOffset       int64                     `protobuf:"varint,4,opt,name=original_offset,json=originalOffset,proto3" json:"original_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

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 (m *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,proto3" json:"block_number,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 (m *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,proto3,oneof"`
}

type KafkaMessage_Regular 

type KafkaMessage_Regular struct {
	Regular *KafkaMessageRegular `protobuf:"bytes,1,opt,name=regular,proto3,oneof"`
}

type KafkaMessage_TimeToCut 

type KafkaMessage_TimeToCut struct {
	TimeToCut *KafkaMessageTimeToCut `protobuf:"bytes,2,opt,name=time_to_cut,json=timeToCut,proto3,oneof"`
}

type KafkaMetadata 

type KafkaMetadata struct {
	LastOffsetPersisted int64 `protobuf:"varint,1,opt,name=last_offset_persisted,json=lastOffsetPersisted,proto3" json:"last_offset_persisted,omitempty"`

	LastOriginalOffsetProcessed int64 `` /* 147-byte string literal not displayed */

	LastResubmittedConfigOffset int64    `` /* 147-byte string literal not displayed */
	XXX_NoUnkeyedLiteral        struct{} `json:"-"`
	XXX_unrecognized            []byte   `json:"-"`
	XXX_sizecache               int32    `json:"-"`
}

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 (m *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,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"`
	ErrorResponse        SeekInfo_SeekErrorResponse `` /* 141-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*SeekInfo) Descriptor 

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

func (*SeekInfo) GetBehavior 

func (m *SeekInfo) GetBehavior() SeekInfo_SeekBehavior

func (*SeekInfo) GetErrorResponse 

func (m *SeekInfo) GetErrorResponse() SeekInfo_SeekErrorResponse

func (*SeekInfo) GetStart 

func (m *SeekInfo) GetStart() *SeekPosition

func (*SeekInfo) GetStop 

func (m *SeekInfo) GetStop() *SeekPosition

func (*SeekInfo) ProtoMessage 

func (*SeekInfo) ProtoMessage()

func (*SeekInfo) Reset 

func (m *SeekInfo) Reset()

func (*SeekInfo) String 

func (m *SeekInfo) String() string

func (*SeekInfo) XXX_DiscardUnknown 

func (m *SeekInfo) XXX_DiscardUnknown()

func (*SeekInfo) XXX_Marshal 

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

func (*SeekInfo) XXX_Merge 

func (m *SeekInfo) XXX_Merge(src proto.Message)

func (*SeekInfo) XXX_Size 

func (m *SeekInfo) XXX_Size() int

func (*SeekInfo) XXX_Unmarshal 

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

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 SeekInfo_SeekErrorResponse 

type SeekInfo_SeekErrorResponse int32
const (
	SeekInfo_STRICT      SeekInfo_SeekErrorResponse = 0
	SeekInfo_BEST_EFFORT SeekInfo_SeekErrorResponse = 1
)

func (SeekInfo_SeekErrorResponse) EnumDescriptor 

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

func (SeekInfo_SeekErrorResponse) String 

func (x SeekInfo_SeekErrorResponse) 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 (m *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 (m *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 {
	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 (m *SeekPosition) XXX_Merge(src proto.Message)

func (*SeekPosition) XXX_OneofWrappers 

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

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 (m *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 {
	Payload              isStepRequest_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*StepRequest) Descriptor 

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

func (*StepRequest) GetConsensusRequest 

func (m *StepRequest) GetConsensusRequest() *ConsensusRequest

func (*StepRequest) GetPayload 

func (m *StepRequest) GetPayload() isStepRequest_Payload

func (*StepRequest) GetSubmitRequest 

func (m *StepRequest) GetSubmitRequest() *SubmitRequest

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

func (*StepRequest) XXX_OneofWrappers 

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

func (*StepRequest) XXX_Size 

func (m *StepRequest) XXX_Size() int

func (*StepRequest) XXX_Unmarshal 

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

type StepRequest_ConsensusRequest 

type StepRequest_ConsensusRequest struct {
	ConsensusRequest *ConsensusRequest `protobuf:"bytes,1,opt,name=consensus_request,json=consensusRequest,proto3,oneof"`
}

type StepRequest_SubmitRequest 

type StepRequest_SubmitRequest struct {
	SubmitRequest *SubmitRequest `protobuf:"bytes,2,opt,name=submit_request,json=submitRequest,proto3,oneof"`
}

type StepResponse 

type StepResponse struct {
	Payload              isStepResponse_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*StepResponse) Descriptor 

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

func (*StepResponse) GetPayload 

func (m *StepResponse) GetPayload() isStepResponse_Payload

func (*StepResponse) GetSubmitRes 

func (m *StepResponse) GetSubmitRes() *SubmitResponse

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

func (*StepResponse) XXX_OneofWrappers 

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

func (*StepResponse) XXX_Size 

func (m *StepResponse) XXX_Size() int

func (*StepResponse) XXX_Unmarshal 

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

type StepResponse_SubmitRes 

type StepResponse_SubmitRes struct {
	SubmitRes *SubmitResponse `protobuf:"bytes,1,opt,name=submit_res,json=submitRes,proto3,oneof"`
}

type SubmitRequest 

type SubmitRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`

	LastValidationSeq uint64 `protobuf:"varint,2,opt,name=last_validation_seq,json=lastValidationSeq,proto3" json:"last_validation_seq,omitempty"`

	Payload              *common.Envelope `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SubmitRequest) Descriptor 

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

func (*SubmitRequest) GetChannel 

func (m *SubmitRequest) GetChannel() string

func (*SubmitRequest) GetLastValidationSeq 

func (m *SubmitRequest) GetLastValidationSeq() uint64

func (*SubmitRequest) GetPayload 

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

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 (m *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 {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`

	Status common.Status `protobuf:"varint,2,opt,name=status,proto3,enum=common.Status" json:"status,omitempty"`

	Info                 string   `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubmitResponse) Descriptor 

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

func (*SubmitResponse) GetChannel 

func (m *SubmitResponse) GetChannel() string

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 (m *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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.