orderer

package
v0.0.0-...-523a819 Latest Latest
Warning

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

Go to latest
Published: Jan 21, 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 (*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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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