orderer

package
v0.3.3 Latest Latest
Warning

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

Go to latest
Published: Dec 21, 2023 License: Apache-2.0 Imports: 10 Imported by: 9

Documentation

Index

Constants

View Source
const (
	AtomicBroadcast_Broadcast_FullMethodName = "/orderer.AtomicBroadcast/Broadcast"
	AtomicBroadcast_Deliver_FullMethodName   = "/orderer.AtomicBroadcast/Deliver"
)
View Source
const (
	BlockAttestations_BlockAttestations_FullMethodName = "/orderer.BlockAttestations/BlockAttestations"
)
View Source
const (
	ClusterNodeService_Step_FullMethodName = "/orderer.ClusterNodeService/Step"
)
View Source
const (
	Cluster_Step_FullMethodName = "/orderer.Cluster/Step"
)

Variables

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

Enum value maps for SeekInfo_SeekBehavior.

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

Enum value maps for SeekInfo_SeekErrorResponse.

View Source
var (
	SeekInfo_SeekContentType_name = map[int32]string{
		0: "BLOCK",
		1: "HEADER_WITH_SIG",
	}
	SeekInfo_SeekContentType_value = map[string]int32{
		"BLOCK":           0,
		"HEADER_WITH_SIG": 1,
	}
)

Enum value maps for SeekInfo_SeekContentType.

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

Enum value maps for ConsensusType_State.

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

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

View Source
var BlockAttestations_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "orderer.BlockAttestations",
	HandlerType: (*BlockAttestationsServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "BlockAttestations",
			Handler:       _BlockAttestations_BlockAttestations_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "orderer/blockattestation.proto",
}

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

View Source
var ClusterNodeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "orderer.ClusterNodeService",
	HandlerType: (*ClusterNodeServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Step",
			Handler:       _ClusterNodeService_Step_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "orderer/clusterserver.proto",
}

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

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

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

View Source
var File_orderer_ab_proto protoreflect.FileDescriptor
View Source
var File_orderer_blockattestation_proto protoreflect.FileDescriptor
View Source
var File_orderer_cluster_proto protoreflect.FileDescriptor
View Source
var File_orderer_clusterserver_proto protoreflect.FileDescriptor
View Source
var File_orderer_configuration_proto protoreflect.FileDescriptor

Functions

func RegisterAtomicBroadcastServer

func RegisterAtomicBroadcastServer(s grpc.ServiceRegistrar, srv AtomicBroadcastServer)

func RegisterBlockAttestationsServer added in v0.3.0

func RegisterBlockAttestationsServer(s grpc.ServiceRegistrar, srv BlockAttestationsServer)

func RegisterClusterNodeServiceServer added in v0.3.0

func RegisterClusterNodeServiceServer(s grpc.ServiceRegistrar, srv ClusterNodeServiceServer)

func RegisterClusterServer

func RegisterClusterServer(s grpc.ServiceRegistrar, srv ClusterServer)

Types

type AtomicBroadcastClient

type AtomicBroadcastClient interface {
	// broadcast receives a reply of Acknowledgement for each common.Envelope in order, indicating success or type of failure
	Broadcast(ctx context.Context, opts ...grpc.CallOption) (AtomicBroadcast_BroadcastClient, error)
	// deliver first requires an Envelope of type DELIVER_SEEK_INFO with Payload data as a mashaled SeekInfo message, then a stream of block replies is received.
	Deliver(ctx context.Context, opts ...grpc.CallOption) (AtomicBroadcast_DeliverClient, error)
}

AtomicBroadcastClient is the client API for AtomicBroadcast service.

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

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. All implementations should embed UnimplementedAtomicBroadcastServer for forward compatibility

type AtomicBroadcast_BroadcastClient

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

type AtomicBroadcast_BroadcastServer

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

type AtomicBroadcast_DeliverClient

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

type AtomicBroadcast_DeliverServer

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

type BatchSize

type BatchSize struct {

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

func (*BatchSize) Descriptor deprecated

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

Deprecated: Use BatchSize.ProtoReflect.Descriptor instead.

func (*BatchSize) GetAbsoluteMaxBytes

func (x *BatchSize) GetAbsoluteMaxBytes() uint32

func (*BatchSize) GetMaxMessageCount

func (x *BatchSize) GetMaxMessageCount() uint32

func (*BatchSize) GetPreferredMaxBytes

func (x *BatchSize) GetPreferredMaxBytes() uint32

func (*BatchSize) ProtoMessage

func (*BatchSize) ProtoMessage()

func (*BatchSize) ProtoReflect

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

func (*BatchSize) Reset

func (x *BatchSize) Reset()

func (*BatchSize) String

func (x *BatchSize) String() string

type BatchTimeout

type BatchTimeout struct {

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

func (*BatchTimeout) Descriptor deprecated

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

Deprecated: Use BatchTimeout.ProtoReflect.Descriptor instead.

func (*BatchTimeout) GetTimeout

func (x *BatchTimeout) GetTimeout() string

func (*BatchTimeout) ProtoMessage

func (*BatchTimeout) ProtoMessage()

func (*BatchTimeout) ProtoReflect

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

func (*BatchTimeout) Reset

func (x *BatchTimeout) Reset()

func (*BatchTimeout) String

func (x *BatchTimeout) String() string

type BlockAttestation added in v0.3.0

type BlockAttestation struct {
	Header   *common.BlockHeader   `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Metadata *common.BlockMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockAttestation) Descriptor deprecated added in v0.3.0

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

Deprecated: Use BlockAttestation.ProtoReflect.Descriptor instead.

func (*BlockAttestation) GetHeader added in v0.3.0

func (x *BlockAttestation) GetHeader() *common.BlockHeader

func (*BlockAttestation) GetMetadata added in v0.3.0

func (x *BlockAttestation) GetMetadata() *common.BlockMetadata

func (*BlockAttestation) ProtoMessage added in v0.3.0

func (*BlockAttestation) ProtoMessage()

func (*BlockAttestation) ProtoReflect added in v0.3.0

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

func (*BlockAttestation) Reset added in v0.3.0

func (x *BlockAttestation) Reset()

func (*BlockAttestation) String added in v0.3.0

func (x *BlockAttestation) String() string

type BlockAttestationResponse added in v0.3.0

type BlockAttestationResponse struct {

	// Types that are assignable to Type:
	//
	//	*BlockAttestationResponse_Status
	//	*BlockAttestationResponse_BlockAttestation
	Type isBlockAttestationResponse_Type `protobuf_oneof:"Type"`
	// contains filtered or unexported fields
}

func (*BlockAttestationResponse) Descriptor deprecated added in v0.3.0

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

Deprecated: Use BlockAttestationResponse.ProtoReflect.Descriptor instead.

func (*BlockAttestationResponse) GetBlockAttestation added in v0.3.0

func (x *BlockAttestationResponse) GetBlockAttestation() *BlockAttestation

func (*BlockAttestationResponse) GetStatus added in v0.3.0

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

func (*BlockAttestationResponse) GetType added in v0.3.0

func (m *BlockAttestationResponse) GetType() isBlockAttestationResponse_Type

func (*BlockAttestationResponse) ProtoMessage added in v0.3.0

func (*BlockAttestationResponse) ProtoMessage()

func (*BlockAttestationResponse) ProtoReflect added in v0.3.0

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

func (*BlockAttestationResponse) Reset added in v0.3.0

func (x *BlockAttestationResponse) Reset()

func (*BlockAttestationResponse) String added in v0.3.0

func (x *BlockAttestationResponse) String() string

type BlockAttestationResponse_BlockAttestation added in v0.3.0

type BlockAttestationResponse_BlockAttestation struct {
	BlockAttestation *BlockAttestation `protobuf:"bytes,2,opt,name=block_attestation,json=blockAttestation,proto3,oneof"`
}

type BlockAttestationResponse_Status added in v0.3.0

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

type BlockAttestationsClient added in v0.3.0

type BlockAttestationsClient interface {
	// BlockAttestations receives an Envelope of type DELIVER_SEEK_INFO , then sends back a stream of BlockAttestations.
	BlockAttestations(ctx context.Context, in *common.Envelope, opts ...grpc.CallOption) (BlockAttestations_BlockAttestationsClient, error)
}

BlockAttestationsClient is the client API for BlockAttestations service.

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

func NewBlockAttestationsClient added in v0.3.0

func NewBlockAttestationsClient(cc grpc.ClientConnInterface) BlockAttestationsClient

type BlockAttestationsServer added in v0.3.0

type BlockAttestationsServer interface {
	// BlockAttestations receives an Envelope of type DELIVER_SEEK_INFO , then sends back a stream of BlockAttestations.
	BlockAttestations(*common.Envelope, BlockAttestations_BlockAttestationsServer) error
}

BlockAttestationsServer is the server API for BlockAttestations service. All implementations should embed UnimplementedBlockAttestationsServer for forward compatibility

type BlockAttestations_BlockAttestationsClient added in v0.3.0

type BlockAttestations_BlockAttestationsClient interface {
	Recv() (*BlockAttestationResponse, error)
	grpc.ClientStream
}

type BlockAttestations_BlockAttestationsServer added in v0.3.0

type BlockAttestations_BlockAttestationsServer interface {
	Send(*BlockAttestationResponse) error
	grpc.ServerStream
}

type BroadcastResponse

type BroadcastResponse struct {

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

func (*BroadcastResponse) Descriptor deprecated

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

Deprecated: Use BroadcastResponse.ProtoReflect.Descriptor instead.

func (*BroadcastResponse) GetInfo

func (x *BroadcastResponse) GetInfo() string

func (*BroadcastResponse) GetStatus

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

func (*BroadcastResponse) ProtoMessage

func (*BroadcastResponse) ProtoMessage()

func (*BroadcastResponse) ProtoReflect

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

func (*BroadcastResponse) Reset

func (x *BroadcastResponse) Reset()

func (*BroadcastResponse) String

func (x *BroadcastResponse) String() string

type ChannelRestrictions

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

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

func (*ChannelRestrictions) Descriptor deprecated

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

Deprecated: Use ChannelRestrictions.ProtoReflect.Descriptor instead.

func (*ChannelRestrictions) GetMaxCount

func (x *ChannelRestrictions) GetMaxCount() uint64

func (*ChannelRestrictions) ProtoMessage

func (*ChannelRestrictions) ProtoMessage()

func (*ChannelRestrictions) ProtoReflect

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

func (*ChannelRestrictions) Reset

func (x *ChannelRestrictions) Reset()

func (*ChannelRestrictions) String

func (x *ChannelRestrictions) String() string

type ClusterClient

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

ClusterClient is the client API for Cluster service.

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

func NewClusterClient

func NewClusterClient(cc grpc.ClientConnInterface) ClusterClient

type ClusterNodeServiceClient added in v0.3.0

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

ClusterNodeServiceClient is the client API for ClusterNodeService service.

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

func NewClusterNodeServiceClient added in v0.3.0

func NewClusterNodeServiceClient(cc grpc.ClientConnInterface) ClusterNodeServiceClient

type ClusterNodeServiceServer added in v0.3.0

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

ClusterNodeServiceServer is the server API for ClusterNodeService service. All implementations should embed UnimplementedClusterNodeServiceServer for forward compatibility

type ClusterNodeServiceStepRequest added in v0.3.0

type ClusterNodeServiceStepRequest struct {

	// Types that are assignable to Payload:
	//
	//	*ClusterNodeServiceStepRequest_NodeConrequest
	//	*ClusterNodeServiceStepRequest_NodeTranrequest
	//	*ClusterNodeServiceStepRequest_NodeAuthrequest
	Payload isClusterNodeServiceStepRequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

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

func (*ClusterNodeServiceStepRequest) Descriptor deprecated added in v0.3.0

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

Deprecated: Use ClusterNodeServiceStepRequest.ProtoReflect.Descriptor instead.

func (*ClusterNodeServiceStepRequest) GetNodeAuthrequest added in v0.3.0

func (x *ClusterNodeServiceStepRequest) GetNodeAuthrequest() *NodeAuthRequest

func (*ClusterNodeServiceStepRequest) GetNodeConrequest added in v0.3.0

func (x *ClusterNodeServiceStepRequest) GetNodeConrequest() *NodeConsensusRequest

func (*ClusterNodeServiceStepRequest) GetNodeTranrequest added in v0.3.0

func (*ClusterNodeServiceStepRequest) GetPayload added in v0.3.0

func (m *ClusterNodeServiceStepRequest) GetPayload() isClusterNodeServiceStepRequest_Payload

func (*ClusterNodeServiceStepRequest) ProtoMessage added in v0.3.0

func (*ClusterNodeServiceStepRequest) ProtoMessage()

func (*ClusterNodeServiceStepRequest) ProtoReflect added in v0.3.0

func (*ClusterNodeServiceStepRequest) Reset added in v0.3.0

func (x *ClusterNodeServiceStepRequest) Reset()

func (*ClusterNodeServiceStepRequest) String added in v0.3.0

type ClusterNodeServiceStepRequest_NodeAuthrequest added in v0.3.0

type ClusterNodeServiceStepRequest_NodeAuthrequest struct {
	// Auth authentiates the member that initiated the stream
	NodeAuthrequest *NodeAuthRequest `protobuf:"bytes,3,opt,name=node_authrequest,json=nodeAuthrequest,proto3,oneof"`
}

type ClusterNodeServiceStepRequest_NodeConrequest added in v0.3.0

type ClusterNodeServiceStepRequest_NodeConrequest struct {
	// node_conrequest is a consensus specific message between the cluster memebers.
	NodeConrequest *NodeConsensusRequest `protobuf:"bytes,1,opt,name=node_conrequest,json=nodeConrequest,proto3,oneof"`
}

type ClusterNodeServiceStepRequest_NodeTranrequest added in v0.3.0

type ClusterNodeServiceStepRequest_NodeTranrequest struct {
	// node_tranrequest is a relay of a transaction.
	NodeTranrequest *NodeTransactionOrderRequest `protobuf:"bytes,2,opt,name=node_tranrequest,json=nodeTranrequest,proto3,oneof"`
}

type ClusterNodeServiceStepResponse added in v0.3.0

type ClusterNodeServiceStepResponse struct {

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

ClusterNodeServiceStepResponse is a message received from a cluster member.

func (*ClusterNodeServiceStepResponse) Descriptor deprecated added in v0.3.0

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

Deprecated: Use ClusterNodeServiceStepResponse.ProtoReflect.Descriptor instead.

func (*ClusterNodeServiceStepResponse) GetPayload added in v0.3.0

func (m *ClusterNodeServiceStepResponse) GetPayload() isClusterNodeServiceStepResponse_Payload

func (*ClusterNodeServiceStepResponse) GetTranorderRes added in v0.3.0

func (*ClusterNodeServiceStepResponse) ProtoMessage added in v0.3.0

func (*ClusterNodeServiceStepResponse) ProtoMessage()

func (*ClusterNodeServiceStepResponse) ProtoReflect added in v0.3.0

func (*ClusterNodeServiceStepResponse) Reset added in v0.3.0

func (x *ClusterNodeServiceStepResponse) Reset()

func (*ClusterNodeServiceStepResponse) String added in v0.3.0

type ClusterNodeServiceStepResponse_TranorderRes added in v0.3.0

type ClusterNodeServiceStepResponse_TranorderRes struct {
	TranorderRes *TransactionOrderResponse `protobuf:"bytes,1,opt,name=tranorder_res,json=tranorderRes,proto3,oneof"`
}

type ClusterNodeService_StepClient added in v0.3.0

type ClusterNodeService_StepClient interface {
	Send(*ClusterNodeServiceStepRequest) error
	Recv() (*ClusterNodeServiceStepResponse, error)
	grpc.ClientStream
}

type ClusterNodeService_StepServer added in v0.3.0

type ClusterNodeService_StepServer interface {
	Send(*ClusterNodeServiceStepResponse) error
	Recv() (*ClusterNodeServiceStepRequest, error)
	grpc.ServerStream
}

type ClusterServer

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

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

type Cluster_StepClient

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

type Cluster_StepServer

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

type ConsensusRequest

type ConsensusRequest struct {
	Channel  string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Payload  []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Metadata []byte `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

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

func (*ConsensusRequest) Descriptor deprecated

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

Deprecated: Use ConsensusRequest.ProtoReflect.Descriptor instead.

func (*ConsensusRequest) GetChannel

func (x *ConsensusRequest) GetChannel() string

func (*ConsensusRequest) GetMetadata

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

func (*ConsensusRequest) GetPayload

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

func (*ConsensusRequest) ProtoMessage

func (*ConsensusRequest) ProtoMessage()

func (*ConsensusRequest) ProtoReflect

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

func (*ConsensusRequest) Reset

func (x *ConsensusRequest) Reset()

func (*ConsensusRequest) String

func (x *ConsensusRequest) String() string

type ConsensusType

type ConsensusType struct {

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

func (*ConsensusType) Descriptor deprecated

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

Deprecated: Use ConsensusType.ProtoReflect.Descriptor instead.

func (*ConsensusType) GetMetadata

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

func (*ConsensusType) GetState

func (x *ConsensusType) GetState() ConsensusType_State

func (*ConsensusType) GetType

func (x *ConsensusType) GetType() string

func (*ConsensusType) ProtoMessage

func (*ConsensusType) ProtoMessage()

func (*ConsensusType) ProtoReflect

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

func (*ConsensusType) Reset

func (x *ConsensusType) Reset()

func (*ConsensusType) String

func (x *ConsensusType) String() string

type ConsensusType_State

type ConsensusType_State int32

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

const (
	ConsensusType_STATE_NORMAL      ConsensusType_State = 0
	ConsensusType_STATE_MAINTENANCE ConsensusType_State = 1
)

func (ConsensusType_State) Descriptor

func (ConsensusType_State) Enum

func (ConsensusType_State) EnumDescriptor deprecated

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

Deprecated: Use ConsensusType_State.Descriptor instead.

func (ConsensusType_State) Number

func (ConsensusType_State) String

func (x ConsensusType_State) String() string

func (ConsensusType_State) Type

type DeliverResponse

type DeliverResponse struct {

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

func (*DeliverResponse) Descriptor deprecated

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

Deprecated: Use DeliverResponse.ProtoReflect.Descriptor instead.

func (*DeliverResponse) GetBlock

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

func (*DeliverResponse) GetStatus

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

func (*DeliverResponse) GetType

func (m *DeliverResponse) GetType() isDeliverResponse_Type

func (*DeliverResponse) ProtoMessage

func (*DeliverResponse) ProtoMessage()

func (*DeliverResponse) ProtoReflect

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

func (*DeliverResponse) Reset

func (x *DeliverResponse) Reset()

func (*DeliverResponse) String

func (x *DeliverResponse) String() string

type DeliverResponse_Block

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

type DeliverResponse_Status

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

type KafkaBrokers deprecated

type KafkaBrokers struct {

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

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

Deprecated: Marked as deprecated in orderer/configuration.proto.

func (*KafkaBrokers) Descriptor deprecated

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

Deprecated: Use KafkaBrokers.ProtoReflect.Descriptor instead.

func (*KafkaBrokers) GetBrokers

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

func (*KafkaBrokers) ProtoMessage

func (*KafkaBrokers) ProtoMessage()

func (*KafkaBrokers) ProtoReflect

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

func (*KafkaBrokers) Reset

func (x *KafkaBrokers) Reset()

func (*KafkaBrokers) String

func (x *KafkaBrokers) String() string

type NodeAuthRequest added in v0.3.0

type NodeAuthRequest struct {

	// version represents the fields on which the signature is computed
	Version uint32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// signature is verifiable using the initiator's public key
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// timestamp indicates the freshness of the request; expected to be within the margin
	// of the responsder's local time
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// from_id is the numerical identifier of the initiator of the connection
	FromId uint64 `protobuf:"varint,4,opt,name=from_id,json=fromId,proto3" json:"from_id,omitempty"`
	// to_id is the numerical identifier of the node that is being connected to
	ToId uint64 `protobuf:"varint,5,opt,name=to_id,json=toId,proto3" json:"to_id,omitempty"`
	// session_binding is verifiable using application level protocol
	SessionBinding []byte `protobuf:"bytes,6,opt,name=session_binding,json=sessionBinding,proto3" json:"session_binding,omitempty"`
	Channel        string `protobuf:"bytes,7,opt,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

NodeAuthRequest for authenticate the stream between the cluster members

func (*NodeAuthRequest) Descriptor deprecated added in v0.3.0

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

Deprecated: Use NodeAuthRequest.ProtoReflect.Descriptor instead.

func (*NodeAuthRequest) GetChannel added in v0.3.0

func (x *NodeAuthRequest) GetChannel() string

func (*NodeAuthRequest) GetFromId added in v0.3.0

func (x *NodeAuthRequest) GetFromId() uint64

func (*NodeAuthRequest) GetSessionBinding added in v0.3.0

func (x *NodeAuthRequest) GetSessionBinding() []byte

func (*NodeAuthRequest) GetSignature added in v0.3.0

func (x *NodeAuthRequest) GetSignature() []byte

func (*NodeAuthRequest) GetTimestamp added in v0.3.0

func (x *NodeAuthRequest) GetTimestamp() *timestamppb.Timestamp

func (*NodeAuthRequest) GetToId added in v0.3.0

func (x *NodeAuthRequest) GetToId() uint64

func (*NodeAuthRequest) GetVersion added in v0.3.0

func (x *NodeAuthRequest) GetVersion() uint32

func (*NodeAuthRequest) ProtoMessage added in v0.3.0

func (*NodeAuthRequest) ProtoMessage()

func (*NodeAuthRequest) ProtoReflect added in v0.3.0

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

func (*NodeAuthRequest) Reset added in v0.3.0

func (x *NodeAuthRequest) Reset()

func (*NodeAuthRequest) String added in v0.3.0

func (x *NodeAuthRequest) String() string

type NodeConsensusRequest added in v0.3.0

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

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

func (*NodeConsensusRequest) Descriptor deprecated added in v0.3.0

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

Deprecated: Use NodeConsensusRequest.ProtoReflect.Descriptor instead.

func (*NodeConsensusRequest) GetMetadata added in v0.3.0

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

func (*NodeConsensusRequest) GetPayload added in v0.3.0

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

func (*NodeConsensusRequest) ProtoMessage added in v0.3.0

func (*NodeConsensusRequest) ProtoMessage()

func (*NodeConsensusRequest) ProtoReflect added in v0.3.0

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

func (*NodeConsensusRequest) Reset added in v0.3.0

func (x *NodeConsensusRequest) Reset()

func (*NodeConsensusRequest) String added in v0.3.0

func (x *NodeConsensusRequest) String() string

type NodeTransactionOrderRequest added in v0.3.0

type NodeTransactionOrderRequest struct {

	// last_validation_seq denotes the last configuration sequence at which the
	// sender validated this message.
	LastValidationSeq uint64 `protobuf:"varint,1,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,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

NodeTransactionOrderRequest wraps a transaction to be sent for ordering.

func (*NodeTransactionOrderRequest) Descriptor deprecated added in v0.3.0

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

Deprecated: Use NodeTransactionOrderRequest.ProtoReflect.Descriptor instead.

func (*NodeTransactionOrderRequest) GetLastValidationSeq added in v0.3.0

func (x *NodeTransactionOrderRequest) GetLastValidationSeq() uint64

func (*NodeTransactionOrderRequest) GetPayload added in v0.3.0

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

func (*NodeTransactionOrderRequest) ProtoMessage added in v0.3.0

func (*NodeTransactionOrderRequest) ProtoMessage()

func (*NodeTransactionOrderRequest) ProtoReflect added in v0.3.0

func (*NodeTransactionOrderRequest) Reset added in v0.3.0

func (x *NodeTransactionOrderRequest) Reset()

func (*NodeTransactionOrderRequest) String added in v0.3.0

func (x *NodeTransactionOrderRequest) String() string

type SeekInfo

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

SeekInfo specifies the range of requested blocks to return If the start position is not found, an error is immediately returned Otherwise, blocks are returned until a missing block is encountered, then behavior is dictated by the SeekBehavior specified.

func (*SeekInfo) Descriptor deprecated

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

Deprecated: Use SeekInfo.ProtoReflect.Descriptor instead.

func (*SeekInfo) GetBehavior

func (x *SeekInfo) GetBehavior() SeekInfo_SeekBehavior

func (*SeekInfo) GetContentType added in v0.3.0

func (x *SeekInfo) GetContentType() SeekInfo_SeekContentType

func (*SeekInfo) GetErrorResponse

func (x *SeekInfo) GetErrorResponse() SeekInfo_SeekErrorResponse

func (*SeekInfo) GetStart

func (x *SeekInfo) GetStart() *SeekPosition

func (*SeekInfo) GetStop

func (x *SeekInfo) GetStop() *SeekPosition

func (*SeekInfo) ProtoMessage

func (*SeekInfo) ProtoMessage()

func (*SeekInfo) ProtoReflect

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

func (*SeekInfo) Reset

func (x *SeekInfo) Reset()

func (*SeekInfo) String

func (x *SeekInfo) String() string

type SeekInfo_SeekBehavior

type SeekInfo_SeekBehavior int32

If BLOCK_UNTIL_READY is specified, the reply will block until the requested blocks are available, if FAIL_IF_NOT_READY is specified, the reply will return an error indicating that the block is not found. To request that all blocks be returned indefinitely as they are created, behavior should be set to BLOCK_UNTIL_READY and the stop should be set to specified with a number of MAX_UINT64

const (
	SeekInfo_BLOCK_UNTIL_READY SeekInfo_SeekBehavior = 0
	SeekInfo_FAIL_IF_NOT_READY SeekInfo_SeekBehavior = 1
)

func (SeekInfo_SeekBehavior) Descriptor

func (SeekInfo_SeekBehavior) Enum

func (SeekInfo_SeekBehavior) EnumDescriptor deprecated

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

Deprecated: Use SeekInfo_SeekBehavior.Descriptor instead.

func (SeekInfo_SeekBehavior) Number

func (SeekInfo_SeekBehavior) String

func (x SeekInfo_SeekBehavior) String() string

func (SeekInfo_SeekBehavior) Type

type SeekInfo_SeekContentType added in v0.3.0

type SeekInfo_SeekContentType int32

SeekContentType indicates what type of content to deliver in response to a request. If BLOCK is specified, the orderer will stream blocks back to the peer. This is the default behavior. If HEADER_WITH_SIG is specified, the orderer will stream only a the header and the signature, and the payload field will be set to nil. This allows the requester to ascertain that the respective signed block exists in the orderer (or cluster of orderers).

const (
	SeekInfo_BLOCK           SeekInfo_SeekContentType = 0
	SeekInfo_HEADER_WITH_SIG SeekInfo_SeekContentType = 1
)

func (SeekInfo_SeekContentType) Descriptor added in v0.3.0

func (SeekInfo_SeekContentType) Enum added in v0.3.0

func (SeekInfo_SeekContentType) EnumDescriptor deprecated added in v0.3.0

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

Deprecated: Use SeekInfo_SeekContentType.Descriptor instead.

func (SeekInfo_SeekContentType) Number added in v0.3.0

func (SeekInfo_SeekContentType) String added in v0.3.0

func (x SeekInfo_SeekContentType) String() string

func (SeekInfo_SeekContentType) Type added in v0.3.0

type SeekInfo_SeekErrorResponse

type SeekInfo_SeekErrorResponse int32

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

const (
	SeekInfo_STRICT      SeekInfo_SeekErrorResponse = 0
	SeekInfo_BEST_EFFORT SeekInfo_SeekErrorResponse = 1
)

func (SeekInfo_SeekErrorResponse) Descriptor

func (SeekInfo_SeekErrorResponse) Enum

func (SeekInfo_SeekErrorResponse) EnumDescriptor deprecated

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

Deprecated: Use SeekInfo_SeekErrorResponse.Descriptor instead.

func (SeekInfo_SeekErrorResponse) Number

func (SeekInfo_SeekErrorResponse) String

func (SeekInfo_SeekErrorResponse) Type

type SeekNewest

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

func (*SeekNewest) Descriptor deprecated

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

Deprecated: Use SeekNewest.ProtoReflect.Descriptor instead.

func (*SeekNewest) ProtoMessage

func (*SeekNewest) ProtoMessage()

func (*SeekNewest) ProtoReflect

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

func (*SeekNewest) Reset

func (x *SeekNewest) Reset()

func (*SeekNewest) String

func (x *SeekNewest) String() string

type SeekNextCommit

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

SeekNextCommit refers to the next block that will be committed

func (*SeekNextCommit) Descriptor deprecated

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

Deprecated: Use SeekNextCommit.ProtoReflect.Descriptor instead.

func (*SeekNextCommit) ProtoMessage

func (*SeekNextCommit) ProtoMessage()

func (*SeekNextCommit) ProtoReflect

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

func (*SeekNextCommit) Reset

func (x *SeekNextCommit) Reset()

func (*SeekNextCommit) String

func (x *SeekNextCommit) String() string

type SeekOldest

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

func (*SeekOldest) Descriptor deprecated

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

Deprecated: Use SeekOldest.ProtoReflect.Descriptor instead.

func (*SeekOldest) ProtoMessage

func (*SeekOldest) ProtoMessage()

func (*SeekOldest) ProtoReflect

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

func (*SeekOldest) Reset

func (x *SeekOldest) Reset()

func (*SeekOldest) String

func (x *SeekOldest) String() string

type SeekPosition

type SeekPosition struct {

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

func (*SeekPosition) Descriptor deprecated

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

Deprecated: Use SeekPosition.ProtoReflect.Descriptor instead.

func (*SeekPosition) GetNewest

func (x *SeekPosition) GetNewest() *SeekNewest

func (*SeekPosition) GetNextCommit

func (x *SeekPosition) GetNextCommit() *SeekNextCommit

func (*SeekPosition) GetOldest

func (x *SeekPosition) GetOldest() *SeekOldest

func (*SeekPosition) GetSpecified

func (x *SeekPosition) GetSpecified() *SeekSpecified

func (*SeekPosition) GetType

func (m *SeekPosition) GetType() isSeekPosition_Type

func (*SeekPosition) ProtoMessage

func (*SeekPosition) ProtoMessage()

func (*SeekPosition) ProtoReflect

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

func (*SeekPosition) Reset

func (x *SeekPosition) Reset()

func (*SeekPosition) String

func (x *SeekPosition) String() string

type SeekPosition_Newest

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

type SeekPosition_NextCommit

type SeekPosition_NextCommit struct {
	NextCommit *SeekNextCommit `protobuf:"bytes,4,opt,name=next_commit,json=nextCommit,proto3,oneof"`
}

type SeekPosition_Oldest

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

type SeekPosition_Specified

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

type SeekSpecified

type SeekSpecified struct {
	Number uint64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// contains filtered or unexported fields
}

func (*SeekSpecified) Descriptor deprecated

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

Deprecated: Use SeekSpecified.ProtoReflect.Descriptor instead.

func (*SeekSpecified) GetNumber

func (x *SeekSpecified) GetNumber() uint64

func (*SeekSpecified) ProtoMessage

func (*SeekSpecified) ProtoMessage()

func (*SeekSpecified) ProtoReflect

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

func (*SeekSpecified) Reset

func (x *SeekSpecified) Reset()

func (*SeekSpecified) String

func (x *SeekSpecified) String() string

type StepRequest

type StepRequest struct {

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

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

func (*StepRequest) Descriptor deprecated

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

Deprecated: Use StepRequest.ProtoReflect.Descriptor instead.

func (*StepRequest) GetConsensusRequest

func (x *StepRequest) GetConsensusRequest() *ConsensusRequest

func (*StepRequest) GetPayload

func (m *StepRequest) GetPayload() isStepRequest_Payload

func (*StepRequest) GetSubmitRequest

func (x *StepRequest) GetSubmitRequest() *SubmitRequest

func (*StepRequest) ProtoMessage

func (*StepRequest) ProtoMessage()

func (*StepRequest) ProtoReflect

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

func (*StepRequest) Reset

func (x *StepRequest) Reset()

func (*StepRequest) String

func (x *StepRequest) String() string

type StepRequest_ConsensusRequest

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

type StepRequest_SubmitRequest

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

type StepResponse

type StepResponse struct {

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

StepResponse is a message received from a cluster member.

func (*StepResponse) Descriptor deprecated

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

Deprecated: Use StepResponse.ProtoReflect.Descriptor instead.

func (*StepResponse) GetPayload

func (m *StepResponse) GetPayload() isStepResponse_Payload

func (*StepResponse) GetSubmitRes

func (x *StepResponse) GetSubmitRes() *SubmitResponse

func (*StepResponse) ProtoMessage

func (*StepResponse) ProtoMessage()

func (*StepResponse) ProtoReflect

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

func (*StepResponse) Reset

func (x *StepResponse) Reset()

func (*StepResponse) String

func (x *StepResponse) String() string

type StepResponse_SubmitRes

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

type SubmitRequest

type SubmitRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// last_validation_seq denotes the last
	// configuration sequence at which the
	// sender validated this message.
	LastValidationSeq uint64 `protobuf:"varint,2,opt,name=last_validation_seq,json=lastValidationSeq,proto3" json:"last_validation_seq,omitempty"`
	// content is the fabric transaction
	// that is forwarded to the cluster member.
	Payload *common.Envelope `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

SubmitRequest wraps a transaction to be sent for ordering.

func (*SubmitRequest) Descriptor deprecated

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

Deprecated: Use SubmitRequest.ProtoReflect.Descriptor instead.

func (*SubmitRequest) GetChannel

func (x *SubmitRequest) GetChannel() string

func (*SubmitRequest) GetLastValidationSeq

func (x *SubmitRequest) GetLastValidationSeq() uint64

func (*SubmitRequest) GetPayload

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

func (*SubmitRequest) ProtoMessage

func (*SubmitRequest) ProtoMessage()

func (*SubmitRequest) ProtoReflect

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

func (*SubmitRequest) Reset

func (x *SubmitRequest) Reset()

func (*SubmitRequest) String

func (x *SubmitRequest) String() string

type SubmitResponse

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

SubmitResponse returns a success or failure status to the sender.

func (*SubmitResponse) Descriptor deprecated

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

Deprecated: Use SubmitResponse.ProtoReflect.Descriptor instead.

func (*SubmitResponse) GetChannel

func (x *SubmitResponse) GetChannel() string

func (*SubmitResponse) GetInfo

func (x *SubmitResponse) GetInfo() string

func (*SubmitResponse) GetStatus

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

func (*SubmitResponse) ProtoMessage

func (*SubmitResponse) ProtoMessage()

func (*SubmitResponse) ProtoReflect

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

func (*SubmitResponse) Reset

func (x *SubmitResponse) Reset()

func (*SubmitResponse) String

func (x *SubmitResponse) String() string

type TransactionOrderResponse added in v0.3.0

type TransactionOrderResponse struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	TxId    string `protobuf:"bytes,2,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	// Status code, which may be used to programatically respond to success/failure.
	Status common.Status `protobuf:"varint,3,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,4,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

TransactionOrderResponse returns a success or failure status to the sender.

func (*TransactionOrderResponse) Descriptor deprecated added in v0.3.0

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

Deprecated: Use TransactionOrderResponse.ProtoReflect.Descriptor instead.

func (*TransactionOrderResponse) GetChannel added in v0.3.0

func (x *TransactionOrderResponse) GetChannel() string

func (*TransactionOrderResponse) GetInfo added in v0.3.0

func (x *TransactionOrderResponse) GetInfo() string

func (*TransactionOrderResponse) GetStatus added in v0.3.0

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

func (*TransactionOrderResponse) GetTxId added in v0.3.0

func (x *TransactionOrderResponse) GetTxId() string

func (*TransactionOrderResponse) ProtoMessage added in v0.3.0

func (*TransactionOrderResponse) ProtoMessage()

func (*TransactionOrderResponse) ProtoReflect added in v0.3.0

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

func (*TransactionOrderResponse) Reset added in v0.3.0

func (x *TransactionOrderResponse) Reset()

func (*TransactionOrderResponse) String added in v0.3.0

func (x *TransactionOrderResponse) String() string

type UnimplementedAtomicBroadcastServer

type UnimplementedAtomicBroadcastServer struct {
}

UnimplementedAtomicBroadcastServer should be embedded to have forward compatible implementations.

func (UnimplementedAtomicBroadcastServer) Broadcast

func (UnimplementedAtomicBroadcastServer) Deliver

type UnimplementedBlockAttestationsServer added in v0.3.0

type UnimplementedBlockAttestationsServer struct {
}

UnimplementedBlockAttestationsServer should be embedded to have forward compatible implementations.

func (UnimplementedBlockAttestationsServer) BlockAttestations added in v0.3.0

type UnimplementedClusterNodeServiceServer added in v0.3.0

type UnimplementedClusterNodeServiceServer struct {
}

UnimplementedClusterNodeServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedClusterNodeServiceServer) Step added in v0.3.0

type UnimplementedClusterServer

type UnimplementedClusterServer struct {
}

UnimplementedClusterServer should be embedded to have forward compatible implementations.

func (UnimplementedClusterServer) Step

type UnsafeAtomicBroadcastServer

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

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

type UnsafeBlockAttestationsServer added in v0.3.0

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

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

type UnsafeClusterNodeServiceServer added in v0.3.0

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

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

type UnsafeClusterServer

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

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL