orderer

package
v0.0.0-...-fbe82ab Latest Latest
Warning

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

 Go to latest Published: Mar 16, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

ConsensuTypeMetadatamap应该让共识实现注册其元数据消息工厂。

View Source 
var KafkaMessageRegular_Class_name = map[int32]string{
	0: "UNKNOWN",
	1: "NORMAL",
	2: "CONFIG",
}
View Source 
var KafkaMessageRegular_Class_value = map[string]int32{
	"UNKNOWN": 0,
	"NORMAL":  1,
	"CONFIG":  2,
}
View Source 
var SeekInfo_SeekBehavior_name = map[int32]string{
	0: "BLOCK_UNTIL_READY",
	1: "FAIL_IF_NOT_READY",
}
View Source 
var SeekInfo_SeekBehavior_value = map[string]int32{
	"BLOCK_UNTIL_READY": 0,
	"FAIL_IF_NOT_READY": 1,
}

Functions

func RegisterAtomicBroadcastServer 

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

func RegisterClusterServer 

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

Types

type AtomicBroadcastClient 

type AtomicBroadcastClient interface {
	//广播接收对每个公用信封的确认回复。信封按顺序排列，指示成功或失败类型。
	Broadcast(ctx context.Context, opts ...grpc.CallOption) (AtomicBroadcast_BroadcastClient, error)
	//Deliver First需要一个deliver_seek_info类型的信封，其有效载荷数据为mashaled seek info消息，然后接收一个块回复流。
	Deliver(ctx context.Context, opts ...grpc.CallOption) (AtomicBroadcast_DeliverClient, error)
}

atomicbroadcast client是atomicbroadcast服务的客户端API。

有关CTX使用和关闭/结束流式RPC的语义，请参阅https://godoc.org/google.golang.org/grpc clientconn.newstream。

func NewAtomicBroadcastClient 

func NewAtomicBroadcastClient(cc *grpc.ClientConn) AtomicBroadcastClient

type AtomicBroadcastServer 

type AtomicBroadcastServer interface {
	//广播接收对每个公用信封的确认回复。信封按顺序排列，指示成功或失败类型。
	Broadcast(AtomicBroadcast_BroadcastServer) error
	//Deliver First需要一个deliver_seek_info类型的信封，其有效载荷数据为mashaled seek info消息，然后接收一个块回复流。
	Deliver(AtomicBroadcast_DeliverServer) error
}

atomicbroadcast server是atomicbroadcast服务的服务器API。

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 {
	//简单地指定为当前、将来的消息数
	//我们可能希望允许按字节大小指定
	MaxMessageCount uint32 `protobuf:"varint,1,opt,name=max_message_count,json=maxMessageCount,proto3" json:"max_message_count,omitempty"`
	//批处理中序列化消息的字节计数不能
	//超过这个值。
	AbsoluteMaxBytes uint32 `protobuf:"varint,2,opt,name=absolute_max_bytes,json=absoluteMaxBytes,proto3" json:"absolute_max_bytes,omitempty"`
	//批处理中序列化消息的字节计数不应
	//超过这个值。
	PreferredMaxBytes    uint32   `protobuf:"varint,3,opt,name=preferred_max_bytes,json=preferredMaxBytes,proto3" json:"preferred_max_bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchSize) Descriptor 

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

func (*BatchSize) GetAbsoluteMaxBytes 

func (m *BatchSize) GetAbsoluteMaxBytes() uint32

func (*BatchSize) GetMaxMessageCount 

func (m *BatchSize) GetMaxMessageCount() uint32

func (*BatchSize) GetPreferredMaxBytes 

func (m *BatchSize) GetPreferredMaxBytes() uint32

func (*BatchSize) ProtoMessage 

func (*BatchSize) ProtoMessage()

func (*BatchSize) Reset 

func (m *BatchSize) Reset()

func (*BatchSize) String 

func (m *BatchSize) String() string

func (*BatchSize) XXX_DiscardUnknown 

func (m *BatchSize) XXX_DiscardUnknown()

func (*BatchSize) XXX_Marshal 

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

func (*BatchSize) XXX_Merge 

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

func (*BatchSize) XXX_Size 

func (m *BatchSize) XXX_Size() int

func (*BatchSize) XXX_Unmarshal 

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

type BatchTimeout 

type BatchTimeout struct {
	//parseDuration（）可解析的任何持续时间字符串：
	//https://golang.org/pkg/time/分析持续时间
	Timeout              string   `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchTimeout) Descriptor 

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

func (*BatchTimeout) GetTimeout 

func (m *BatchTimeout) GetTimeout() string

func (*BatchTimeout) ProtoMessage 

func (*BatchTimeout) ProtoMessage()

func (*BatchTimeout) Reset 

func (m *BatchTimeout) Reset()

func (*BatchTimeout) String 

func (m *BatchTimeout) String() string

func (*BatchTimeout) XXX_DiscardUnknown 

func (m *BatchTimeout) XXX_DiscardUnknown()

func (*BatchTimeout) XXX_Marshal 

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

func (*BatchTimeout) XXX_Merge 

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

func (*BatchTimeout) XXX_Size 

func (m *BatchTimeout) XXX_Size() int

func (*BatchTimeout) XXX_Unmarshal 

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

type BroadcastResponse 

type BroadcastResponse struct {
	//状态代码，可用于对成功/失败进行编程响应
	Status common.Status `protobuf:"varint,1,opt,name=status,proto3,enum=common.Status" json:"status,omitempty"`
	//可能包含有关返回状态的其他信息的信息字符串
	Info                 string   `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BroadcastResponse) Descriptor 

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

func (*BroadcastResponse) GetInfo 

func (m *BroadcastResponse) GetInfo() string

func (*BroadcastResponse) GetStatus 

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

func (*BroadcastResponse) ProtoMessage 

func (*BroadcastResponse) ProtoMessage()

func (*BroadcastResponse) Reset 

func (m *BroadcastResponse) Reset()

func (*BroadcastResponse) String 

func (m *BroadcastResponse) String() string

func (*BroadcastResponse) XXX_DiscardUnknown 

func (m *BroadcastResponse) XXX_DiscardUnknown()

func (*BroadcastResponse) XXX_Marshal 

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

func (*BroadcastResponse) XXX_Merge 

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

func (*BroadcastResponse) XXX_Size 

func (m *BroadcastResponse) XXX_Size() int

func (*BroadcastResponse) XXX_Unmarshal 

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

type ChannelRestrictions 

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

channel restrictions是一个mssage，它为医嘱者传递对频道创建的限制。

func (*ChannelRestrictions) Descriptor 

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

func (*ChannelRestrictions) GetMaxCount 

func (m *ChannelRestrictions) GetMaxCount() uint64

func (*ChannelRestrictions) ProtoMessage 

func (*ChannelRestrictions) ProtoMessage()

func (*ChannelRestrictions) Reset 

func (m *ChannelRestrictions) Reset()

func (*ChannelRestrictions) String 

func (m *ChannelRestrictions) String() string

func (*ChannelRestrictions) XXX_DiscardUnknown 

func (m *ChannelRestrictions) XXX_DiscardUnknown()

func (*ChannelRestrictions) XXX_Marshal 

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

func (*ChannelRestrictions) XXX_Merge 

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

func (*ChannelRestrictions) XXX_Size 

func (m *ChannelRestrictions) XXX_Size() int

func (*ChannelRestrictions) XXX_Unmarshal 

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

type ClusterClient 

type ClusterClient interface {
	//提交向群集成员提交事务
	Submit(ctx context.Context, opts ...grpc.CallOption) (Cluster_SubmitClient, error)
	//步骤将特定于实现的消息传递给另一个集群成员。
	Step(ctx context.Context, in *StepRequest, opts ...grpc.CallOption) (*StepResponse, error)
}

clusterClient是群集服务的客户端API。

有关CTX使用和关闭/结束流式RPC的语义，请参阅https://godoc.org/google.golang.org/grpc clientconn.newstream。

func NewClusterClient 

func NewClusterClient(cc *grpc.ClientConn) ClusterClient

type ClusterServer 

type ClusterServer interface {
	//提交向群集成员提交事务
	Submit(Cluster_SubmitServer) error
	//步骤将特定于实现的消息传递给另一个集群成员。
	Step(context.Context, *StepRequest) (*StepResponse, error)
}

cluster server是群集服务的服务器API。

type Cluster_SubmitClient 

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

type Cluster_SubmitServer 

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

type ConsensusType 

type ConsensusType struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	//不透明元数据，取决于共识类型。
	Metadata             []byte   `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConsensusType) Descriptor 

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

func (*ConsensusType) GetMetadata 

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

func (*ConsensusType) GetType 

func (m *ConsensusType) GetType() string

func (*ConsensusType) ProtoMessage 

func (*ConsensusType) ProtoMessage()

func (*ConsensusType) Reset 

func (m *ConsensusType) Reset()

func (*ConsensusType) String 

func (m *ConsensusType) String() string

func (*ConsensusType) VariablyOpaqueFieldProto 

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

func (*ConsensusType) VariablyOpaqueFields 

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

func (*ConsensusType) XXX_DiscardUnknown 

func (m *ConsensusType) XXX_DiscardUnknown()

func (*ConsensusType) XXX_Marshal 

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

func (*ConsensusType) XXX_Merge 

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

func (*ConsensusType) XXX_Size 

func (m *ConsensusType) XXX_Size() int

func (*ConsensusType) XXX_Unmarshal 

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

type ConsensusTypeMetadataFactory 

type ConsensusTypeMetadataFactory interface {
	NewMessage() proto.Message
}

type DeliverResponse 

type DeliverResponse struct {
	//有效分配给类型的类型：
	//*交付响应\状态
	//*DeliverResponse_块
	Type                 isDeliverResponse_Type `protobuf_oneof:"Type"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*DeliverResponse) Descriptor 

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

func (*DeliverResponse) GetBlock 

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

func (*DeliverResponse) GetStatus 

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

func (*DeliverResponse) GetType 

func (m *DeliverResponse) GetType() isDeliverResponse_Type

func (*DeliverResponse) ProtoMessage 

func (*DeliverResponse) ProtoMessage()

func (*DeliverResponse) Reset 

func (m *DeliverResponse) Reset()

func (*DeliverResponse) String 

func (m *DeliverResponse) String() string

func (*DeliverResponse) XXX_DiscardUnknown 

func (m *DeliverResponse) XXX_DiscardUnknown()

func (*DeliverResponse) XXX_Marshal 

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

func (*DeliverResponse) XXX_Merge 

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

func (*DeliverResponse) XXX_OneofFuncs 

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

xxxoneoffuncs用于Proto包的内部使用。

func (*DeliverResponse) XXX_Size 

func (m *DeliverResponse) XXX_Size() int

func (*DeliverResponse) XXX_Unmarshal 

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

type DeliverResponse_Block 

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

type DeliverResponse_Status 

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

type DynamicOrdererConfigValue 

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

func (*DynamicOrdererConfigValue) VariablyOpaqueFieldProto 

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

type DynamicOrdererGroup 

type DynamicOrdererGroup struct {
	*common.ConfigGroup
}

func (*DynamicOrdererGroup) DynamicMapFieldProto 

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

type DynamicOrdererGroupFactory 

type DynamicOrdererGroupFactory struct{}

func (DynamicOrdererGroupFactory) DynamicConfigGroup 

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

type DynamicOrdererOrgConfigValue 

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

func (*DynamicOrdererOrgConfigValue) VariablyOpaqueFieldProto 

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

type DynamicOrdererOrgGroup 

type DynamicOrdererOrgGroup struct {
	*common.ConfigGroup
}

func (*DynamicOrdererOrgGroup) DynamicMapFieldProto 

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

type KafkaBrokers 

type KafkaBrokers struct {
	//这里的每个代理都应该使用（IP主机）：端口表示法进行标识，
	//例如，127.0.0.1:7050或localhost:7050是有效条目
	Brokers              []string `protobuf:"bytes,1,rep,name=brokers,proto3" json:"brokers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

带有引导代理列表，即这不是 代理订购服务

func (*KafkaBrokers) Descriptor 

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

func (*KafkaBrokers) GetBrokers 

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

func (*KafkaBrokers) ProtoMessage 

func (*KafkaBrokers) ProtoMessage()

func (*KafkaBrokers) Reset 

func (m *KafkaBrokers) Reset()

func (*KafkaBrokers) String 

func (m *KafkaBrokers) String() string

func (*KafkaBrokers) XXX_DiscardUnknown 

func (m *KafkaBrokers) XXX_DiscardUnknown()

func (*KafkaBrokers) XXX_Marshal 

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

func (*KafkaBrokers) XXX_Merge 

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

func (*KafkaBrokers) XXX_Size 

func (m *KafkaBrokers) XXX_Size() int

func (*KafkaBrokers) XXX_Unmarshal 

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

type KafkaMessage 

type KafkaMessage struct {
	//有效分配给类型的类型：
	//*Kafkamessage_常规
	//*Kafkamessage_时间输出
	//*Kafkamessage_连接
	Type                 isKafkaMessage_Type `protobuf_oneof:"Type"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Kafkamessage是消息的包装类型 卡夫卡订购商处理的。

func (*KafkaMessage) Descriptor 

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

func (*KafkaMessage) GetConnect 

func (m *KafkaMessage) GetConnect() *KafkaMessageConnect

func (*KafkaMessage) GetRegular 

func (m *KafkaMessage) GetRegular() *KafkaMessageRegular

func (*KafkaMessage) GetTimeToCut 

func (m *KafkaMessage) GetTimeToCut() *KafkaMessageTimeToCut

func (*KafkaMessage) GetType 

func (m *KafkaMessage) GetType() isKafkaMessage_Type

func (*KafkaMessage) ProtoMessage 

func (*KafkaMessage) ProtoMessage()

func (*KafkaMessage) Reset 

func (m *KafkaMessage) Reset()

func (*KafkaMessage) String 

func (m *KafkaMessage) String() string

func (*KafkaMessage) XXX_DiscardUnknown 

func (m *KafkaMessage) XXX_DiscardUnknown()

func (*KafkaMessage) XXX_Marshal 

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

func (*KafkaMessage) XXX_Merge 

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

func (*KafkaMessage) XXX_OneofFuncs 

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

xxxoneoffuncs用于Proto包的内部使用。

func (*KafkaMessage) XXX_Size 

func (m *KafkaMessage) XXX_Size() int

func (*KafkaMessage) XXX_Unmarshal 

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

type KafkaMessageConnect 

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

KafkamessageConnect在启动时由订购者发布。 它是用来防止恐慌，如果我们 将消耗一个空分区。它被所有人忽略了 处理分区时的排序器。

func (*KafkaMessageConnect) Descriptor 

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

func (*KafkaMessageConnect) GetPayload 

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

func (*KafkaMessageConnect) ProtoMessage 

func (*KafkaMessageConnect) ProtoMessage()

func (*KafkaMessageConnect) Reset 

func (m *KafkaMessageConnect) Reset()

func (*KafkaMessageConnect) String 

func (m *KafkaMessageConnect) String() string

func (*KafkaMessageConnect) XXX_DiscardUnknown 

func (m *KafkaMessageConnect) XXX_DiscardUnknown()

func (*KafkaMessageConnect) XXX_Marshal 

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

func (*KafkaMessageConnect) XXX_Merge 

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

func (*KafkaMessageConnect) XXX_Size 

func (m *KafkaMessageConnect) XXX_Size() int

func (*KafkaMessageConnect) XXX_Unmarshal 

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

type KafkaMessageRegular 

type KafkaMessageRegular struct {
	Payload              []byte                    `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	ConfigSeq            uint64                    `protobuf:"varint,2,opt,name=config_seq,json=configSeq,proto3" json:"config_seq,omitempty"`
	Class                KafkaMessageRegular_Class `protobuf:"varint,3,opt,name=class,proto3,enum=orderer.KafkaMessageRegular_Class" json:"class,omitempty"`
	OriginalOffset       int64                     `protobuf:"varint,4,opt,name=original_offset,json=originalOffset,proto3" json:"original_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

Kafkamessageregular包装了一个整理好的信封。

func (*KafkaMessageRegular) Descriptor 

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

func (*KafkaMessageRegular) GetClass 

func (m *KafkaMessageRegular) GetClass() KafkaMessageRegular_Class

func (*KafkaMessageRegular) GetConfigSeq 

func (m *KafkaMessageRegular) GetConfigSeq() uint64

func (*KafkaMessageRegular) GetOriginalOffset 

func (m *KafkaMessageRegular) GetOriginalOffset() int64

func (*KafkaMessageRegular) GetPayload 

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

func (*KafkaMessageRegular) ProtoMessage 

func (*KafkaMessageRegular) ProtoMessage()

func (*KafkaMessageRegular) Reset 

func (m *KafkaMessageRegular) Reset()

func (*KafkaMessageRegular) String 

func (m *KafkaMessageRegular) String() string

func (*KafkaMessageRegular) XXX_DiscardUnknown 

func (m *KafkaMessageRegular) XXX_DiscardUnknown()

func (*KafkaMessageRegular) XXX_Marshal 

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

func (*KafkaMessageRegular) XXX_Merge 

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

func (*KafkaMessageRegular) XXX_Size 

func (m *KafkaMessageRegular) XXX_Size() int

func (*KafkaMessageRegular) XXX_Unmarshal 

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

type KafkaMessageRegular_Class 

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

func (KafkaMessageRegular_Class) EnumDescriptor 

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

func (KafkaMessageRegular_Class) String 

func (x KafkaMessageRegular_Class) String() string

type KafkaMessageTimeToCut 

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

kafkamessagetimetocut用于向订购方发送信号 是时候切割块了。

func (*KafkaMessageTimeToCut) Descriptor 

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

func (*KafkaMessageTimeToCut) GetBlockNumber 

func (m *KafkaMessageTimeToCut) GetBlockNumber() uint64

func (*KafkaMessageTimeToCut) ProtoMessage 

func (*KafkaMessageTimeToCut) ProtoMessage()

func (*KafkaMessageTimeToCut) Reset 

func (m *KafkaMessageTimeToCut) Reset()

func (*KafkaMessageTimeToCut) String 

func (m *KafkaMessageTimeToCut) String() string

func (*KafkaMessageTimeToCut) XXX_DiscardUnknown 

func (m *KafkaMessageTimeToCut) XXX_DiscardUnknown()

func (*KafkaMessageTimeToCut) XXX_Marshal 

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

func (*KafkaMessageTimeToCut) XXX_Merge 

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

func (*KafkaMessageTimeToCut) XXX_Size 

func (m *KafkaMessageTimeToCut) XXX_Size() int

func (*KafkaMessageTimeToCut) XXX_Unmarshal 

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

type KafkaMessage_Connect 

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

type KafkaMessage_Regular 

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

type KafkaMessage_TimeToCut 

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

type KafkaMetadata 

type KafkaMetadata struct {
	//LastOffsetPersisted是元数据消息的编码值
	//它编码在案例的排序器块元数据索引中。
	//基于卡夫卡的订购者。
	LastOffsetPersisted int64 `protobuf:"varint,1,opt,name=last_offset_persisted,json=lastOffsetPersisted,proto3" json:"last_offset_persisted,omitempty"`
	//LastOriginalOffsetProcessed用于跟踪最新的
	//如果消息重新验证和重新排序，则处理偏移量。
	//此值用于从中删除重新提交的邮件
	//多个订购者，这样我们就不用再费心重新处理它了。
	LastOriginalOffsetProcessed int64 `` /* 147-byte string literal not displayed */
	//LastSubmittedConfigOffset用于捕获
	//配置kafka消息，重新验证并重新提交。通过比较
	//最后处理的原始偏移量，我们可以确定是否存在
	//仍然是已重新提交但未处理的配置消息
	//然而。它被用作阻止进入消息的条件，因此我们可以减少
	//当config seq保持不变时，重复重新提交消息的开销
	//前进。
	LastResubmittedConfigOffset int64    `` /* 147-byte string literal not displayed */
	XXX_NoUnkeyedLiteral        struct{} `json:"-"`
	XXX_unrecognized            []byte   `json:"-"`
	XXX_sizecache               int32    `json:"-"`
}

Kafkametadata被编码到order块中以跟踪 与此块关联的与Kafka相关的元数据。

func (*KafkaMetadata) Descriptor 

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

func (*KafkaMetadata) GetLastOffsetPersisted 

func (m *KafkaMetadata) GetLastOffsetPersisted() int64

func (*KafkaMetadata) GetLastOriginalOffsetProcessed 

func (m *KafkaMetadata) GetLastOriginalOffsetProcessed() int64

func (*KafkaMetadata) GetLastResubmittedConfigOffset 

func (m *KafkaMetadata) GetLastResubmittedConfigOffset() int64

func (*KafkaMetadata) ProtoMessage 

func (*KafkaMetadata) ProtoMessage()

func (*KafkaMetadata) Reset 

func (m *KafkaMetadata) Reset()

func (*KafkaMetadata) String 

func (m *KafkaMetadata) String() string

func (*KafkaMetadata) XXX_DiscardUnknown 

func (m *KafkaMetadata) XXX_DiscardUnknown()

func (*KafkaMetadata) XXX_Marshal 

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

func (*KafkaMetadata) XXX_Merge 

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

func (*KafkaMetadata) XXX_Size 

func (m *KafkaMetadata) XXX_Size() int

func (*KafkaMetadata) XXX_Unmarshal 

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

type SeekInfo 

type SeekInfo struct {
	Start                *SeekPosition         `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Stop                 *SeekPosition         `protobuf:"bytes,2,opt,name=stop,proto3" json:"stop,omitempty"`
	Behavior             SeekInfo_SeekBehavior `protobuf:"varint,3,opt,name=behavior,proto3,enum=orderer.SeekInfo_SeekBehavior" json:"behavior,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

seekinfo指定要返回的请求块的范围 如果未找到起始位置，则立即返回错误 否则，将返回块，直到遇到丢失的块，然后指定行为 按指定的SeekBehavior。如果在指定“准备就绪”之前阻止，则答复将阻止到 请求的块是可用的，如果指定了“未就绪”，则回复将返回一个 指示找不到块的错误。请求无限期地返回所有块 当它们被创建时，行为应该被设置为阻止，直到“准备就绪”，停止应该被设置为 指定的最大值为14

func (*SeekInfo) Descriptor 

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

func (*SeekInfo) GetBehavior 

func (m *SeekInfo) GetBehavior() SeekInfo_SeekBehavior

func (*SeekInfo) GetStart 

func (m *SeekInfo) GetStart() *SeekPosition

func (*SeekInfo) GetStop 

func (m *SeekInfo) GetStop() *SeekPosition

func (*SeekInfo) ProtoMessage 

func (*SeekInfo) ProtoMessage()

func (*SeekInfo) Reset 

func (m *SeekInfo) Reset()

func (*SeekInfo) String 

func (m *SeekInfo) String() string

func (*SeekInfo) XXX_DiscardUnknown 

func (m *SeekInfo) XXX_DiscardUnknown()

func (*SeekInfo) XXX_Marshal 

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

func (*SeekInfo) XXX_Merge 

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

func (*SeekInfo) XXX_Size 

func (m *SeekInfo) XXX_Size() int

func (*SeekInfo) XXX_Unmarshal 

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

type SeekInfo_SeekBehavior 

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

func (SeekInfo_SeekBehavior) EnumDescriptor 

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

func (SeekInfo_SeekBehavior) String 

func (x SeekInfo_SeekBehavior) String() string

type SeekNewest 

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

func (*SeekNewest) Descriptor 

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

func (*SeekNewest) ProtoMessage 

func (*SeekNewest) ProtoMessage()

func (*SeekNewest) Reset 

func (m *SeekNewest) Reset()

func (*SeekNewest) String 

func (m *SeekNewest) String() string

func (*SeekNewest) XXX_DiscardUnknown 

func (m *SeekNewest) XXX_DiscardUnknown()

func (*SeekNewest) XXX_Marshal 

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

func (*SeekNewest) XXX_Merge 

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

func (*SeekNewest) XXX_Size 

func (m *SeekNewest) XXX_Size() int

func (*SeekNewest) XXX_Unmarshal 

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

type SeekOldest 

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

func (*SeekOldest) Descriptor 

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

func (*SeekOldest) ProtoMessage 

func (*SeekOldest) ProtoMessage()

func (*SeekOldest) Reset 

func (m *SeekOldest) Reset()

func (*SeekOldest) String 

func (m *SeekOldest) String() string

func (*SeekOldest) XXX_DiscardUnknown 

func (m *SeekOldest) XXX_DiscardUnknown()

func (*SeekOldest) XXX_Marshal 

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

func (*SeekOldest) XXX_Merge 

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

func (*SeekOldest) XXX_Size 

func (m *SeekOldest) XXX_Size() int

func (*SeekOldest) XXX_Unmarshal 

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

type SeekPosition 

type SeekPosition struct {
	//有效分配给类型的类型：
	//*请参见位置\最新
	//*请参见位置“最旧”
	//*请参见指定的位置
	Type                 isSeekPosition_Type `protobuf_oneof:"Type"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*SeekPosition) Descriptor 

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

func (*SeekPosition) GetNewest 

func (m *SeekPosition) GetNewest() *SeekNewest

func (*SeekPosition) GetOldest 

func (m *SeekPosition) GetOldest() *SeekOldest

func (*SeekPosition) GetSpecified 

func (m *SeekPosition) GetSpecified() *SeekSpecified

func (*SeekPosition) GetType 

func (m *SeekPosition) GetType() isSeekPosition_Type

func (*SeekPosition) ProtoMessage 

func (*SeekPosition) ProtoMessage()

func (*SeekPosition) Reset 

func (m *SeekPosition) Reset()

func (*SeekPosition) String 

func (m *SeekPosition) String() string

func (*SeekPosition) XXX_DiscardUnknown 

func (m *SeekPosition) XXX_DiscardUnknown()

func (*SeekPosition) XXX_Marshal 

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

func (*SeekPosition) XXX_Merge 

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

func (*SeekPosition) XXX_OneofFuncs 

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

xxxoneoffuncs用于Proto包的内部使用。

func (*SeekPosition) XXX_Size 

func (m *SeekPosition) XXX_Size() int

func (*SeekPosition) XXX_Unmarshal 

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

type SeekPosition_Newest 

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

type SeekPosition_Oldest 

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

type SeekPosition_Specified 

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

type SeekSpecified 

type SeekSpecified struct {
	Number               uint64   `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SeekSpecified) Descriptor 

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

func (*SeekSpecified) GetNumber 

func (m *SeekSpecified) GetNumber() uint64

func (*SeekSpecified) ProtoMessage 

func (*SeekSpecified) ProtoMessage()

func (*SeekSpecified) Reset 

func (m *SeekSpecified) Reset()

func (*SeekSpecified) String 

func (m *SeekSpecified) String() string

func (*SeekSpecified) XXX_DiscardUnknown 

func (m *SeekSpecified) XXX_DiscardUnknown()

func (*SeekSpecified) XXX_Marshal 

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

func (*SeekSpecified) XXX_Merge 

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

func (*SeekSpecified) XXX_Size 

func (m *SeekSpecified) XXX_Size() int

func (*SeekSpecified) XXX_Unmarshal 

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

type StepRequest 

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

stepRequest包含共识实现 发送到群集成员的特定消息

func (*StepRequest) Descriptor 

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

func (*StepRequest) GetChannel 

func (m *StepRequest) GetChannel() string

func (*StepRequest) GetPayload 

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

func (*StepRequest) ProtoMessage 

func (*StepRequest) ProtoMessage()

func (*StepRequest) Reset 

func (m *StepRequest) Reset()

func (*StepRequest) String 

func (m *StepRequest) String() string

func (*StepRequest) XXX_DiscardUnknown 

func (m *StepRequest) XXX_DiscardUnknown()

func (*StepRequest) XXX_Marshal 

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

func (*StepRequest) XXX_Merge 

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

func (*StepRequest) XXX_Size 

func (m *StepRequest) XXX_Size() int

func (*StepRequest) XXX_Unmarshal 

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

type StepResponse 

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

StepResponse包含共识实施 从接收到的特定消息 作为对stepRequest的响应的集群成员

func (*StepResponse) Descriptor 

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

func (*StepResponse) GetPayload 

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

func (*StepResponse) ProtoMessage 

func (*StepResponse) ProtoMessage()

func (*StepResponse) Reset 

func (m *StepResponse) Reset()

func (*StepResponse) String 

func (m *StepResponse) String() string

func (*StepResponse) XXX_DiscardUnknown 

func (m *StepResponse) XXX_DiscardUnknown()

func (*StepResponse) XXX_Marshal 

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

func (*StepResponse) XXX_Merge 

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

func (*StepResponse) XXX_Size 

func (m *StepResponse) XXX_Size() int

func (*StepResponse) XXX_Unmarshal 

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

type SubmitRequest 

type SubmitRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	//Last_validation_seq表示最后一个
	//配置顺序
	//发件人已验证此邮件
	LastValidationSeq uint64 `protobuf:"varint,2,opt,name=last_validation_seq,json=lastValidationSeq,proto3" json:"last_validation_seq,omitempty"`
	//内容是结构事务
	//转发给群集成员的
	Content              *common.Envelope `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

SubmitRequest包装要发送用于订购的事务

func (*SubmitRequest) Descriptor 

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

func (*SubmitRequest) GetChannel 

func (m *SubmitRequest) GetChannel() string

func (*SubmitRequest) GetContent 

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

func (*SubmitRequest) GetLastValidationSeq 

func (m *SubmitRequest) GetLastValidationSeq() uint64

func (*SubmitRequest) ProtoMessage 

func (*SubmitRequest) ProtoMessage()

func (*SubmitRequest) Reset 

func (m *SubmitRequest) Reset()

func (*SubmitRequest) String 

func (m *SubmitRequest) String() string

func (*SubmitRequest) XXX_DiscardUnknown 

func (m *SubmitRequest) XXX_DiscardUnknown()

func (*SubmitRequest) XXX_Marshal 

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

func (*SubmitRequest) XXX_Merge 

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

func (*SubmitRequest) XXX_Size 

func (m *SubmitRequest) XXX_Size() int

func (*SubmitRequest) XXX_Unmarshal 

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

type SubmitResponse 

type SubmitResponse struct {
	//状态代码，可用于对成功/失败进行编程响应
	Status common.Status `protobuf:"varint,1,opt,name=status,proto3,enum=common.Status" json:"status,omitempty"`
	//可能包含有关返回状态的其他信息的信息字符串
	Info                 string   `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SubmitResponse返回成功 或发送程序的失败状态

func (*SubmitResponse) Descriptor 

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

func (*SubmitResponse) GetInfo 

func (m *SubmitResponse) GetInfo() string

func (*SubmitResponse) GetStatus 

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

func (*SubmitResponse) ProtoMessage 

func (*SubmitResponse) ProtoMessage()

func (*SubmitResponse) Reset 

func (m *SubmitResponse) Reset()

func (*SubmitResponse) String 

func (m *SubmitResponse) String() string

func (*SubmitResponse) XXX_DiscardUnknown 

func (m *SubmitResponse) XXX_DiscardUnknown()

func (*SubmitResponse) XXX_Marshal 

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

func (*SubmitResponse) XXX_Merge 

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

func (*SubmitResponse) XXX_Size 

func (m *SubmitResponse) XXX_Size() int

func (*SubmitResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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