fabric: github.com/hyperledger/fabric/protos/orderer Index | Files | Directories

package orderer

import "github.com/hyperledger/fabric/protos/orderer"

Index

Package Files

ab.pb.go cluster.pb.go configuration.go configuration.pb.go kafka.pb.go

Variables

var ConsensusTypeMetadataMap = map[string]ConsensusTypeMetadataFactory{}

ConsensuTypeMetadataMap should have consensus implementations register their metadata message factories

var ConsensusType_State_name = map[int32]string{
    0:  "STATE_NORMAL",
    1:  "STATE_MAINTENANCE",
}
var ConsensusType_State_value = map[string]int32{
    "STATE_NORMAL":      0,
    "STATE_MAINTENANCE": 1,
}
var KafkaMessageRegular_Class_name = map[int32]string{
    0:  "UNKNOWN",
    1:  "NORMAL",
    2:  "CONFIG",
}
var KafkaMessageRegular_Class_value = map[string]int32{
    "UNKNOWN": 0,
    "NORMAL":  1,
    "CONFIG":  2,
}
var SeekInfo_SeekBehavior_name = map[int32]string{
    0:  "BLOCK_UNTIL_READY",
    1:  "FAIL_IF_NOT_READY",
}
var SeekInfo_SeekBehavior_value = map[string]int32{
    "BLOCK_UNTIL_READY": 0,
    "FAIL_IF_NOT_READY": 1,
}
var SeekInfo_SeekErrorResponse_name = map[int32]string{
    0:  "STRICT",
    1:  "BEST_EFFORT",
}
var SeekInfo_SeekErrorResponse_value = map[string]int32{
    "STRICT":      0,
    "BEST_EFFORT": 1,
}

func RegisterAtomicBroadcastServer Uses

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

func RegisterClusterServer Uses

func RegisterClusterServer(s *grpc.Server, srv ClusterServer)

type AtomicBroadcastClient Uses

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 Uses

func NewAtomicBroadcastClient(cc *grpc.ClientConn) AtomicBroadcastClient

type AtomicBroadcastServer Uses

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 Uses

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

type AtomicBroadcast_BroadcastServer Uses

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

type AtomicBroadcast_DeliverClient Uses

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

type AtomicBroadcast_DeliverServer Uses

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

type BatchSize Uses

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 Uses

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

func (*BatchSize) GetAbsoluteMaxBytes Uses

func (m *BatchSize) GetAbsoluteMaxBytes() uint32

func (*BatchSize) GetMaxMessageCount Uses

func (m *BatchSize) GetMaxMessageCount() uint32

func (*BatchSize) GetPreferredMaxBytes Uses

func (m *BatchSize) GetPreferredMaxBytes() uint32

func (*BatchSize) ProtoMessage Uses

func (*BatchSize) ProtoMessage()

func (*BatchSize) Reset Uses

func (m *BatchSize) Reset()

func (*BatchSize) String Uses

func (m *BatchSize) String() string

func (*BatchSize) XXX_DiscardUnknown Uses

func (m *BatchSize) XXX_DiscardUnknown()

func (*BatchSize) XXX_Marshal Uses

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

func (*BatchSize) XXX_Merge Uses

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

func (*BatchSize) XXX_Size Uses

func (m *BatchSize) XXX_Size() int

func (*BatchSize) XXX_Unmarshal Uses

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

type BatchTimeout Uses

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 Uses

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

func (*BatchTimeout) GetTimeout Uses

func (m *BatchTimeout) GetTimeout() string

func (*BatchTimeout) ProtoMessage Uses

func (*BatchTimeout) ProtoMessage()

func (*BatchTimeout) Reset Uses

func (m *BatchTimeout) Reset()

func (*BatchTimeout) String Uses

func (m *BatchTimeout) String() string

func (*BatchTimeout) XXX_DiscardUnknown Uses

func (m *BatchTimeout) XXX_DiscardUnknown()

func (*BatchTimeout) XXX_Marshal Uses

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

func (*BatchTimeout) XXX_Merge Uses

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

func (*BatchTimeout) XXX_Size Uses

func (m *BatchTimeout) XXX_Size() int

func (*BatchTimeout) XXX_Unmarshal Uses

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

type BroadcastResponse Uses

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 Uses

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

func (*BroadcastResponse) GetInfo Uses

func (m *BroadcastResponse) GetInfo() string

func (*BroadcastResponse) GetStatus Uses

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

func (*BroadcastResponse) ProtoMessage Uses

func (*BroadcastResponse) ProtoMessage()

func (*BroadcastResponse) Reset Uses

func (m *BroadcastResponse) Reset()

func (*BroadcastResponse) String Uses

func (m *BroadcastResponse) String() string

func (*BroadcastResponse) XXX_DiscardUnknown Uses

func (m *BroadcastResponse) XXX_DiscardUnknown()

func (*BroadcastResponse) XXX_Marshal Uses

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

func (*BroadcastResponse) XXX_Merge Uses

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

func (*BroadcastResponse) XXX_Size Uses

func (m *BroadcastResponse) XXX_Size() int

func (*BroadcastResponse) XXX_Unmarshal Uses

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

type ChannelRestrictions Uses

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 Uses

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

func (*ChannelRestrictions) GetMaxCount Uses

func (m *ChannelRestrictions) GetMaxCount() uint64

func (*ChannelRestrictions) ProtoMessage Uses

func (*ChannelRestrictions) ProtoMessage()

func (*ChannelRestrictions) Reset Uses

func (m *ChannelRestrictions) Reset()

func (*ChannelRestrictions) String Uses

func (m *ChannelRestrictions) String() string

func (*ChannelRestrictions) XXX_DiscardUnknown Uses

func (m *ChannelRestrictions) XXX_DiscardUnknown()

func (*ChannelRestrictions) XXX_Marshal Uses

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

func (*ChannelRestrictions) XXX_Merge Uses

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

func (*ChannelRestrictions) XXX_Size Uses

func (m *ChannelRestrictions) XXX_Size() int

func (*ChannelRestrictions) XXX_Unmarshal Uses

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

type ClusterClient Uses

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 Uses

func NewClusterClient(cc *grpc.ClientConn) ClusterClient

type ClusterServer Uses

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 Uses

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

type Cluster_StepServer Uses

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

type ConsensusRequest Uses

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 Uses

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

func (*ConsensusRequest) GetChannel Uses

func (m *ConsensusRequest) GetChannel() string

func (*ConsensusRequest) GetPayload Uses

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

func (*ConsensusRequest) ProtoMessage Uses

func (*ConsensusRequest) ProtoMessage()

func (*ConsensusRequest) Reset Uses

func (m *ConsensusRequest) Reset()

func (*ConsensusRequest) String Uses

func (m *ConsensusRequest) String() string

func (*ConsensusRequest) XXX_DiscardUnknown Uses

func (m *ConsensusRequest) XXX_DiscardUnknown()

func (*ConsensusRequest) XXX_Marshal Uses

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

func (*ConsensusRequest) XXX_Merge Uses

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

func (*ConsensusRequest) XXX_Size Uses

func (m *ConsensusRequest) XXX_Size() int

func (*ConsensusRequest) XXX_Unmarshal Uses

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

type ConsensusType Uses

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 Uses

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

func (*ConsensusType) GetMetadata Uses

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

func (*ConsensusType) GetState Uses

func (m *ConsensusType) GetState() ConsensusType_State

func (*ConsensusType) GetType Uses

func (m *ConsensusType) GetType() string

func (*ConsensusType) ProtoMessage Uses

func (*ConsensusType) ProtoMessage()

func (*ConsensusType) Reset Uses

func (m *ConsensusType) Reset()

func (*ConsensusType) String Uses

func (m *ConsensusType) String() string

func (*ConsensusType) VariablyOpaqueFieldProto Uses

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

func (*ConsensusType) VariablyOpaqueFields Uses

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

func (*ConsensusType) XXX_DiscardUnknown Uses

func (m *ConsensusType) XXX_DiscardUnknown()

func (*ConsensusType) XXX_Marshal Uses

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

func (*ConsensusType) XXX_Merge Uses

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

func (*ConsensusType) XXX_Size Uses

func (m *ConsensusType) XXX_Size() int

func (*ConsensusType) XXX_Unmarshal Uses

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

type ConsensusTypeMetadataFactory Uses

type ConsensusTypeMetadataFactory interface {
    NewMessage() proto.Message
}

type ConsensusType_State Uses

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 Uses

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

func (ConsensusType_State) String Uses

func (x ConsensusType_State) String() string

type DeliverResponse Uses

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 Uses

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

func (*DeliverResponse) GetBlock Uses

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

func (*DeliverResponse) GetStatus Uses

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

func (*DeliverResponse) GetType Uses

func (m *DeliverResponse) GetType() isDeliverResponse_Type

func (*DeliverResponse) ProtoMessage Uses

func (*DeliverResponse) ProtoMessage()

func (*DeliverResponse) Reset Uses

func (m *DeliverResponse) Reset()

func (*DeliverResponse) String Uses

func (m *DeliverResponse) String() string

func (*DeliverResponse) XXX_DiscardUnknown Uses

func (m *DeliverResponse) XXX_DiscardUnknown()

func (*DeliverResponse) XXX_Marshal Uses

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

func (*DeliverResponse) XXX_Merge Uses

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

func (*DeliverResponse) XXX_OneofFuncs Uses

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 Uses

func (m *DeliverResponse) XXX_Size() int

func (*DeliverResponse) XXX_Unmarshal Uses

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

type DeliverResponse_Block Uses

type DeliverResponse_Block struct {
    Block *common.Block `protobuf:"bytes,2,opt,name=block,proto3,oneof"`
}

type DeliverResponse_Status Uses

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

type DynamicOrdererConfigValue Uses

type DynamicOrdererConfigValue struct {
    *common.ConfigValue
    // contains filtered or unexported fields
}

func (*DynamicOrdererConfigValue) VariablyOpaqueFieldProto Uses

func (docv *DynamicOrdererConfigValue) VariablyOpaqueFieldProto(name string) (proto.Message, error)

type DynamicOrdererGroup Uses

type DynamicOrdererGroup struct {
    *common.ConfigGroup
}

func (*DynamicOrdererGroup) DynamicMapFieldProto Uses

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

type DynamicOrdererGroupFactory Uses

type DynamicOrdererGroupFactory struct{}

func (DynamicOrdererGroupFactory) DynamicConfigGroup Uses

func (dogf DynamicOrdererGroupFactory) DynamicConfigGroup(cg *common.ConfigGroup) proto.Message

type DynamicOrdererOrgConfigValue Uses

type DynamicOrdererOrgConfigValue struct {
    *common.ConfigValue
    // contains filtered or unexported fields
}

func (*DynamicOrdererOrgConfigValue) VariablyOpaqueFieldProto Uses

func (doocv *DynamicOrdererOrgConfigValue) VariablyOpaqueFieldProto(name string) (proto.Message, error)

type DynamicOrdererOrgGroup Uses

type DynamicOrdererOrgGroup struct {
    *common.ConfigGroup
}

func (*DynamicOrdererOrgGroup) DynamicMapFieldProto Uses

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

type KafkaBrokers Uses

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 Uses

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

func (*KafkaBrokers) GetBrokers Uses

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

func (*KafkaBrokers) ProtoMessage Uses

func (*KafkaBrokers) ProtoMessage()

func (*KafkaBrokers) Reset Uses

func (m *KafkaBrokers) Reset()

func (*KafkaBrokers) String Uses

func (m *KafkaBrokers) String() string

func (*KafkaBrokers) XXX_DiscardUnknown Uses

func (m *KafkaBrokers) XXX_DiscardUnknown()

func (*KafkaBrokers) XXX_Marshal Uses

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

func (*KafkaBrokers) XXX_Merge Uses

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

func (*KafkaBrokers) XXX_Size Uses

func (m *KafkaBrokers) XXX_Size() int

func (*KafkaBrokers) XXX_Unmarshal Uses

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

type KafkaMessage Uses

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 Uses

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

func (*KafkaMessage) GetConnect Uses

func (m *KafkaMessage) GetConnect() *KafkaMessageConnect

func (*KafkaMessage) GetRegular Uses

func (m *KafkaMessage) GetRegular() *KafkaMessageRegular

func (*KafkaMessage) GetTimeToCut Uses

func (m *KafkaMessage) GetTimeToCut() *KafkaMessageTimeToCut

func (*KafkaMessage) GetType Uses

func (m *KafkaMessage) GetType() isKafkaMessage_Type

func (*KafkaMessage) ProtoMessage Uses

func (*KafkaMessage) ProtoMessage()

func (*KafkaMessage) Reset Uses

func (m *KafkaMessage) Reset()

func (*KafkaMessage) String Uses

func (m *KafkaMessage) String() string

func (*KafkaMessage) XXX_DiscardUnknown Uses

func (m *KafkaMessage) XXX_DiscardUnknown()

func (*KafkaMessage) XXX_Marshal Uses

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

func (*KafkaMessage) XXX_Merge Uses

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

func (*KafkaMessage) XXX_OneofFuncs Uses

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 Uses

func (m *KafkaMessage) XXX_Size() int

func (*KafkaMessage) XXX_Unmarshal Uses

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

type KafkaMessageConnect Uses

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 Uses

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

func (*KafkaMessageConnect) GetPayload Uses

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

func (*KafkaMessageConnect) ProtoMessage Uses

func (*KafkaMessageConnect) ProtoMessage()

func (*KafkaMessageConnect) Reset Uses

func (m *KafkaMessageConnect) Reset()

func (*KafkaMessageConnect) String Uses

func (m *KafkaMessageConnect) String() string

func (*KafkaMessageConnect) XXX_DiscardUnknown Uses

func (m *KafkaMessageConnect) XXX_DiscardUnknown()

func (*KafkaMessageConnect) XXX_Marshal Uses

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

func (*KafkaMessageConnect) XXX_Merge Uses

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

func (*KafkaMessageConnect) XXX_Size Uses

func (m *KafkaMessageConnect) XXX_Size() int

func (*KafkaMessageConnect) XXX_Unmarshal Uses

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

type KafkaMessageRegular Uses

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 Uses

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

func (*KafkaMessageRegular) GetClass Uses

func (m *KafkaMessageRegular) GetClass() KafkaMessageRegular_Class

func (*KafkaMessageRegular) GetConfigSeq Uses

func (m *KafkaMessageRegular) GetConfigSeq() uint64

func (*KafkaMessageRegular) GetOriginalOffset Uses

func (m *KafkaMessageRegular) GetOriginalOffset() int64

func (*KafkaMessageRegular) GetPayload Uses

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

func (*KafkaMessageRegular) ProtoMessage Uses

func (*KafkaMessageRegular) ProtoMessage()

func (*KafkaMessageRegular) Reset Uses

func (m *KafkaMessageRegular) Reset()

func (*KafkaMessageRegular) String Uses

func (m *KafkaMessageRegular) String() string

func (*KafkaMessageRegular) XXX_DiscardUnknown Uses

func (m *KafkaMessageRegular) XXX_DiscardUnknown()

func (*KafkaMessageRegular) XXX_Marshal Uses

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

func (*KafkaMessageRegular) XXX_Merge Uses

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

func (*KafkaMessageRegular) XXX_Size Uses

func (m *KafkaMessageRegular) XXX_Size() int

func (*KafkaMessageRegular) XXX_Unmarshal Uses

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

type KafkaMessageRegular_Class Uses

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

func (KafkaMessageRegular_Class) EnumDescriptor Uses

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

func (KafkaMessageRegular_Class) String Uses

func (x KafkaMessageRegular_Class) String() string

type KafkaMessageTimeToCut Uses

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 Uses

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

func (*KafkaMessageTimeToCut) GetBlockNumber Uses

func (m *KafkaMessageTimeToCut) GetBlockNumber() uint64

func (*KafkaMessageTimeToCut) ProtoMessage Uses

func (*KafkaMessageTimeToCut) ProtoMessage()

func (*KafkaMessageTimeToCut) Reset Uses

func (m *KafkaMessageTimeToCut) Reset()

func (*KafkaMessageTimeToCut) String Uses

func (m *KafkaMessageTimeToCut) String() string

func (*KafkaMessageTimeToCut) XXX_DiscardUnknown Uses

func (m *KafkaMessageTimeToCut) XXX_DiscardUnknown()

func (*KafkaMessageTimeToCut) XXX_Marshal Uses

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

func (*KafkaMessageTimeToCut) XXX_Merge Uses

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

func (*KafkaMessageTimeToCut) XXX_Size Uses

func (m *KafkaMessageTimeToCut) XXX_Size() int

func (*KafkaMessageTimeToCut) XXX_Unmarshal Uses

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

type KafkaMessage_Connect Uses

type KafkaMessage_Connect struct {
    Connect *KafkaMessageConnect `protobuf:"bytes,3,opt,name=connect,proto3,oneof"`
}

type KafkaMessage_Regular Uses

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

type KafkaMessage_TimeToCut Uses

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

type KafkaMetadata Uses

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 `protobuf:"varint,2,opt,name=last_original_offset_processed,json=lastOriginalOffsetProcessed,proto3" json:"last_original_offset_processed,omitempty"`
    // 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    `protobuf:"varint,3,opt,name=last_resubmitted_config_offset,json=lastResubmittedConfigOffset,proto3" json:"last_resubmitted_config_offset,omitempty"`
    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 Uses

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

func (*KafkaMetadata) GetLastOffsetPersisted Uses

func (m *KafkaMetadata) GetLastOffsetPersisted() int64

func (*KafkaMetadata) GetLastOriginalOffsetProcessed Uses

func (m *KafkaMetadata) GetLastOriginalOffsetProcessed() int64

func (*KafkaMetadata) GetLastResubmittedConfigOffset Uses

func (m *KafkaMetadata) GetLastResubmittedConfigOffset() int64

func (*KafkaMetadata) ProtoMessage Uses

func (*KafkaMetadata) ProtoMessage()

func (*KafkaMetadata) Reset Uses

func (m *KafkaMetadata) Reset()

func (*KafkaMetadata) String Uses

func (m *KafkaMetadata) String() string

func (*KafkaMetadata) XXX_DiscardUnknown Uses

func (m *KafkaMetadata) XXX_DiscardUnknown()

func (*KafkaMetadata) XXX_Marshal Uses

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

func (*KafkaMetadata) XXX_Merge Uses

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

func (*KafkaMetadata) XXX_Size Uses

func (m *KafkaMetadata) XXX_Size() int

func (*KafkaMetadata) XXX_Unmarshal Uses

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

type SeekInfo Uses

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 `protobuf:"varint,4,opt,name=error_response,json=errorResponse,proto3,enum=orderer.SeekInfo_SeekErrorResponse" json:"error_response,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.

func (*SeekInfo) Descriptor Uses

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

func (*SeekInfo) GetBehavior Uses

func (m *SeekInfo) GetBehavior() SeekInfo_SeekBehavior

func (*SeekInfo) GetErrorResponse Uses

func (m *SeekInfo) GetErrorResponse() SeekInfo_SeekErrorResponse

func (*SeekInfo) GetStart Uses

func (m *SeekInfo) GetStart() *SeekPosition

func (*SeekInfo) GetStop Uses

func (m *SeekInfo) GetStop() *SeekPosition

func (*SeekInfo) ProtoMessage Uses

func (*SeekInfo) ProtoMessage()

func (*SeekInfo) Reset Uses

func (m *SeekInfo) Reset()

func (*SeekInfo) String Uses

func (m *SeekInfo) String() string

func (*SeekInfo) XXX_DiscardUnknown Uses

func (m *SeekInfo) XXX_DiscardUnknown()

func (*SeekInfo) XXX_Marshal Uses

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

func (*SeekInfo) XXX_Merge Uses

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

func (*SeekInfo) XXX_Size Uses

func (m *SeekInfo) XXX_Size() int

func (*SeekInfo) XXX_Unmarshal Uses

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

type SeekInfo_SeekBehavior Uses

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 Uses

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

func (SeekInfo_SeekBehavior) String Uses

func (x SeekInfo_SeekBehavior) String() string

type SeekInfo_SeekErrorResponse Uses

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 Uses

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

func (SeekInfo_SeekErrorResponse) String Uses

func (x SeekInfo_SeekErrorResponse) String() string

type SeekNewest Uses

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

func (*SeekNewest) Descriptor Uses

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

func (*SeekNewest) ProtoMessage Uses

func (*SeekNewest) ProtoMessage()

func (*SeekNewest) Reset Uses

func (m *SeekNewest) Reset()

func (*SeekNewest) String Uses

func (m *SeekNewest) String() string

func (*SeekNewest) XXX_DiscardUnknown Uses

func (m *SeekNewest) XXX_DiscardUnknown()

func (*SeekNewest) XXX_Marshal Uses

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

func (*SeekNewest) XXX_Merge Uses

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

func (*SeekNewest) XXX_Size Uses

func (m *SeekNewest) XXX_Size() int

func (*SeekNewest) XXX_Unmarshal Uses

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

type SeekOldest Uses

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

func (*SeekOldest) Descriptor Uses

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

func (*SeekOldest) ProtoMessage Uses

func (*SeekOldest) ProtoMessage()

func (*SeekOldest) Reset Uses

func (m *SeekOldest) Reset()

func (*SeekOldest) String Uses

func (m *SeekOldest) String() string

func (*SeekOldest) XXX_DiscardUnknown Uses

func (m *SeekOldest) XXX_DiscardUnknown()

func (*SeekOldest) XXX_Marshal Uses

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

func (*SeekOldest) XXX_Merge Uses

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

func (*SeekOldest) XXX_Size Uses

func (m *SeekOldest) XXX_Size() int

func (*SeekOldest) XXX_Unmarshal Uses

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

type SeekPosition Uses

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 Uses

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

func (*SeekPosition) GetNewest Uses

func (m *SeekPosition) GetNewest() *SeekNewest

func (*SeekPosition) GetOldest Uses

func (m *SeekPosition) GetOldest() *SeekOldest

func (*SeekPosition) GetSpecified Uses

func (m *SeekPosition) GetSpecified() *SeekSpecified

func (*SeekPosition) GetType Uses

func (m *SeekPosition) GetType() isSeekPosition_Type

func (*SeekPosition) ProtoMessage Uses

func (*SeekPosition) ProtoMessage()

func (*SeekPosition) Reset Uses

func (m *SeekPosition) Reset()

func (*SeekPosition) String Uses

func (m *SeekPosition) String() string

func (*SeekPosition) XXX_DiscardUnknown Uses

func (m *SeekPosition) XXX_DiscardUnknown()

func (*SeekPosition) XXX_Marshal Uses

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

func (*SeekPosition) XXX_Merge Uses

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

func (*SeekPosition) XXX_OneofFuncs Uses

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 Uses

func (m *SeekPosition) XXX_Size() int

func (*SeekPosition) XXX_Unmarshal Uses

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

type SeekPosition_Newest Uses

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

type SeekPosition_Oldest Uses

type SeekPosition_Oldest struct {
    Oldest *SeekOldest `protobuf:"bytes,2,opt,name=oldest,proto3,oneof"`
}

type SeekPosition_Specified Uses

type SeekPosition_Specified struct {
    Specified *SeekSpecified `protobuf:"bytes,3,opt,name=specified,proto3,oneof"`
}

type SeekSpecified Uses

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 Uses

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

func (*SeekSpecified) GetNumber Uses

func (m *SeekSpecified) GetNumber() uint64

func (*SeekSpecified) ProtoMessage Uses

func (*SeekSpecified) ProtoMessage()

func (*SeekSpecified) Reset Uses

func (m *SeekSpecified) Reset()

func (*SeekSpecified) String Uses

func (m *SeekSpecified) String() string

func (*SeekSpecified) XXX_DiscardUnknown Uses

func (m *SeekSpecified) XXX_DiscardUnknown()

func (*SeekSpecified) XXX_Marshal Uses

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

func (*SeekSpecified) XXX_Merge Uses

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

func (*SeekSpecified) XXX_Size Uses

func (m *SeekSpecified) XXX_Size() int

func (*SeekSpecified) XXX_Unmarshal Uses

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

type StepRequest Uses

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 Uses

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

func (*StepRequest) GetConsensusRequest Uses

func (m *StepRequest) GetConsensusRequest() *ConsensusRequest

func (*StepRequest) GetPayload Uses

func (m *StepRequest) GetPayload() isStepRequest_Payload

func (*StepRequest) GetSubmitRequest Uses

func (m *StepRequest) GetSubmitRequest() *SubmitRequest

func (*StepRequest) ProtoMessage Uses

func (*StepRequest) ProtoMessage()

func (*StepRequest) Reset Uses

func (m *StepRequest) Reset()

func (*StepRequest) String Uses

func (m *StepRequest) String() string

func (*StepRequest) XXX_DiscardUnknown Uses

func (m *StepRequest) XXX_DiscardUnknown()

func (*StepRequest) XXX_Marshal Uses

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

func (*StepRequest) XXX_Merge Uses

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

func (*StepRequest) XXX_OneofFuncs Uses

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 Uses

func (m *StepRequest) XXX_Size() int

func (*StepRequest) XXX_Unmarshal Uses

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

type StepRequest_ConsensusRequest Uses

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

type StepRequest_SubmitRequest Uses

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

type StepResponse Uses

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 Uses

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

func (*StepResponse) GetPayload Uses

func (m *StepResponse) GetPayload() isStepResponse_Payload

func (*StepResponse) GetSubmitRes Uses

func (m *StepResponse) GetSubmitRes() *SubmitResponse

func (*StepResponse) ProtoMessage Uses

func (*StepResponse) ProtoMessage()

func (*StepResponse) Reset Uses

func (m *StepResponse) Reset()

func (*StepResponse) String Uses

func (m *StepResponse) String() string

func (*StepResponse) XXX_DiscardUnknown Uses

func (m *StepResponse) XXX_DiscardUnknown()

func (*StepResponse) XXX_Marshal Uses

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

func (*StepResponse) XXX_Merge Uses

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

func (*StepResponse) XXX_OneofFuncs Uses

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 Uses

func (m *StepResponse) XXX_Size() int

func (*StepResponse) XXX_Unmarshal Uses

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

type StepResponse_SubmitRes Uses

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

type SubmitRequest Uses

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 Uses

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

func (*SubmitRequest) GetChannel Uses

func (m *SubmitRequest) GetChannel() string

func (*SubmitRequest) GetLastValidationSeq Uses

func (m *SubmitRequest) GetLastValidationSeq() uint64

func (*SubmitRequest) GetPayload Uses

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

func (*SubmitRequest) ProtoMessage Uses

func (*SubmitRequest) ProtoMessage()

func (*SubmitRequest) Reset Uses

func (m *SubmitRequest) Reset()

func (*SubmitRequest) String Uses

func (m *SubmitRequest) String() string

func (*SubmitRequest) XXX_DiscardUnknown Uses

func (m *SubmitRequest) XXX_DiscardUnknown()

func (*SubmitRequest) XXX_Marshal Uses

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

func (*SubmitRequest) XXX_Merge Uses

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

func (*SubmitRequest) XXX_Size Uses

func (m *SubmitRequest) XXX_Size() int

func (*SubmitRequest) XXX_Unmarshal Uses

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

type SubmitResponse Uses

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 Uses

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

func (*SubmitResponse) GetChannel Uses

func (m *SubmitResponse) GetChannel() string

func (*SubmitResponse) GetInfo Uses

func (m *SubmitResponse) GetInfo() string

func (*SubmitResponse) GetStatus Uses

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

func (*SubmitResponse) ProtoMessage Uses

func (*SubmitResponse) ProtoMessage()

func (*SubmitResponse) Reset Uses

func (m *SubmitResponse) Reset()

func (*SubmitResponse) String Uses

func (m *SubmitResponse) String() string

func (*SubmitResponse) XXX_DiscardUnknown Uses

func (m *SubmitResponse) XXX_DiscardUnknown()

func (*SubmitResponse) XXX_Marshal Uses

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

func (*SubmitResponse) XXX_Merge Uses

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

func (*SubmitResponse) XXX_Size Uses

func (m *SubmitResponse) XXX_Size() int

func (*SubmitResponse) XXX_Unmarshal Uses

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

Directories

PathSynopsis
etcdraft

Package orderer imports 8 packages (graph) and is imported by 98 packages. Updated 2019-06-11. Refresh now. Tools for package owners.