Documentation

Index

Constants

This section is empty.

Variables

View Source
var ConsensusTypeMetadataMap = map[string]ConsensusTypeMetadataFactory{}

    ConsensuTypeMetadataMap should have consensus implementations register their metadata message factories

    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 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

      func NewAtomicBroadcastClient

      func NewAtomicBroadcastClient(cc *grpc.ClientConn) AtomicBroadcastClient

      type AtomicBroadcastServer

      type AtomicBroadcastServer interface {
      	// broadcast receives a reply of Acknowledgement for each common.Envelope in order, indicating success or type of failure
      	Broadcast(AtomicBroadcast_BroadcastServer) error
      	// deliver first requires an Envelope of type DELIVER_SEEK_INFO with Payload data as a mashaled SeekInfo message, then a stream of block replies is received.
      	Deliver(AtomicBroadcast_DeliverServer) error
      }

        AtomicBroadcastServer is the server API for AtomicBroadcast service.

        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"`
        	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 (dst *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 {
        	// Any duration string parseable by ParseDuration():
        	// https://golang.org/pkg/time/#ParseDuration
        	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 (dst *BatchTimeout) XXX_Merge(src proto.Message)

        func (*BatchTimeout) XXX_Size

        func (m *BatchTimeout) XXX_Size() int

        func (*BatchTimeout) XXX_Unmarshal

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

        type BroadcastResponse

        type BroadcastResponse struct {
        	// Status code, which may be used to programatically respond to success/failure
        	Status common.Status `protobuf:"varint,1,opt,name=status,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"`
        	XXX_NoUnkeyedLiteral struct{} `json:"-"`
        	XXX_unrecognized     []byte   `json:"-"`
        	XXX_sizecache        int32    `json:"-"`
        }

        func (*BroadcastResponse) Descriptor

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

        func (*BroadcastResponse) GetInfo

        func (m *BroadcastResponse) GetInfo() string

        func (*BroadcastResponse) GetStatus

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

        func (*BroadcastResponse) ProtoMessage

        func (*BroadcastResponse) ProtoMessage()

        func (*BroadcastResponse) Reset

        func (m *BroadcastResponse) Reset()

        func (*BroadcastResponse) String

        func (m *BroadcastResponse) String() string

        func (*BroadcastResponse) XXX_DiscardUnknown

        func (m *BroadcastResponse) XXX_DiscardUnknown()

        func (*BroadcastResponse) XXX_Marshal

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

        func (*BroadcastResponse) XXX_Merge

        func (dst *BroadcastResponse) XXX_Merge(src proto.Message)

        func (*BroadcastResponse) XXX_Size

        func (m *BroadcastResponse) XXX_Size() int

        func (*BroadcastResponse) XXX_Unmarshal

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

        type ChannelRestrictions

        type ChannelRestrictions struct {
        	MaxCount             uint64   `protobuf:"varint,1,opt,name=max_count,json=maxCount,proto3" json:"max_count,omitempty"`
        	XXX_NoUnkeyedLiteral struct{} `json:"-"`
        	XXX_unrecognized     []byte   `json:"-"`
        	XXX_sizecache        int32    `json:"-"`
        }

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

          func (*ChannelRestrictions) Descriptor

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

          func (*ChannelRestrictions) GetMaxCount

          func (m *ChannelRestrictions) GetMaxCount() uint64

          func (*ChannelRestrictions) ProtoMessage

          func (*ChannelRestrictions) ProtoMessage()

          func (*ChannelRestrictions) Reset

          func (m *ChannelRestrictions) Reset()

          func (*ChannelRestrictions) String

          func (m *ChannelRestrictions) String() string

          func (*ChannelRestrictions) XXX_DiscardUnknown

          func (m *ChannelRestrictions) XXX_DiscardUnknown()

          func (*ChannelRestrictions) XXX_Marshal

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

          func (*ChannelRestrictions) XXX_Merge

          func (dst *ChannelRestrictions) XXX_Merge(src proto.Message)

          func (*ChannelRestrictions) XXX_Size

          func (m *ChannelRestrictions) XXX_Size() int

          func (*ChannelRestrictions) XXX_Unmarshal

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

          type ClusterClient

          type ClusterClient interface {
          	// 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

            func NewClusterClient

            func NewClusterClient(cc *grpc.ClientConn) ClusterClient

            type ClusterServer

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

              ClusterServer is the server API for Cluster service.

              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"`
              	XXX_NoUnkeyedLiteral struct{} `json:"-"`
              	XXX_unrecognized     []byte   `json:"-"`
              	XXX_sizecache        int32    `json:"-"`
              }

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

                func (*ConsensusRequest) Descriptor

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

                func (*ConsensusRequest) GetChannel

                func (m *ConsensusRequest) GetChannel() string

                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 (dst *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 {
                	// 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"`
                	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 (dst *ConsensusType) XXX_Merge(src proto.Message)

                func (*ConsensusType) XXX_Size

                func (m *ConsensusType) XXX_Size() int

                func (*ConsensusType) XXX_Unmarshal

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

                type ConsensusTypeMetadataFactory

                type ConsensusTypeMetadataFactory interface {
                	NewMessage() proto.Message
                }

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

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

                  func (ConsensusType_State) String

                  func (x ConsensusType_State) String() string

                  type DeliverResponse

                  type DeliverResponse struct {
                  	// Types that are valid to be assigned to Type:
                  	//	*DeliverResponse_Status
                  	//	*DeliverResponse_Block
                  	Type                 isDeliverResponse_Type `protobuf_oneof:"Type"`
                  	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
                  	XXX_unrecognized     []byte                 `json:"-"`
                  	XXX_sizecache        int32                  `json:"-"`
                  }

                  func (*DeliverResponse) Descriptor

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

                  func (*DeliverResponse) GetBlock

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

                  func (*DeliverResponse) GetStatus

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

                  func (*DeliverResponse) GetType

                  func (m *DeliverResponse) GetType() isDeliverResponse_Type

                  func (*DeliverResponse) ProtoMessage

                  func (*DeliverResponse) ProtoMessage()

                  func (*DeliverResponse) Reset

                  func (m *DeliverResponse) Reset()

                  func (*DeliverResponse) String

                  func (m *DeliverResponse) String() string

                  func (*DeliverResponse) XXX_DiscardUnknown

                  func (m *DeliverResponse) XXX_DiscardUnknown()

                  func (*DeliverResponse) XXX_Marshal

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

                  func (*DeliverResponse) XXX_Merge

                  func (dst *DeliverResponse) XXX_Merge(src proto.Message)

                  func (*DeliverResponse) XXX_OneofFuncs

                  func (*DeliverResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

                    XXX_OneofFuncs is for the internal use of the proto package.

                    func (*DeliverResponse) XXX_Size

                    func (m *DeliverResponse) XXX_Size() int

                    func (*DeliverResponse) XXX_Unmarshal

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

                    type DeliverResponse_Block

                    type DeliverResponse_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 {
                    	// 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"`
                    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                    	XXX_unrecognized     []byte   `json:"-"`
                    	XXX_sizecache        int32    `json:"-"`
                    }

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

                      func (*KafkaBrokers) Descriptor

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

                      func (*KafkaBrokers) GetBrokers

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

                      func (*KafkaBrokers) ProtoMessage

                      func (*KafkaBrokers) ProtoMessage()

                      func (*KafkaBrokers) Reset

                      func (m *KafkaBrokers) Reset()

                      func (*KafkaBrokers) String

                      func (m *KafkaBrokers) String() string

                      func (*KafkaBrokers) XXX_DiscardUnknown

                      func (m *KafkaBrokers) XXX_DiscardUnknown()

                      func (*KafkaBrokers) XXX_Marshal

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

                      func (*KafkaBrokers) XXX_Merge

                      func (dst *KafkaBrokers) XXX_Merge(src proto.Message)

                      func (*KafkaBrokers) XXX_Size

                      func (m *KafkaBrokers) XXX_Size() int

                      func (*KafkaBrokers) XXX_Unmarshal

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

                      type KafkaMessage

                      type KafkaMessage struct {
                      	// Types that are valid to be assigned to Type:
                      	//	*KafkaMessage_Regular
                      	//	*KafkaMessage_TimeToCut
                      	//	*KafkaMessage_Connect
                      	Type                 isKafkaMessage_Type `protobuf_oneof:"Type"`
                      	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
                      	XXX_unrecognized     []byte              `json:"-"`
                      	XXX_sizecache        int32               `json:"-"`
                      }

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

                        func (*KafkaMessage) Descriptor

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

                        func (*KafkaMessage) GetConnect

                        func (m *KafkaMessage) GetConnect() *KafkaMessageConnect

                        func (*KafkaMessage) GetRegular

                        func (m *KafkaMessage) GetRegular() *KafkaMessageRegular

                        func (*KafkaMessage) GetTimeToCut

                        func (m *KafkaMessage) GetTimeToCut() *KafkaMessageTimeToCut

                        func (*KafkaMessage) GetType

                        func (m *KafkaMessage) GetType() isKafkaMessage_Type

                        func (*KafkaMessage) ProtoMessage

                        func (*KafkaMessage) ProtoMessage()

                        func (*KafkaMessage) Reset

                        func (m *KafkaMessage) Reset()

                        func (*KafkaMessage) String

                        func (m *KafkaMessage) String() string

                        func (*KafkaMessage) XXX_DiscardUnknown

                        func (m *KafkaMessage) XXX_DiscardUnknown()

                        func (*KafkaMessage) XXX_Marshal

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

                        func (*KafkaMessage) XXX_Merge

                        func (dst *KafkaMessage) XXX_Merge(src proto.Message)

                        func (*KafkaMessage) XXX_OneofFuncs

                        func (*KafkaMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

                          XXX_OneofFuncs is for the internal use of the proto package.

                          func (*KafkaMessage) XXX_Size

                          func (m *KafkaMessage) XXX_Size() int

                          func (*KafkaMessage) XXX_Unmarshal

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

                          type KafkaMessageConnect

                          type KafkaMessageConnect struct {
                          	Payload              []byte   `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
                          	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                          	XXX_unrecognized     []byte   `json:"-"`
                          	XXX_sizecache        int32    `json:"-"`
                          }

                            KafkaMessageConnect is posted by an orderer upon booting up. It is used to prevent the panic that would be caused if we were to consume an empty partition. It is ignored by all orderers when processing the partition.

                            func (*KafkaMessageConnect) Descriptor

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

                            func (*KafkaMessageConnect) GetPayload

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

                            func (*KafkaMessageConnect) ProtoMessage

                            func (*KafkaMessageConnect) ProtoMessage()

                            func (*KafkaMessageConnect) Reset

                            func (m *KafkaMessageConnect) Reset()

                            func (*KafkaMessageConnect) String

                            func (m *KafkaMessageConnect) String() string

                            func (*KafkaMessageConnect) XXX_DiscardUnknown

                            func (m *KafkaMessageConnect) XXX_DiscardUnknown()

                            func (*KafkaMessageConnect) XXX_Marshal

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

                            func (*KafkaMessageConnect) XXX_Merge

                            func (dst *KafkaMessageConnect) XXX_Merge(src proto.Message)

                            func (*KafkaMessageConnect) XXX_Size

                            func (m *KafkaMessageConnect) XXX_Size() int

                            func (*KafkaMessageConnect) XXX_Unmarshal

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

                            type KafkaMessageRegular

                            type KafkaMessageRegular struct {
                            	Payload              []byte                    `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
                            	ConfigSeq            uint64                    `protobuf:"varint,2,opt,name=config_seq,json=configSeq,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:"-"`
                            }

                              KafkaMessageRegular wraps a marshalled envelope.

                              func (*KafkaMessageRegular) Descriptor

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

                              func (*KafkaMessageRegular) GetClass

                              func (*KafkaMessageRegular) GetConfigSeq

                              func (m *KafkaMessageRegular) GetConfigSeq() uint64

                              func (*KafkaMessageRegular) GetOriginalOffset

                              func (m *KafkaMessageRegular) GetOriginalOffset() int64

                              func (*KafkaMessageRegular) GetPayload

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

                              func (*KafkaMessageRegular) ProtoMessage

                              func (*KafkaMessageRegular) ProtoMessage()

                              func (*KafkaMessageRegular) Reset

                              func (m *KafkaMessageRegular) Reset()

                              func (*KafkaMessageRegular) String

                              func (m *KafkaMessageRegular) String() string

                              func (*KafkaMessageRegular) XXX_DiscardUnknown

                              func (m *KafkaMessageRegular) XXX_DiscardUnknown()

                              func (*KafkaMessageRegular) XXX_Marshal

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

                              func (*KafkaMessageRegular) XXX_Merge

                              func (dst *KafkaMessageRegular) XXX_Merge(src proto.Message)

                              func (*KafkaMessageRegular) XXX_Size

                              func (m *KafkaMessageRegular) XXX_Size() int

                              func (*KafkaMessageRegular) XXX_Unmarshal

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

                              type KafkaMessageRegular_Class

                              type KafkaMessageRegular_Class int32
                              const (
                              	KafkaMessageRegular_UNKNOWN KafkaMessageRegular_Class = 0
                              	KafkaMessageRegular_NORMAL  KafkaMessageRegular_Class = 1
                              	KafkaMessageRegular_CONFIG  KafkaMessageRegular_Class = 2
                              )

                              func (KafkaMessageRegular_Class) EnumDescriptor

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

                              func (KafkaMessageRegular_Class) String

                              func (x KafkaMessageRegular_Class) String() string

                              type KafkaMessageTimeToCut

                              type KafkaMessageTimeToCut struct {
                              	BlockNumber          uint64   `protobuf:"varint,1,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
                              	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                              	XXX_unrecognized     []byte   `json:"-"`
                              	XXX_sizecache        int32    `json:"-"`
                              }

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

                                func (*KafkaMessageTimeToCut) Descriptor

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

                                func (*KafkaMessageTimeToCut) GetBlockNumber

                                func (m *KafkaMessageTimeToCut) GetBlockNumber() uint64

                                func (*KafkaMessageTimeToCut) ProtoMessage

                                func (*KafkaMessageTimeToCut) ProtoMessage()

                                func (*KafkaMessageTimeToCut) Reset

                                func (m *KafkaMessageTimeToCut) Reset()

                                func (*KafkaMessageTimeToCut) String

                                func (m *KafkaMessageTimeToCut) String() string

                                func (*KafkaMessageTimeToCut) XXX_DiscardUnknown

                                func (m *KafkaMessageTimeToCut) XXX_DiscardUnknown()

                                func (*KafkaMessageTimeToCut) XXX_Marshal

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

                                func (*KafkaMessageTimeToCut) XXX_Merge

                                func (dst *KafkaMessageTimeToCut) XXX_Merge(src proto.Message)

                                func (*KafkaMessageTimeToCut) XXX_Size

                                func (m *KafkaMessageTimeToCut) XXX_Size() int

                                func (*KafkaMessageTimeToCut) XXX_Unmarshal

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

                                type KafkaMessage_Connect

                                type KafkaMessage_Connect struct {
                                	Connect *KafkaMessageConnect `protobuf:"bytes,3,opt,name=connect,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 */
                                	XXX_NoUnkeyedLiteral        struct{} `json:"-"`
                                	XXX_unrecognized            []byte   `json:"-"`
                                	XXX_sizecache               int32    `json:"-"`
                                }

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

                                  func (*KafkaMetadata) Descriptor

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

                                  func (*KafkaMetadata) GetLastOffsetPersisted

                                  func (m *KafkaMetadata) GetLastOffsetPersisted() int64

                                  func (*KafkaMetadata) GetLastOriginalOffsetProcessed

                                  func (m *KafkaMetadata) GetLastOriginalOffsetProcessed() int64

                                  func (*KafkaMetadata) GetLastResubmittedConfigOffset

                                  func (m *KafkaMetadata) GetLastResubmittedConfigOffset() int64

                                  func (*KafkaMetadata) ProtoMessage

                                  func (*KafkaMetadata) ProtoMessage()

                                  func (*KafkaMetadata) Reset

                                  func (m *KafkaMetadata) Reset()

                                  func (*KafkaMetadata) String

                                  func (m *KafkaMetadata) String() string

                                  func (*KafkaMetadata) XXX_DiscardUnknown

                                  func (m *KafkaMetadata) XXX_DiscardUnknown()

                                  func (*KafkaMetadata) XXX_Marshal

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

                                  func (*KafkaMetadata) XXX_Merge

                                  func (dst *KafkaMetadata) XXX_Merge(src proto.Message)

                                  func (*KafkaMetadata) XXX_Size

                                  func (m *KafkaMetadata) XXX_Size() int

                                  func (*KafkaMetadata) XXX_Unmarshal

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

                                  type SeekInfo

                                  type SeekInfo struct {
                                  	Start                *SeekPosition              `protobuf:"bytes,1,opt,name=start,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:"-"`
                                  }

                                    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

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

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

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

                                      func (SeekInfo_SeekBehavior) String

                                      func (x SeekInfo_SeekBehavior) String() string

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

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

                                        func (SeekInfo_SeekErrorResponse) String

                                        type SeekNewest

                                        type SeekNewest struct {
                                        	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                        	XXX_unrecognized     []byte   `json:"-"`
                                        	XXX_sizecache        int32    `json:"-"`
                                        }

                                        func (*SeekNewest) Descriptor

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

                                        func (*SeekNewest) ProtoMessage

                                        func (*SeekNewest) ProtoMessage()

                                        func (*SeekNewest) Reset

                                        func (m *SeekNewest) Reset()

                                        func (*SeekNewest) String

                                        func (m *SeekNewest) String() string

                                        func (*SeekNewest) XXX_DiscardUnknown

                                        func (m *SeekNewest) XXX_DiscardUnknown()

                                        func (*SeekNewest) XXX_Marshal

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

                                        func (*SeekNewest) XXX_Merge

                                        func (dst *SeekNewest) XXX_Merge(src proto.Message)

                                        func (*SeekNewest) XXX_Size

                                        func (m *SeekNewest) XXX_Size() int

                                        func (*SeekNewest) XXX_Unmarshal

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

                                        type SeekOldest

                                        type SeekOldest struct {
                                        	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                        	XXX_unrecognized     []byte   `json:"-"`
                                        	XXX_sizecache        int32    `json:"-"`
                                        }

                                        func (*SeekOldest) Descriptor

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

                                        func (*SeekOldest) ProtoMessage

                                        func (*SeekOldest) ProtoMessage()

                                        func (*SeekOldest) Reset

                                        func (m *SeekOldest) Reset()

                                        func (*SeekOldest) String

                                        func (m *SeekOldest) String() string

                                        func (*SeekOldest) XXX_DiscardUnknown

                                        func (m *SeekOldest) XXX_DiscardUnknown()

                                        func (*SeekOldest) XXX_Marshal

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

                                        func (*SeekOldest) XXX_Merge

                                        func (dst *SeekOldest) XXX_Merge(src proto.Message)

                                        func (*SeekOldest) XXX_Size

                                        func (m *SeekOldest) XXX_Size() int

                                        func (*SeekOldest) XXX_Unmarshal

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

                                        type SeekPosition

                                        type SeekPosition struct {
                                        	// Types that are valid to be assigned to Type:
                                        	//	*SeekPosition_Newest
                                        	//	*SeekPosition_Oldest
                                        	//	*SeekPosition_Specified
                                        	Type                 isSeekPosition_Type `protobuf_oneof:"Type"`
                                        	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
                                        	XXX_unrecognized     []byte              `json:"-"`
                                        	XXX_sizecache        int32               `json:"-"`
                                        }

                                        func (*SeekPosition) Descriptor

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

                                        func (*SeekPosition) GetNewest

                                        func (m *SeekPosition) GetNewest() *SeekNewest

                                        func (*SeekPosition) GetOldest

                                        func (m *SeekPosition) GetOldest() *SeekOldest

                                        func (*SeekPosition) GetSpecified

                                        func (m *SeekPosition) GetSpecified() *SeekSpecified

                                        func (*SeekPosition) GetType

                                        func (m *SeekPosition) GetType() isSeekPosition_Type

                                        func (*SeekPosition) ProtoMessage

                                        func (*SeekPosition) ProtoMessage()

                                        func (*SeekPosition) Reset

                                        func (m *SeekPosition) Reset()

                                        func (*SeekPosition) String

                                        func (m *SeekPosition) String() string

                                        func (*SeekPosition) XXX_DiscardUnknown

                                        func (m *SeekPosition) XXX_DiscardUnknown()

                                        func (*SeekPosition) XXX_Marshal

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

                                        func (*SeekPosition) XXX_Merge

                                        func (dst *SeekPosition) XXX_Merge(src proto.Message)

                                        func (*SeekPosition) XXX_OneofFuncs

                                        func (*SeekPosition) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

                                          XXX_OneofFuncs is for the internal use of the proto package.

                                          func (*SeekPosition) XXX_Size

                                          func (m *SeekPosition) XXX_Size() int

                                          func (*SeekPosition) XXX_Unmarshal

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

                                          type SeekPosition_Newest

                                          type SeekPosition_Newest struct {
                                          	Newest *SeekNewest `protobuf:"bytes,1,opt,name=newest,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 (dst *SeekSpecified) XXX_Merge(src proto.Message)

                                          func (*SeekSpecified) XXX_Size

                                          func (m *SeekSpecified) XXX_Size() int

                                          func (*SeekSpecified) XXX_Unmarshal

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

                                          type StepRequest

                                          type StepRequest struct {
                                          	// Types that are valid to be assigned to Payload:
                                          	//	*StepRequest_ConsensusRequest
                                          	//	*StepRequest_SubmitRequest
                                          	Payload              isStepRequest_Payload `protobuf_oneof:"payload"`
                                          	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
                                          	XXX_unrecognized     []byte                `json:"-"`
                                          	XXX_sizecache        int32                 `json:"-"`
                                          }

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

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

                                            func (*StepRequest) XXX_OneofFuncs

                                            func (*StepRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

                                              XXX_OneofFuncs is for the internal use of the proto package.

                                              func (*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 {
                                              	// Types that are valid to be assigned to Payload:
                                              	//	*StepResponse_SubmitRes
                                              	Payload              isStepResponse_Payload `protobuf_oneof:"payload"`
                                              	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
                                              	XXX_unrecognized     []byte                 `json:"-"`
                                              	XXX_sizecache        int32                  `json:"-"`
                                              }

                                                StepResponse is a message received from a cluster member.

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

                                                func (*StepResponse) XXX_OneofFuncs

                                                func (*StepResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

                                                  XXX_OneofFuncs is for the internal use of the proto package.

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

                                                    SubmitRequest wraps a transaction to be sent for ordering.

                                                    func (*SubmitRequest) Descriptor

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

                                                    func (*SubmitRequest) GetChannel

                                                    func (m *SubmitRequest) GetChannel() string

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

                                                    func (*SubmitRequest) XXX_Size

                                                    func (m *SubmitRequest) XXX_Size() int

                                                    func (*SubmitRequest) XXX_Unmarshal

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

                                                    type SubmitResponse

                                                    type SubmitResponse struct {
                                                    	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"`
                                                    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                    	XXX_unrecognized     []byte   `json:"-"`
                                                    	XXX_sizecache        int32    `json:"-"`
                                                    }

                                                      SubmitResponse returns a success or failure status to the sender.

                                                      func (*SubmitResponse) Descriptor

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

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

                                                      func (*SubmitResponse) XXX_Size

                                                      func (m *SubmitResponse) XXX_Size() int

                                                      func (*SubmitResponse) XXX_Unmarshal

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

                                                      Directories

                                                      Path Synopsis