orderer

package
v0.0.0-...-79afef5 Latest Latest
Warning

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

 Go to latest Published: Mar 5, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SeekInfo_SeekBehavior_name = map[int32]string{
		0: "BLOCK_UNTIL_READY",
		1: "FAIL_IF_NOT_READY",
	}
	SeekInfo_SeekBehavior_value = map[string]int32{
		"BLOCK_UNTIL_READY": 0,
		"FAIL_IF_NOT_READY": 1,
	}
)

Enum value maps for SeekInfo_SeekBehavior.

View Source 
var (
	SeekInfo_SeekErrorResponse_name = map[int32]string{
		0: "STRICT",
		1: "BEST_EFFORT",
	}
	SeekInfo_SeekErrorResponse_value = map[string]int32{
		"STRICT":      0,
		"BEST_EFFORT": 1,
	}
)

Enum value maps for SeekInfo_SeekErrorResponse.

View Source 
var (
	ConsensusType_State_name = map[int32]string{
		0: "STATE_NORMAL",
		1: "STATE_MAINTENANCE",
	}
	ConsensusType_State_value = map[string]int32{
		"STATE_NORMAL":      0,
		"STATE_MAINTENANCE": 1,
	}
)

Enum value maps for ConsensusType_State.

View Source 
var (
	KafkaMessageRegular_Class_name = map[int32]string{
		0: "UNKNOWN",
		1: "NORMAL",
		2: "CONFIG",
	}
	KafkaMessageRegular_Class_value = map[string]int32{
		"UNKNOWN": 0,
		"NORMAL":  1,
		"CONFIG":  2,
	}
)

Enum value maps for KafkaMessageRegular_Class.

View Source 
var AtomicBroadcast_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "orderer.AtomicBroadcast",
	HandlerType: (*AtomicBroadcastServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Broadcast",
			Handler:       _AtomicBroadcast_Broadcast_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "Deliver",
			Handler:       _AtomicBroadcast_Deliver_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "orderer/ab.proto",
}

AtomicBroadcast_ServiceDesc is the grpc.ServiceDesc for AtomicBroadcast service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Cluster_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "orderer.Cluster",
	HandlerType: (*ClusterServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Step",
			Handler:       _Cluster_Step_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "orderer/cluster.proto",
}

Cluster_ServiceDesc is the grpc.ServiceDesc for Cluster service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_orderer_ab_proto protoreflect.FileDescriptor
View Source 
var File_orderer_cluster_proto protoreflect.FileDescriptor
View Source 
var File_orderer_configuration_proto protoreflect.FileDescriptor
View Source 
var File_orderer_kafka_proto protoreflect.FileDescriptor

Functions

func RegisterAtomicBroadcastServer 

func RegisterAtomicBroadcastServer(s grpc.ServiceRegistrar, srv AtomicBroadcastServer)

func RegisterClusterServer 

func RegisterClusterServer(s grpc.ServiceRegistrar, 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)
}

AtomicBroadcastClient is the client API for AtomicBroadcast service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAtomicBroadcastClient 

func NewAtomicBroadcastClient(cc grpc.ClientConnInterface) 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
	// contains filtered or unexported methods
}

AtomicBroadcastServer is the server API for AtomicBroadcast service. All implementations must embed UnimplementedAtomicBroadcastServer for forward compatibility

type AtomicBroadcast_BroadcastClient 

type AtomicBroadcast_BroadcastClient interface {
	Send(*common.Envelope) error
	Recv() (*BroadcastResponse, error)
	grpc.ClientStream
}

type AtomicBroadcast_BroadcastServer 

type AtomicBroadcast_BroadcastServer interface {
	Send(*BroadcastResponse) error
	Recv() (*common.Envelope, error)
	grpc.ServerStream
}

type AtomicBroadcast_DeliverClient 

type AtomicBroadcast_DeliverClient interface {
	Send(*common.Envelope) error
	Recv() (*DeliverResponse, error)
	grpc.ClientStream
}

type AtomicBroadcast_DeliverServer 

type AtomicBroadcast_DeliverServer interface {
	Send(*DeliverResponse) error
	Recv() (*common.Envelope, error)
	grpc.ServerStream
}

type BatchSize 

type BatchSize struct {

	// Simply specified as number of messages for now, in the future
	// we may want to allow this to be specified by size in bytes
	MaxMessageCount uint32 `protobuf:"varint,1,opt,name=max_message_count,json=maxMessageCount,proto3" json:"max_message_count,omitempty"`
	// The byte count of the serialized messages in a batch cannot
	// exceed this value.
	AbsoluteMaxBytes uint32 `protobuf:"varint,2,opt,name=absolute_max_bytes,json=absoluteMaxBytes,proto3" json:"absolute_max_bytes,omitempty"`
	// The byte count of the serialized messages in a batch should not
	// exceed this value.
	PreferredMaxBytes uint32 `protobuf:"varint,3,opt,name=preferred_max_bytes,json=preferredMaxBytes,proto3" json:"preferred_max_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchSize) Descriptor deprecated 

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

Deprecated: Use BatchSize.ProtoReflect.Descriptor instead.

func (*BatchSize) GetAbsoluteMaxBytes 

func (x *BatchSize) GetAbsoluteMaxBytes() uint32

func (*BatchSize) GetMaxMessageCount 

func (x *BatchSize) GetMaxMessageCount() uint32

func (*BatchSize) GetPreferredMaxBytes 

func (x *BatchSize) GetPreferredMaxBytes() uint32

func (*BatchSize) ProtoMessage 

func (*BatchSize) ProtoMessage()

func (*BatchSize) ProtoReflect 

func (x *BatchSize) ProtoReflect() protoreflect.Message

func (*BatchSize) Reset 

func (x *BatchSize) Reset()

func (*BatchSize) String 

func (x *BatchSize) String() string

type BatchTimeout 

type BatchTimeout struct {

	// Any duration string parseable by ParseDuration():
	// https://golang.org/pkg/time/#ParseDuration
	Timeout string `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchTimeout) Descriptor deprecated 

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

Deprecated: Use BatchTimeout.ProtoReflect.Descriptor instead.

func (*BatchTimeout) GetTimeout 

func (x *BatchTimeout) GetTimeout() string

func (*BatchTimeout) ProtoMessage 

func (*BatchTimeout) ProtoMessage()

func (*BatchTimeout) ProtoReflect 

func (x *BatchTimeout) ProtoReflect() protoreflect.Message

func (*BatchTimeout) Reset 

func (x *BatchTimeout) Reset()

func (*BatchTimeout) String 

func (x *BatchTimeout) String() string

type BroadcastResponse 

type BroadcastResponse struct {

	// Status code, which may be used to programatically respond to success/failure
	Status common.Status `protobuf:"varint,1,opt,name=status,proto3,enum=common.Status" json:"status,omitempty"`
	// Info string which may contain additional information about the status returned
	Info string `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*BroadcastResponse) Descriptor deprecated 

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

Deprecated: Use BroadcastResponse.ProtoReflect.Descriptor instead.

func (*BroadcastResponse) GetInfo 

func (x *BroadcastResponse) GetInfo() string

func (*BroadcastResponse) GetStatus 

func (x *BroadcastResponse) GetStatus() common.Status

func (*BroadcastResponse) ProtoMessage 

func (*BroadcastResponse) ProtoMessage()

func (*BroadcastResponse) ProtoReflect 

func (x *BroadcastResponse) ProtoReflect() protoreflect.Message

func (*BroadcastResponse) Reset 

func (x *BroadcastResponse) Reset()

func (*BroadcastResponse) String 

func (x *BroadcastResponse) String() string

type ChannelRestrictions 

type ChannelRestrictions struct {
	MaxCount uint64 `protobuf:"varint,1,opt,name=max_count,json=maxCount,proto3" json:"max_count,omitempty"` // The max count of channels to allow to be created, a value of 0 indicates no limit
	// contains filtered or unexported fields
}

ChannelRestrictions is the mssage which conveys restrictions on channel creation for an orderer

func (*ChannelRestrictions) Descriptor deprecated 

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

Deprecated: Use ChannelRestrictions.ProtoReflect.Descriptor instead.

func (*ChannelRestrictions) GetMaxCount 

func (x *ChannelRestrictions) GetMaxCount() uint64

func (*ChannelRestrictions) ProtoMessage 

func (*ChannelRestrictions) ProtoMessage()

func (*ChannelRestrictions) ProtoReflect 

func (x *ChannelRestrictions) ProtoReflect() protoreflect.Message

func (*ChannelRestrictions) Reset 

func (x *ChannelRestrictions) Reset()

func (*ChannelRestrictions) String 

func (x *ChannelRestrictions) String() string

type ClusterClient 

type ClusterClient interface {
	// Step passes an implementation-specific message to another cluster member.
	Step(ctx context.Context, opts ...grpc.CallOption) (Cluster_StepClient, error)
}

ClusterClient is the client API for Cluster service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewClusterClient 

func NewClusterClient(cc grpc.ClientConnInterface) ClusterClient

type ClusterServer 

type ClusterServer interface {
	// Step passes an implementation-specific message to another cluster member.
	Step(Cluster_StepServer) error
	// contains filtered or unexported methods
}

ClusterServer is the server API for Cluster service. All implementations must embed UnimplementedClusterServer for forward compatibility

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"`
	// contains filtered or unexported fields
}

ConsensusRequest is a consensus specific message sent to a cluster member.

func (*ConsensusRequest) Descriptor deprecated 

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

Deprecated: Use ConsensusRequest.ProtoReflect.Descriptor instead.

func (*ConsensusRequest) GetChannel 

func (x *ConsensusRequest) GetChannel() string

func (*ConsensusRequest) GetMetadata 

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

func (*ConsensusRequest) GetPayload 

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

func (*ConsensusRequest) ProtoMessage 

func (*ConsensusRequest) ProtoMessage()

func (*ConsensusRequest) ProtoReflect 

func (x *ConsensusRequest) ProtoReflect() protoreflect.Message

func (*ConsensusRequest) Reset 

func (x *ConsensusRequest) Reset()

func (*ConsensusRequest) String 

func (x *ConsensusRequest) String() string

type ConsensusType 

type ConsensusType struct {

	// The consensus type: "solo", "kafka" or "etcdraft".
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Opaque metadata, dependent on the consensus type.
	Metadata []byte `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// The state signals the ordering service to go into maintenance mode, typically for consensus-type migration.
	State ConsensusType_State `protobuf:"varint,3,opt,name=state,proto3,enum=orderer.ConsensusType_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsensusType) Descriptor deprecated 

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

Deprecated: Use ConsensusType.ProtoReflect.Descriptor instead.

func (*ConsensusType) GetMetadata 

func (x *ConsensusType) GetMetadata() []byte

func (*ConsensusType) GetState 

func (x *ConsensusType) GetState() ConsensusType_State

func (*ConsensusType) GetType 

func (x *ConsensusType) GetType() string

func (*ConsensusType) ProtoMessage 

func (*ConsensusType) ProtoMessage()

func (*ConsensusType) ProtoReflect 

func (x *ConsensusType) ProtoReflect() protoreflect.Message

func (*ConsensusType) Reset 

func (x *ConsensusType) Reset()

func (*ConsensusType) String 

func (x *ConsensusType) String() string

type ConsensusType_State 

type ConsensusType_State int32

State defines the orderer mode of operation, typically for consensus-type migration. NORMAL is during normal operation, when consensus-type migration is not, and can not, take place. MAINTENANCE is when the consensus-type can be changed. 

const (
	ConsensusType_STATE_NORMAL      ConsensusType_State = 0
	ConsensusType_STATE_MAINTENANCE ConsensusType_State = 1
)

func (ConsensusType_State) Descriptor 

func (ConsensusType_State) Descriptor() protoreflect.EnumDescriptor

func (ConsensusType_State) Enum 

func (x ConsensusType_State) Enum() *ConsensusType_State

func (ConsensusType_State) EnumDescriptor deprecated 

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

Deprecated: Use ConsensusType_State.Descriptor instead.

func (ConsensusType_State) Number 

func (x ConsensusType_State) Number() protoreflect.EnumNumber

func (ConsensusType_State) String 

func (x ConsensusType_State) String() string

func (ConsensusType_State) Type 

func (ConsensusType_State) Type() protoreflect.EnumType

type DeliverResponse 

type DeliverResponse struct {

	// Types that are assignable to Type:
	//	*DeliverResponse_Status
	//	*DeliverResponse_Block
	Type isDeliverResponse_Type `protobuf_oneof:"Type"`
	// contains filtered or unexported fields
}

func (*DeliverResponse) Descriptor deprecated 

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

Deprecated: Use DeliverResponse.ProtoReflect.Descriptor instead.

func (*DeliverResponse) GetBlock 

func (x *DeliverResponse) GetBlock() *common.Block

func (*DeliverResponse) GetStatus 

func (x *DeliverResponse) GetStatus() common.Status

func (*DeliverResponse) GetType 

func (m *DeliverResponse) GetType() isDeliverResponse_Type

func (*DeliverResponse) ProtoMessage 

func (*DeliverResponse) ProtoMessage()

func (*DeliverResponse) ProtoReflect 

func (x *DeliverResponse) ProtoReflect() protoreflect.Message

func (*DeliverResponse) Reset 

func (x *DeliverResponse) Reset()

func (*DeliverResponse) String 

func (x *DeliverResponse) String() string

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 KafkaBrokers 

type KafkaBrokers struct {

	// Each broker here should be identified using the (IP|host):port notation,
	// e.g. 127.0.0.1:7050, or localhost:7050 are valid entries
	Brokers []string `protobuf:"bytes,1,rep,name=brokers,proto3" json:"brokers,omitempty"`
	// contains filtered or unexported fields
}

Carries a list of bootstrap brokers, i.e. this is not the exclusive set of brokers an ordering service

func (*KafkaBrokers) Descriptor deprecated 

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

Deprecated: Use KafkaBrokers.ProtoReflect.Descriptor instead.

func (*KafkaBrokers) GetBrokers 

func (x *KafkaBrokers) GetBrokers() []string

func (*KafkaBrokers) ProtoMessage 

func (*KafkaBrokers) ProtoMessage()

func (*KafkaBrokers) ProtoReflect 

func (x *KafkaBrokers) ProtoReflect() protoreflect.Message

func (*KafkaBrokers) Reset 

func (x *KafkaBrokers) Reset()

func (*KafkaBrokers) String 

func (x *KafkaBrokers) String() string

type KafkaMessage 

type KafkaMessage struct {

	// Types that are assignable to Type:
	//	*KafkaMessage_Regular
	//	*KafkaMessage_TimeToCut
	//	*KafkaMessage_Connect
	Type isKafkaMessage_Type `protobuf_oneof:"Type"`
	// contains filtered or unexported fields
}

KafkaMessage is a wrapper type for the messages that the Kafka-based orderer deals with.

func (*KafkaMessage) Descriptor deprecated 

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

Deprecated: Use KafkaMessage.ProtoReflect.Descriptor instead.

func (*KafkaMessage) GetConnect 

func (x *KafkaMessage) GetConnect() *KafkaMessageConnect

func (*KafkaMessage) GetRegular 

func (x *KafkaMessage) GetRegular() *KafkaMessageRegular

func (*KafkaMessage) GetTimeToCut 

func (x *KafkaMessage) GetTimeToCut() *KafkaMessageTimeToCut

func (*KafkaMessage) GetType 

func (m *KafkaMessage) GetType() isKafkaMessage_Type

func (*KafkaMessage) ProtoMessage 

func (*KafkaMessage) ProtoMessage()

func (*KafkaMessage) ProtoReflect 

func (x *KafkaMessage) ProtoReflect() protoreflect.Message

func (*KafkaMessage) Reset 

func (x *KafkaMessage) Reset()

func (*KafkaMessage) String 

func (x *KafkaMessage) String() string

type KafkaMessageConnect 

type KafkaMessageConnect struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

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 deprecated 

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

Deprecated: Use KafkaMessageConnect.ProtoReflect.Descriptor instead.

func (*KafkaMessageConnect) GetPayload 

func (x *KafkaMessageConnect) GetPayload() []byte

func (*KafkaMessageConnect) ProtoMessage 

func (*KafkaMessageConnect) ProtoMessage()

func (*KafkaMessageConnect) ProtoReflect 

func (x *KafkaMessageConnect) ProtoReflect() protoreflect.Message

func (*KafkaMessageConnect) Reset 

func (x *KafkaMessageConnect) Reset()

func (*KafkaMessageConnect) String 

func (x *KafkaMessageConnect) String() string

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"`
	// contains filtered or unexported fields
}

KafkaMessageRegular wraps a marshalled envelope.

func (*KafkaMessageRegular) Descriptor deprecated 

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

Deprecated: Use KafkaMessageRegular.ProtoReflect.Descriptor instead.

func (*KafkaMessageRegular) GetClass 

func (x *KafkaMessageRegular) GetClass() KafkaMessageRegular_Class

func (*KafkaMessageRegular) GetConfigSeq 

func (x *KafkaMessageRegular) GetConfigSeq() uint64

func (*KafkaMessageRegular) GetOriginalOffset 

func (x *KafkaMessageRegular) GetOriginalOffset() int64

func (*KafkaMessageRegular) GetPayload 

func (x *KafkaMessageRegular) GetPayload() []byte

func (*KafkaMessageRegular) ProtoMessage 

func (*KafkaMessageRegular) ProtoMessage()

func (*KafkaMessageRegular) ProtoReflect 

func (x *KafkaMessageRegular) ProtoReflect() protoreflect.Message

func (*KafkaMessageRegular) Reset 

func (x *KafkaMessageRegular) Reset()

func (*KafkaMessageRegular) String 

func (x *KafkaMessageRegular) String() string

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

func (KafkaMessageRegular_Class) Descriptor() protoreflect.EnumDescriptor

func (KafkaMessageRegular_Class) Enum 

func (x KafkaMessageRegular_Class) Enum() *KafkaMessageRegular_Class

func (KafkaMessageRegular_Class) EnumDescriptor deprecated 

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

Deprecated: Use KafkaMessageRegular_Class.Descriptor instead.

func (KafkaMessageRegular_Class) Number 

func (x KafkaMessageRegular_Class) Number() protoreflect.EnumNumber

func (KafkaMessageRegular_Class) String 

func (x KafkaMessageRegular_Class) String() string

func (KafkaMessageRegular_Class) Type 

func (KafkaMessageRegular_Class) Type() protoreflect.EnumType

type KafkaMessageTimeToCut 

type KafkaMessageTimeToCut struct {
	BlockNumber uint64 `protobuf:"varint,1,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
	// contains filtered or unexported fields
}

KafkaMessageTimeToCut is used to signal to the orderers that it is time to cut block <block_number>.

func (*KafkaMessageTimeToCut) Descriptor deprecated 

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

Deprecated: Use KafkaMessageTimeToCut.ProtoReflect.Descriptor instead.

func (*KafkaMessageTimeToCut) GetBlockNumber 

func (x *KafkaMessageTimeToCut) GetBlockNumber() uint64

func (*KafkaMessageTimeToCut) ProtoMessage 

func (*KafkaMessageTimeToCut) ProtoMessage()

func (*KafkaMessageTimeToCut) ProtoReflect 

func (x *KafkaMessageTimeToCut) ProtoReflect() protoreflect.Message

func (*KafkaMessageTimeToCut) Reset 

func (x *KafkaMessageTimeToCut) Reset()

func (*KafkaMessageTimeToCut) String 

func (x *KafkaMessageTimeToCut) String() string

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 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,proto3" 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 `` /* 147-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 `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

KafkaMetadata is encoded into the ORDERER block to keep track of Kafka-related metadata associated with this block.

func (*KafkaMetadata) Descriptor deprecated 

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

Deprecated: Use KafkaMetadata.ProtoReflect.Descriptor instead.

func (*KafkaMetadata) GetLastOffsetPersisted 

func (x *KafkaMetadata) GetLastOffsetPersisted() int64

func (*KafkaMetadata) GetLastOriginalOffsetProcessed 

func (x *KafkaMetadata) GetLastOriginalOffsetProcessed() int64

func (*KafkaMetadata) GetLastResubmittedConfigOffset 

func (x *KafkaMetadata) GetLastResubmittedConfigOffset() int64

func (*KafkaMetadata) ProtoMessage 

func (*KafkaMetadata) ProtoMessage()

func (*KafkaMetadata) ProtoReflect 

func (x *KafkaMetadata) ProtoReflect() protoreflect.Message

func (*KafkaMetadata) Reset 

func (x *KafkaMetadata) Reset()

func (*KafkaMetadata) String 

func (x *KafkaMetadata) String() string

type SeekInfo 

type SeekInfo struct {
	Start         *SeekPosition              `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`                                           // The position to start the deliver from
	Stop          *SeekPosition              `protobuf:"bytes,2,opt,name=stop,proto3" json:"stop,omitempty"`                                             // The position to stop the deliver
	Behavior      SeekInfo_SeekBehavior      `protobuf:"varint,3,opt,name=behavior,proto3,enum=orderer.SeekInfo_SeekBehavior" json:"behavior,omitempty"` // The behavior when a missing block is encountered
	ErrorResponse SeekInfo_SeekErrorResponse ``                                                                                                          // How to respond to errors reported to the deliver service
	/* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

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.

func (*SeekInfo) Descriptor deprecated 

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

Deprecated: Use SeekInfo.ProtoReflect.Descriptor instead.

func (*SeekInfo) GetBehavior 

func (x *SeekInfo) GetBehavior() SeekInfo_SeekBehavior

func (*SeekInfo) GetErrorResponse 

func (x *SeekInfo) GetErrorResponse() SeekInfo_SeekErrorResponse

func (*SeekInfo) GetStart 

func (x *SeekInfo) GetStart() *SeekPosition

func (*SeekInfo) GetStop 

func (x *SeekInfo) GetStop() *SeekPosition

func (*SeekInfo) ProtoMessage 

func (*SeekInfo) ProtoMessage()

func (*SeekInfo) ProtoReflect 

func (x *SeekInfo) ProtoReflect() protoreflect.Message

func (*SeekInfo) Reset 

func (x *SeekInfo) Reset()

func (*SeekInfo) String 

func (x *SeekInfo) String() string

type SeekInfo_SeekBehavior 

type SeekInfo_SeekBehavior int32

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 

const (
	SeekInfo_BLOCK_UNTIL_READY SeekInfo_SeekBehavior = 0
	SeekInfo_FAIL_IF_NOT_READY SeekInfo_SeekBehavior = 1
)

func (SeekInfo_SeekBehavior) Descriptor 

func (SeekInfo_SeekBehavior) Descriptor() protoreflect.EnumDescriptor

func (SeekInfo_SeekBehavior) Enum 

func (x SeekInfo_SeekBehavior) Enum() *SeekInfo_SeekBehavior

func (SeekInfo_SeekBehavior) EnumDescriptor deprecated 

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

Deprecated: Use SeekInfo_SeekBehavior.Descriptor instead.

func (SeekInfo_SeekBehavior) Number 

func (x SeekInfo_SeekBehavior) Number() protoreflect.EnumNumber

func (SeekInfo_SeekBehavior) String 

func (x SeekInfo_SeekBehavior) String() string

func (SeekInfo_SeekBehavior) Type 

func (SeekInfo_SeekBehavior) Type() protoreflect.EnumType

type SeekInfo_SeekErrorResponse 

type SeekInfo_SeekErrorResponse int32

SeekErrorTolerance indicates to the server how block provider errors should be tolerated. By default, if the deliver service detects a problem in the underlying block source (typically, in the orderer, a consenter error), it will begin to reject deliver requests. This is to prevent a client from waiting for blocks from an orderer which is stuck in an errored state. This is almost always the desired behavior and clients should stick with the default STRICT checking behavior. However, in some scenarios, particularly when attempting to recover from a crash or other corruption, it's desirable to force an orderer to respond with blocks on a best effort basis, even if the backing consensus implementation is in an errored state. In this case, set the SeekErrorResponse to BEST_EFFORT to ignore the consenter errors. 

const (
	SeekInfo_STRICT      SeekInfo_SeekErrorResponse = 0
	SeekInfo_BEST_EFFORT SeekInfo_SeekErrorResponse = 1
)

func (SeekInfo_SeekErrorResponse) Descriptor 

func (SeekInfo_SeekErrorResponse) Descriptor() protoreflect.EnumDescriptor

func (SeekInfo_SeekErrorResponse) Enum 

func (x SeekInfo_SeekErrorResponse) Enum() *SeekInfo_SeekErrorResponse

func (SeekInfo_SeekErrorResponse) EnumDescriptor deprecated 

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

Deprecated: Use SeekInfo_SeekErrorResponse.Descriptor instead.

func (SeekInfo_SeekErrorResponse) Number 

func (x SeekInfo_SeekErrorResponse) Number() protoreflect.EnumNumber

func (SeekInfo_SeekErrorResponse) String 

func (x SeekInfo_SeekErrorResponse) String() string

func (SeekInfo_SeekErrorResponse) Type 

func (SeekInfo_SeekErrorResponse) Type() protoreflect.EnumType

type SeekNewest 

type SeekNewest struct {
	// contains filtered or unexported fields
}

func (*SeekNewest) Descriptor deprecated 

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

Deprecated: Use SeekNewest.ProtoReflect.Descriptor instead.

func (*SeekNewest) ProtoMessage 

func (*SeekNewest) ProtoMessage()

func (*SeekNewest) ProtoReflect 

func (x *SeekNewest) ProtoReflect() protoreflect.Message

func (*SeekNewest) Reset 

func (x *SeekNewest) Reset()

func (*SeekNewest) String 

func (x *SeekNewest) String() string

type SeekNextCommit 

type SeekNextCommit struct {
	// contains filtered or unexported fields
}

SeekNextCommit refers to the next block that will be committed

func (*SeekNextCommit) Descriptor deprecated 

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

Deprecated: Use SeekNextCommit.ProtoReflect.Descriptor instead.

func (*SeekNextCommit) ProtoMessage 

func (*SeekNextCommit) ProtoMessage()

func (*SeekNextCommit) ProtoReflect 

func (x *SeekNextCommit) ProtoReflect() protoreflect.Message

func (*SeekNextCommit) Reset 

func (x *SeekNextCommit) Reset()

func (*SeekNextCommit) String 

func (x *SeekNextCommit) String() string

type SeekOldest 

type SeekOldest struct {
	// contains filtered or unexported fields
}

func (*SeekOldest) Descriptor deprecated 

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

Deprecated: Use SeekOldest.ProtoReflect.Descriptor instead.

func (*SeekOldest) ProtoMessage 

func (*SeekOldest) ProtoMessage()

func (*SeekOldest) ProtoReflect 

func (x *SeekOldest) ProtoReflect() protoreflect.Message

func (*SeekOldest) Reset 

func (x *SeekOldest) Reset()

func (*SeekOldest) String 

func (x *SeekOldest) String() string

type SeekPosition 

type SeekPosition struct {

	// Types that are assignable to Type:
	//	*SeekPosition_Newest
	//	*SeekPosition_Oldest
	//	*SeekPosition_Specified
	//	*SeekPosition_NextCommit
	Type isSeekPosition_Type `protobuf_oneof:"Type"`
	// contains filtered or unexported fields
}

func (*SeekPosition) Descriptor deprecated 

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

Deprecated: Use SeekPosition.ProtoReflect.Descriptor instead.

func (*SeekPosition) GetNewest 

func (x *SeekPosition) GetNewest() *SeekNewest

func (*SeekPosition) GetNextCommit 

func (x *SeekPosition) GetNextCommit() *SeekNextCommit

func (*SeekPosition) GetOldest 

func (x *SeekPosition) GetOldest() *SeekOldest

func (*SeekPosition) GetSpecified 

func (x *SeekPosition) GetSpecified() *SeekSpecified

func (*SeekPosition) GetType 

func (m *SeekPosition) GetType() isSeekPosition_Type

func (*SeekPosition) ProtoMessage 

func (*SeekPosition) ProtoMessage()

func (*SeekPosition) ProtoReflect 

func (x *SeekPosition) ProtoReflect() protoreflect.Message

func (*SeekPosition) Reset 

func (x *SeekPosition) Reset()

func (*SeekPosition) String 

func (x *SeekPosition) String() string

type SeekPosition_Newest 

type SeekPosition_Newest struct {
	Newest *SeekNewest `protobuf:"bytes,1,opt,name=newest,proto3,oneof"`
}

type SeekPosition_NextCommit 

type SeekPosition_NextCommit struct {
	NextCommit *SeekNextCommit `protobuf:"bytes,4,opt,name=next_commit,json=nextCommit,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"`
	// contains filtered or unexported fields
}

func (*SeekSpecified) Descriptor deprecated 

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

Deprecated: Use SeekSpecified.ProtoReflect.Descriptor instead.

func (*SeekSpecified) GetNumber 

func (x *SeekSpecified) GetNumber() uint64

func (*SeekSpecified) ProtoMessage 

func (*SeekSpecified) ProtoMessage()

func (*SeekSpecified) ProtoReflect 

func (x *SeekSpecified) ProtoReflect() protoreflect.Message

func (*SeekSpecified) Reset 

func (x *SeekSpecified) Reset()

func (*SeekSpecified) String 

func (x *SeekSpecified) String() string

type StepRequest 

type StepRequest struct {

	// Types that are assignable to Payload:
	//	*StepRequest_ConsensusRequest
	//	*StepRequest_SubmitRequest
	Payload isStepRequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

StepRequest wraps a message that is sent to a cluster member.

func (*StepRequest) Descriptor deprecated 

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

Deprecated: Use StepRequest.ProtoReflect.Descriptor instead.

func (*StepRequest) GetConsensusRequest 

func (x *StepRequest) GetConsensusRequest() *ConsensusRequest

func (*StepRequest) GetPayload 

func (m *StepRequest) GetPayload() isStepRequest_Payload

func (*StepRequest) GetSubmitRequest 

func (x *StepRequest) GetSubmitRequest() *SubmitRequest

func (*StepRequest) ProtoMessage 

func (*StepRequest) ProtoMessage()

func (*StepRequest) ProtoReflect 

func (x *StepRequest) ProtoReflect() protoreflect.Message

func (*StepRequest) Reset 

func (x *StepRequest) Reset()

func (*StepRequest) String 

func (x *StepRequest) String() string

type StepRequest_ConsensusRequest 

type StepRequest_ConsensusRequest struct {
	// consensus_request is a consensus specific message.
	ConsensusRequest *ConsensusRequest `protobuf:"bytes,1,opt,name=consensus_request,json=consensusRequest,proto3,oneof"`
}

type StepRequest_SubmitRequest 

type StepRequest_SubmitRequest struct {
	// submit_request is a relay of a transaction.
	SubmitRequest *SubmitRequest `protobuf:"bytes,2,opt,name=submit_request,json=submitRequest,proto3,oneof"`
}

type StepResponse 

type StepResponse struct {

	// Types that are assignable to Payload:
	//	*StepResponse_SubmitRes
	Payload isStepResponse_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

StepResponse is a message received from a cluster member.

func (*StepResponse) Descriptor deprecated 

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

Deprecated: Use StepResponse.ProtoReflect.Descriptor instead.

func (*StepResponse) GetPayload 

func (m *StepResponse) GetPayload() isStepResponse_Payload

func (*StepResponse) GetSubmitRes 

func (x *StepResponse) GetSubmitRes() *SubmitResponse

func (*StepResponse) ProtoMessage 

func (*StepResponse) ProtoMessage()

func (*StepResponse) ProtoReflect 

func (x *StepResponse) ProtoReflect() protoreflect.Message

func (*StepResponse) Reset 

func (x *StepResponse) Reset()

func (*StepResponse) String 

func (x *StepResponse) String() string

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"`
	// 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,proto3" json:"last_validation_seq,omitempty"`
	// content is the fabric transaction
	// that is forwarded to the cluster member.
	Payload *common.Envelope `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

SubmitRequest wraps a transaction to be sent for ordering.

func (*SubmitRequest) Descriptor deprecated 

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

Deprecated: Use SubmitRequest.ProtoReflect.Descriptor instead.

func (*SubmitRequest) GetChannel 

func (x *SubmitRequest) GetChannel() string

func (*SubmitRequest) GetLastValidationSeq 

func (x *SubmitRequest) GetLastValidationSeq() uint64

func (*SubmitRequest) GetPayload 

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

func (*SubmitRequest) ProtoMessage 

func (*SubmitRequest) ProtoMessage()

func (*SubmitRequest) ProtoReflect 

func (x *SubmitRequest) ProtoReflect() protoreflect.Message

func (*SubmitRequest) Reset 

func (x *SubmitRequest) Reset()

func (*SubmitRequest) String 

func (x *SubmitRequest) String() string

type SubmitResponse 

type SubmitResponse struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// Status code, which may be used to programatically respond to success/failure.
	Status common.Status `protobuf:"varint,2,opt,name=status,proto3,enum=common.Status" json:"status,omitempty"`
	// Info string which may contain additional information about the returned status.
	Info string `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

SubmitResponse returns a success or failure status to the sender.

func (*SubmitResponse) Descriptor deprecated 

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

Deprecated: Use SubmitResponse.ProtoReflect.Descriptor instead.

func (*SubmitResponse) GetChannel 

func (x *SubmitResponse) GetChannel() string

func (*SubmitResponse) GetInfo 

func (x *SubmitResponse) GetInfo() string

func (*SubmitResponse) GetStatus 

func (x *SubmitResponse) GetStatus() common.Status

func (*SubmitResponse) ProtoMessage 

func (*SubmitResponse) ProtoMessage()

func (*SubmitResponse) ProtoReflect 

func (x *SubmitResponse) ProtoReflect() protoreflect.Message

func (*SubmitResponse) Reset 

func (x *SubmitResponse) Reset()

func (*SubmitResponse) String 

func (x *SubmitResponse) String() string

type UnimplementedAtomicBroadcastServer 

type UnimplementedAtomicBroadcastServer struct {
}

UnimplementedAtomicBroadcastServer must be embedded to have forward compatible implementations.

func (UnimplementedAtomicBroadcastServer) Broadcast 

func (UnimplementedAtomicBroadcastServer) Broadcast(AtomicBroadcast_BroadcastServer) error

func (UnimplementedAtomicBroadcastServer) Deliver 

func (UnimplementedAtomicBroadcastServer) Deliver(AtomicBroadcast_DeliverServer) error

type UnimplementedClusterServer 

type UnimplementedClusterServer struct {
}

UnimplementedClusterServer must be embedded to have forward compatible implementations.

func (UnimplementedClusterServer) Step 

func (UnimplementedClusterServer) Step(Cluster_StepServer) error

type UnsafeAtomicBroadcastServer 

type UnsafeAtomicBroadcastServer interface {
	// contains filtered or unexported methods
}

UnsafeAtomicBroadcastServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AtomicBroadcastServer will result in compilation errors.

type UnsafeClusterServer 

type UnsafeClusterServer interface {
	// contains filtered or unexported methods
}

UnsafeClusterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClusterServer will result in compilation errors.

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.