orderer

package
v1.4.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Dec 10, 2018 License: Apache-2.0 Imports: 8 Imported by: 0

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 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,
}

Functions ¶

func RegisterAtomicBroadcastServer ¶ 

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

func RegisterClusterServer ¶ added in v1.3.0 

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 ¶ added in v1.3.0 

func (m *BatchSize) XXX_DiscardUnknown()

func (*BatchSize) XXX_Marshal ¶ added in v1.3.0 

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

func (*BatchSize) XXX_Merge ¶ added in v1.3.0 

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

func (*BatchSize) XXX_Size ¶ added in v1.3.0 

func (m *BatchSize) XXX_Size() int

func (*BatchSize) XXX_Unmarshal ¶ added in v1.3.0 

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 ¶ added in v1.3.0 

func (m *BatchTimeout) XXX_DiscardUnknown()

func (*BatchTimeout) XXX_Marshal ¶ added in v1.3.0 

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

func (*BatchTimeout) XXX_Merge ¶ added in v1.3.0 

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

func (*BatchTimeout) XXX_Size ¶ added in v1.3.0 

func (m *BatchTimeout) XXX_Size() int

func (*BatchTimeout) XXX_Unmarshal ¶ added in v1.3.0 

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 ¶ added in v1.1.0 

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 ¶ added in v1.3.0 

func (m *BroadcastResponse) XXX_DiscardUnknown()

func (*BroadcastResponse) XXX_Marshal ¶ added in v1.3.0 

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

func (*BroadcastResponse) XXX_Merge ¶ added in v1.3.0 

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

func (*BroadcastResponse) XXX_Size ¶ added in v1.3.0 

func (m *BroadcastResponse) XXX_Size() int

func (*BroadcastResponse) XXX_Unmarshal ¶ added in v1.3.0 

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 ¶ added in v1.3.0 

func (m *ChannelRestrictions) XXX_DiscardUnknown()

func (*ChannelRestrictions) XXX_Marshal ¶ added in v1.3.0 

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

func (*ChannelRestrictions) XXX_Merge ¶ added in v1.3.0 

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

func (*ChannelRestrictions) XXX_Size ¶ added in v1.3.0 

func (m *ChannelRestrictions) XXX_Size() int

func (*ChannelRestrictions) XXX_Unmarshal ¶ added in v1.3.0 

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

type ClusterClient ¶ added in v1.3.0 

type ClusterClient interface {
	// Submit submits transactions to a cluster member
	Submit(ctx context.Context, opts ...grpc.CallOption) (Cluster_SubmitClient, error)
	// Step passes an implementation-specific message to another cluster member.
	Step(ctx context.Context, in *StepRequest, opts ...grpc.CallOption) (*StepResponse, 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 ¶ added in v1.3.0 

func NewClusterClient(cc *grpc.ClientConn) ClusterClient

type ClusterServer ¶ added in v1.3.0 

type ClusterServer interface {
	// Submit submits transactions to a cluster member
	Submit(Cluster_SubmitServer) error
	// Step passes an implementation-specific message to another cluster member.
	Step(context.Context, *StepRequest) (*StepResponse, error)
}

ClusterServer is the server API for Cluster service.

type Cluster_SubmitClient ¶ added in v1.3.0 

type Cluster_SubmitClient interface {
	Send(*SubmitRequest) error
	Recv() (*SubmitResponse, error)
	grpc.ClientStream
}

type Cluster_SubmitServer ¶ added in v1.3.0 

type Cluster_SubmitServer interface {
	Send(*SubmitResponse) error
	Recv() (*SubmitRequest, error)
	grpc.ServerStream
}

type ConsensusType ¶ 

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

func (*ConsensusType) Descriptor ¶ 

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

func (*ConsensusType) GetMetadata ¶ added in v1.3.0 

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

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 ¶ added in v1.3.0 

func (ct *ConsensusType) VariablyOpaqueFieldProto(name string) (proto.Message, error)

func (*ConsensusType) VariablyOpaqueFields ¶ added in v1.3.0 

func (ct *ConsensusType) VariablyOpaqueFields() []string

func (*ConsensusType) XXX_DiscardUnknown ¶ added in v1.3.0 

func (m *ConsensusType) XXX_DiscardUnknown()

func (*ConsensusType) XXX_Marshal ¶ added in v1.3.0 

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

func (*ConsensusType) XXX_Merge ¶ added in v1.3.0 

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

func (*ConsensusType) XXX_Size ¶ added in v1.3.0 

func (m *ConsensusType) XXX_Size() int

func (*ConsensusType) XXX_Unmarshal ¶ added in v1.3.0 

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

type ConsensusTypeMetadataFactory ¶ added in v1.3.0 

type ConsensusTypeMetadataFactory interface {
	NewMessage() proto.Message
}

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 ¶ added in v1.3.0 

func (m *DeliverResponse) XXX_DiscardUnknown()

func (*DeliverResponse) XXX_Marshal ¶ added in v1.3.0 

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

func (*DeliverResponse) XXX_Merge ¶ added in v1.3.0 

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 ¶ added in v1.3.0 

func (m *DeliverResponse) XXX_Size() int

func (*DeliverResponse) XXX_Unmarshal ¶ added in v1.3.0 

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 ¶ added in v1.3.0 

func (m *KafkaBrokers) XXX_DiscardUnknown()

func (*KafkaBrokers) XXX_Marshal ¶ added in v1.3.0 

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

func (*KafkaBrokers) XXX_Merge ¶ added in v1.3.0 

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

func (*KafkaBrokers) XXX_Size ¶ added in v1.3.0 

func (m *KafkaBrokers) XXX_Size() int

func (*KafkaBrokers) XXX_Unmarshal ¶ added in v1.3.0 

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 ¶ added in v1.3.0 

func (m *KafkaMessage) XXX_DiscardUnknown()

func (*KafkaMessage) XXX_Marshal ¶ added in v1.3.0 

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

func (*KafkaMessage) XXX_Merge ¶ added in v1.3.0 

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 ¶ added in v1.3.0 

func (m *KafkaMessage) XXX_Size() int

func (*KafkaMessage) XXX_Unmarshal ¶ added in v1.3.0 

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 ¶ added in v1.3.0 

func (m *KafkaMessageConnect) XXX_DiscardUnknown()

func (*KafkaMessageConnect) XXX_Marshal ¶ added in v1.3.0 

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

func (*KafkaMessageConnect) XXX_Merge ¶ added in v1.3.0 

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

func (*KafkaMessageConnect) XXX_Size ¶ added in v1.3.0 

func (m *KafkaMessageConnect) XXX_Size() int

func (*KafkaMessageConnect) XXX_Unmarshal ¶ added in v1.3.0 

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 ¶ added in v1.1.0 

func (m *KafkaMessageRegular) GetClass() KafkaMessageRegular_Class

func (*KafkaMessageRegular) GetConfigSeq ¶ added in v1.1.0 

func (m *KafkaMessageRegular) GetConfigSeq() uint64

func (*KafkaMessageRegular) GetOriginalOffset ¶ added in v1.1.0 

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 ¶ added in v1.3.0 

func (m *KafkaMessageRegular) XXX_DiscardUnknown()

func (*KafkaMessageRegular) XXX_Marshal ¶ added in v1.3.0 

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

func (*KafkaMessageRegular) XXX_Merge ¶ added in v1.3.0 

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

func (*KafkaMessageRegular) XXX_Size ¶ added in v1.3.0 

func (m *KafkaMessageRegular) XXX_Size() int

func (*KafkaMessageRegular) XXX_Unmarshal ¶ added in v1.3.0 

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

type KafkaMessageRegular_Class ¶ added in v1.1.0 

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

func (KafkaMessageRegular_Class) EnumDescriptor ¶ added in v1.1.0 

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

func (KafkaMessageRegular_Class) String ¶ added in v1.1.0 

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 ¶ added in v1.3.0 

func (m *KafkaMessageTimeToCut) XXX_DiscardUnknown()

func (*KafkaMessageTimeToCut) XXX_Marshal ¶ added in v1.3.0 

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

func (*KafkaMessageTimeToCut) XXX_Merge ¶ added in v1.3.0 

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

func (*KafkaMessageTimeToCut) XXX_Size ¶ added in v1.3.0 

func (m *KafkaMessageTimeToCut) XXX_Size() int

func (*KafkaMessageTimeToCut) XXX_Unmarshal ¶ added in v1.3.0 

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 ¶ added in v1.1.0 

func (m *KafkaMetadata) GetLastOriginalOffsetProcessed() int64

func (*KafkaMetadata) GetLastResubmittedConfigOffset ¶ added in v1.1.0 

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 ¶ added in v1.3.0 

func (m *KafkaMetadata) XXX_DiscardUnknown()

func (*KafkaMetadata) XXX_Marshal ¶ added in v1.3.0 

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

func (*KafkaMetadata) XXX_Merge ¶ added in v1.3.0 

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

func (*KafkaMetadata) XXX_Size ¶ added in v1.3.0 

func (m *KafkaMetadata) XXX_Size() int

func (*KafkaMetadata) XXX_Unmarshal ¶ added in v1.3.0 

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"`
	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. 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

func (*SeekInfo) Descriptor ¶ 

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

func (*SeekInfo) GetBehavior ¶ 

func (m *SeekInfo) GetBehavior() SeekInfo_SeekBehavior

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 ¶ added in v1.3.0 

func (m *SeekInfo) XXX_DiscardUnknown()

func (*SeekInfo) XXX_Marshal ¶ added in v1.3.0 

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

func (*SeekInfo) XXX_Merge ¶ added in v1.3.0 

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

func (*SeekInfo) XXX_Size ¶ added in v1.3.0 

func (m *SeekInfo) XXX_Size() int

func (*SeekInfo) XXX_Unmarshal ¶ added in v1.3.0 

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

type SeekInfo_SeekBehavior ¶ 

type SeekInfo_SeekBehavior int32
const (
	SeekInfo_BLOCK_UNTIL_READY SeekInfo_SeekBehavior = 0
	SeekInfo_FAIL_IF_NOT_READY SeekInfo_SeekBehavior = 1
)

func (SeekInfo_SeekBehavior) EnumDescriptor ¶ 

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

func (SeekInfo_SeekBehavior) String ¶ 

func (x SeekInfo_SeekBehavior) String() string

type 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 ¶ added in v1.3.0 

func (m *SeekNewest) XXX_DiscardUnknown()

func (*SeekNewest) XXX_Marshal ¶ added in v1.3.0 

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

func (*SeekNewest) XXX_Merge ¶ added in v1.3.0 

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

func (*SeekNewest) XXX_Size ¶ added in v1.3.0 

func (m *SeekNewest) XXX_Size() int

func (*SeekNewest) XXX_Unmarshal ¶ added in v1.3.0 

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 ¶ added in v1.3.0 

func (m *SeekOldest) XXX_DiscardUnknown()

func (*SeekOldest) XXX_Marshal ¶ added in v1.3.0 

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

func (*SeekOldest) XXX_Merge ¶ added in v1.3.0 

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

func (*SeekOldest) XXX_Size ¶ added in v1.3.0 

func (m *SeekOldest) XXX_Size() int

func (*SeekOldest) XXX_Unmarshal ¶ added in v1.3.0 

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 ¶ added in v1.3.0 

func (m *SeekPosition) XXX_DiscardUnknown()

func (*SeekPosition) XXX_Marshal ¶ added in v1.3.0 

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

func (*SeekPosition) XXX_Merge ¶ added in v1.3.0 

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 ¶ added in v1.3.0 

func (m *SeekPosition) XXX_Size() int

func (*SeekPosition) XXX_Unmarshal ¶ added in v1.3.0 

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 ¶ added in v1.3.0 

func (m *SeekSpecified) XXX_DiscardUnknown()

func (*SeekSpecified) XXX_Marshal ¶ added in v1.3.0 

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

func (*SeekSpecified) XXX_Merge ¶ added in v1.3.0 

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

func (*SeekSpecified) XXX_Size ¶ added in v1.3.0 

func (m *SeekSpecified) XXX_Size() int

func (*SeekSpecified) XXX_Unmarshal ¶ added in v1.3.0 

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

type StepRequest ¶ added in v1.3.0 

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

StepRequest wraps a consensus implementation specific message that is sent to a cluster member

func (*StepRequest) Descriptor ¶ added in v1.3.0 

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

func (*StepRequest) GetChannel ¶ added in v1.3.0 

func (m *StepRequest) GetChannel() string

func (*StepRequest) GetPayload ¶ added in v1.3.0 

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

func (*StepRequest) ProtoMessage ¶ added in v1.3.0 

func (*StepRequest) ProtoMessage()

func (*StepRequest) Reset ¶ added in v1.3.0 

func (m *StepRequest) Reset()

func (*StepRequest) String ¶ added in v1.3.0 

func (m *StepRequest) String() string

func (*StepRequest) XXX_DiscardUnknown ¶ added in v1.3.0 

func (m *StepRequest) XXX_DiscardUnknown()

func (*StepRequest) XXX_Marshal ¶ added in v1.3.0 

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

func (*StepRequest) XXX_Merge ¶ added in v1.3.0 

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

func (*StepRequest) XXX_Size ¶ added in v1.3.0 

func (m *StepRequest) XXX_Size() int

func (*StepRequest) XXX_Unmarshal ¶ added in v1.3.0 

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

type StepResponse ¶ added in v1.3.0 

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

StepResponse wraps a consensus implementation specific message that is received from a cluster member as a response to a StepRequest

func (*StepResponse) Descriptor ¶ added in v1.3.0 

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

func (*StepResponse) GetPayload ¶ added in v1.3.0 

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

func (*StepResponse) ProtoMessage ¶ added in v1.3.0 

func (*StepResponse) ProtoMessage()

func (*StepResponse) Reset ¶ added in v1.3.0 

func (m *StepResponse) Reset()

func (*StepResponse) String ¶ added in v1.3.0 

func (m *StepResponse) String() string

func (*StepResponse) XXX_DiscardUnknown ¶ added in v1.3.0 

func (m *StepResponse) XXX_DiscardUnknown()

func (*StepResponse) XXX_Marshal ¶ added in v1.3.0 

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

func (*StepResponse) XXX_Merge ¶ added in v1.3.0 

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

func (*StepResponse) XXX_Size ¶ added in v1.3.0 

func (m *StepResponse) XXX_Size() int

func (*StepResponse) XXX_Unmarshal ¶ added in v1.3.0 

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

type SubmitRequest ¶ added in v1.3.0 

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
	Content              *common.Envelope `protobuf:"bytes,3,opt,name=content,proto3" json:"content,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 ¶ added in v1.3.0 

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

func (*SubmitRequest) GetChannel ¶ added in v1.3.0 

func (m *SubmitRequest) GetChannel() string

func (*SubmitRequest) GetContent ¶ added in v1.3.0 

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

func (*SubmitRequest) GetLastValidationSeq ¶ added in v1.3.0 

func (m *SubmitRequest) GetLastValidationSeq() uint64

func (*SubmitRequest) ProtoMessage ¶ added in v1.3.0 

func (*SubmitRequest) ProtoMessage()

func (*SubmitRequest) Reset ¶ added in v1.3.0 

func (m *SubmitRequest) Reset()

func (*SubmitRequest) String ¶ added in v1.3.0 

func (m *SubmitRequest) String() string

func (*SubmitRequest) XXX_DiscardUnknown ¶ added in v1.3.0 

func (m *SubmitRequest) XXX_DiscardUnknown()

func (*SubmitRequest) XXX_Marshal ¶ added in v1.3.0 

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

func (*SubmitRequest) XXX_Merge ¶ added in v1.3.0 

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

func (*SubmitRequest) XXX_Size ¶ added in v1.3.0 

func (m *SubmitRequest) XXX_Size() int

func (*SubmitRequest) XXX_Unmarshal ¶ added in v1.3.0 

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

type SubmitResponse ¶ added in v1.3.0 

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

SubmitResponse returns a success or failure status to the sender

func (*SubmitResponse) Descriptor ¶ added in v1.3.0 

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

func (*SubmitResponse) GetInfo ¶ added in v1.3.0 

func (m *SubmitResponse) GetInfo() string

func (*SubmitResponse) GetStatus ¶ added in v1.3.0 

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

func (*SubmitResponse) ProtoMessage ¶ added in v1.3.0 

func (*SubmitResponse) ProtoMessage()

func (*SubmitResponse) Reset ¶ added in v1.3.0 

func (m *SubmitResponse) Reset()

func (*SubmitResponse) String ¶ added in v1.3.0 

func (m *SubmitResponse) String() string

func (*SubmitResponse) XXX_DiscardUnknown ¶ added in v1.3.0 

func (m *SubmitResponse) XXX_DiscardUnknown()

func (*SubmitResponse) XXX_Marshal ¶ added in v1.3.0 

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

func (*SubmitResponse) XXX_Merge ¶ added in v1.3.0 

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

func (*SubmitResponse) XXX_Size ¶ added in v1.3.0 

func (m *SubmitResponse) XXX_Size() int

func (*SubmitResponse) XXX_Unmarshal ¶ added in v1.3.0 

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

Source Files ¶

View all Source files

Directories ¶

Path Synopsis

Jump to

Keyboard shortcuts

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