Documentation ¶
Index ¶
- Variables
- func RegisterGenesisServer(s *grpc.Server, srv GenesisServer)
- type AnchorPeer
- func (*AnchorPeer) Descriptor() ([]byte, []int)
- func (m *AnchorPeer) GetHost() string
- func (m *AnchorPeer) GetPort() int32
- func (*AnchorPeer) ProtoMessage()
- func (m *AnchorPeer) Reset()
- func (m *AnchorPeer) String() string
- func (m *AnchorPeer) XXX_DiscardUnknown()
- func (m *AnchorPeer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AnchorPeer) XXX_Merge(src proto.Message)
- func (m *AnchorPeer) XXX_Size() int
- func (m *AnchorPeer) XXX_Unmarshal(b []byte) error
- type BatchSize
- func (*BatchSize) Descriptor() ([]byte, []int)
- func (m *BatchSize) GetAbsoluteMaxBytes() uint32
- func (m *BatchSize) GetMaxMessageCount() uint32
- func (m *BatchSize) GetPreferredMaxBytes() uint32
- func (*BatchSize) ProtoMessage()
- func (m *BatchSize) Reset()
- func (m *BatchSize) String() string
- func (m *BatchSize) XXX_DiscardUnknown()
- func (m *BatchSize) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BatchSize) XXX_Merge(src proto.Message)
- func (m *BatchSize) XXX_Size() int
- func (m *BatchSize) XXX_Unmarshal(b []byte) error
- type Code
- type Consenter
- func (*Consenter) Descriptor() ([]byte, []int)
- func (m *Consenter) GetClientTlsCert() []byte
- func (m *Consenter) GetHost() string
- func (m *Consenter) GetPort() uint32
- func (m *Consenter) GetServerTlsCert() []byte
- func (*Consenter) ProtoMessage()
- func (m *Consenter) Reset()
- func (m *Consenter) String() string
- func (m *Consenter) XXX_DiscardUnknown()
- func (m *Consenter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Consenter) XXX_Merge(src proto.Message)
- func (m *Consenter) XXX_Size() int
- func (m *Consenter) XXX_Unmarshal(b []byte) error
- type Consortium
- func (*Consortium) Descriptor() ([]byte, []int)
- func (m *Consortium) GetName() string
- func (m *Consortium) GetPeerOrgs() []*PeerOrg
- func (*Consortium) ProtoMessage()
- func (m *Consortium) Reset()
- func (m *Consortium) String() string
- func (m *Consortium) XXX_DiscardUnknown()
- func (m *Consortium) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Consortium) XXX_Merge(src proto.Message)
- func (m *Consortium) XXX_Size() int
- func (m *Consortium) XXX_Unmarshal(b []byte) error
- type EtcdRaft
- func (*EtcdRaft) Descriptor() ([]byte, []int)
- func (m *EtcdRaft) GetConsenters() []*Consenter
- func (m *EtcdRaft) GetOptions() *Options
- func (*EtcdRaft) ProtoMessage()
- func (m *EtcdRaft) Reset()
- func (m *EtcdRaft) String() string
- func (m *EtcdRaft) XXX_DiscardUnknown()
- func (m *EtcdRaft) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EtcdRaft) XXX_Merge(src proto.Message)
- func (m *EtcdRaft) XXX_Size() int
- func (m *EtcdRaft) XXX_Unmarshal(b []byte) error
- type GenesisClient
- type GenesisServer
- type League
- func (*League) Descriptor() ([]byte, []int)
- func (m *League) GetDomain() string
- func (m *League) GetVersion() Version
- func (*League) ProtoMessage()
- func (m *League) Reset()
- func (m *League) String() string
- func (m *League) XXX_DiscardUnknown()
- func (m *League) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *League) XXX_Merge(src proto.Message)
- func (m *League) XXX_Size() int
- func (m *League) XXX_Unmarshal(b []byte) error
- type MspCert
- func (*MspCert) Descriptor() ([]byte, []int)
- func (m *MspCert) GetAdminCert() []byte
- func (m *MspCert) GetCaCert() []byte
- func (m *MspCert) GetTlsCaCert() []byte
- func (*MspCert) ProtoMessage()
- func (m *MspCert) Reset()
- func (m *MspCert) String() string
- func (m *MspCert) XXX_DiscardUnknown()
- func (m *MspCert) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MspCert) XXX_Merge(src proto.Message)
- func (m *MspCert) XXX_Size() int
- func (m *MspCert) XXX_Unmarshal(b []byte) error
- type Options
- func (*Options) Descriptor() ([]byte, []int)
- func (m *Options) GetElectionTick() uint32
- func (m *Options) GetHeartbeatTick() uint32
- func (m *Options) GetMaxInflightBlocks() uint32
- func (m *Options) GetSnapshotIntervalSize() uint32
- func (m *Options) GetTickInterval() string
- func (*Options) ProtoMessage()
- func (m *Options) Reset()
- func (m *Options) String() string
- func (m *Options) XXX_DiscardUnknown()
- func (m *Options) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Options) XXX_Merge(src proto.Message)
- func (m *Options) XXX_Size() int
- func (m *Options) XXX_Unmarshal(b []byte) error
- type Orderer
- func (*Orderer) Descriptor() ([]byte, []int)
- func (m *Orderer) GetAddresses() []string
- func (m *Orderer) GetBatchSize() *BatchSize
- func (m *Orderer) GetBatchTimeout() int64
- func (m *Orderer) GetEtcdRaft() *EtcdRaft
- func (m *Orderer) GetMaxChannels() uint64
- func (*Orderer) ProtoMessage()
- func (m *Orderer) Reset()
- func (m *Orderer) String() string
- func (m *Orderer) XXX_DiscardUnknown()
- func (m *Orderer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Orderer) XXX_Merge(src proto.Message)
- func (m *Orderer) XXX_Size() int
- func (m *Orderer) XXX_Unmarshal(b []byte) error
- type OrdererOrg
- func (*OrdererOrg) Descriptor() ([]byte, []int)
- func (m *OrdererOrg) GetCert() *MspCert
- func (m *OrdererOrg) GetDomain() string
- func (m *OrdererOrg) GetName() string
- func (m *OrdererOrg) GetOrdererEndpoints() []string
- func (*OrdererOrg) ProtoMessage()
- func (m *OrdererOrg) Reset()
- func (m *OrdererOrg) String() string
- func (m *OrdererOrg) XXX_DiscardUnknown()
- func (m *OrdererOrg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OrdererOrg) XXX_Merge(src proto.Message)
- func (m *OrdererOrg) XXX_Size() int
- func (m *OrdererOrg) XXX_Unmarshal(b []byte) error
- type OrgType
- type PeerOrg
- func (*PeerOrg) Descriptor() ([]byte, []int)
- func (m *PeerOrg) GetAnchorPeers() []*AnchorPeer
- func (m *PeerOrg) GetCert() *MspCert
- func (m *PeerOrg) GetDomain() string
- func (m *PeerOrg) GetName() string
- func (m *PeerOrg) GetOrdererEndpoints() []string
- func (*PeerOrg) ProtoMessage()
- func (m *PeerOrg) Reset()
- func (m *PeerOrg) String() string
- func (m *PeerOrg) XXX_DiscardUnknown()
- func (m *PeerOrg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeerOrg) XXX_Merge(src proto.Message)
- func (m *PeerOrg) XXX_Size() int
- func (m *PeerOrg) XXX_Unmarshal(b []byte) error
- type ReqChannelTx
- func (*ReqChannelTx) Descriptor() ([]byte, []int)
- func (m *ReqChannelTx) GetChannelID() string
- func (m *ReqChannelTx) GetConsortium() string
- func (m *ReqChannelTx) GetLeague() *League
- func (m *ReqChannelTx) GetPeerOrgs() []*PeerOrg
- func (*ReqChannelTx) ProtoMessage()
- func (m *ReqChannelTx) Reset()
- func (m *ReqChannelTx) String() string
- func (m *ReqChannelTx) XXX_DiscardUnknown()
- func (m *ReqChannelTx) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReqChannelTx) XXX_Merge(src proto.Message)
- func (m *ReqChannelTx) XXX_Size() int
- func (m *ReqChannelTx) XXX_Unmarshal(b []byte) error
- type ReqGenesisBlock
- func (*ReqGenesisBlock) Descriptor() ([]byte, []int)
- func (m *ReqGenesisBlock) GetConsortiums() []*Consortium
- func (m *ReqGenesisBlock) GetDefaultChannelID() string
- func (m *ReqGenesisBlock) GetLeague() *League
- func (m *ReqGenesisBlock) GetOrderer() *Orderer
- func (m *ReqGenesisBlock) GetOrdererOrgs() []*OrdererOrg
- func (*ReqGenesisBlock) ProtoMessage()
- func (m *ReqGenesisBlock) Reset()
- func (m *ReqGenesisBlock) String() string
- func (m *ReqGenesisBlock) XXX_DiscardUnknown()
- func (m *ReqGenesisBlock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReqGenesisBlock) XXX_Merge(src proto.Message)
- func (m *ReqGenesisBlock) XXX_Size() int
- func (m *ReqGenesisBlock) XXX_Unmarshal(b []byte) error
- type RespChannelTx
- func (*RespChannelTx) Descriptor() ([]byte, []int)
- func (m *RespChannelTx) GetChannelTxData() []byte
- func (m *RespChannelTx) GetCode() Code
- func (m *RespChannelTx) GetErrMsg() string
- func (*RespChannelTx) ProtoMessage()
- func (m *RespChannelTx) Reset()
- func (m *RespChannelTx) String() string
- func (m *RespChannelTx) XXX_DiscardUnknown()
- func (m *RespChannelTx) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RespChannelTx) XXX_Merge(src proto.Message)
- func (m *RespChannelTx) XXX_Size() int
- func (m *RespChannelTx) XXX_Unmarshal(b []byte) error
- type RespGenesisBlock
- func (*RespGenesisBlock) Descriptor() ([]byte, []int)
- func (m *RespGenesisBlock) GetBlockData() []byte
- func (m *RespGenesisBlock) GetCode() Code
- func (m *RespGenesisBlock) GetErrMsg() string
- func (*RespGenesisBlock) ProtoMessage()
- func (m *RespGenesisBlock) Reset()
- func (m *RespGenesisBlock) String() string
- func (m *RespGenesisBlock) XXX_DiscardUnknown()
- func (m *RespGenesisBlock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RespGenesisBlock) XXX_Merge(src proto.Message)
- func (m *RespGenesisBlock) XXX_Size() int
- func (m *RespGenesisBlock) XXX_Unmarshal(b []byte) error
- type Version
Constants ¶
This section is empty.
Variables ¶
var Code_name = map[int32]string{
0: "Success",
1: "Fail",
}
var Code_value = map[string]int32{
"Success": 0,
"Fail": 1,
}
var OrgType_name = map[int32]string{
0: "Order",
1: "Peer",
}
var OrgType_value = map[string]int32{
"Order": 0,
"Peer": 1,
}
var Version_name = map[int32]string{
0: "V1_1",
1: "V1_2",
2: "V1_3",
3: "V1_4",
4: "V2_0",
}
var Version_value = map[string]int32{
"V1_1": 0,
"V1_2": 1,
"V1_3": 2,
"V1_4": 3,
"V2_0": 4,
}
Functions ¶
func RegisterGenesisServer ¶
func RegisterGenesisServer(s *grpc.Server, srv GenesisServer)
Types ¶
type AnchorPeer ¶
type AnchorPeer struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
锚节点定义了节点的位置,这些节点可用于跨组织的gossip通信。注意,这个值只在应用程序部分上下文的genesis块中编码
func (*AnchorPeer) Descriptor ¶
func (*AnchorPeer) Descriptor() ([]byte, []int)
func (*AnchorPeer) GetHost ¶
func (m *AnchorPeer) GetHost() string
func (*AnchorPeer) GetPort ¶
func (m *AnchorPeer) GetPort() int32
func (*AnchorPeer) ProtoMessage ¶
func (*AnchorPeer) ProtoMessage()
func (*AnchorPeer) Reset ¶
func (m *AnchorPeer) Reset()
func (*AnchorPeer) String ¶
func (m *AnchorPeer) String() string
func (*AnchorPeer) XXX_DiscardUnknown ¶
func (m *AnchorPeer) XXX_DiscardUnknown()
func (*AnchorPeer) XXX_Marshal ¶
func (m *AnchorPeer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AnchorPeer) XXX_Merge ¶
func (m *AnchorPeer) XXX_Merge(src proto.Message)
func (*AnchorPeer) XXX_Size ¶
func (m *AnchorPeer) XXX_Size() int
func (*AnchorPeer) XXX_Unmarshal ¶
func (m *AnchorPeer) XXX_Unmarshal(b []byte) error
type BatchSize ¶
type BatchSize struct { // 最大消息数:批处理中允许的最大消息数。没有一个块包含超过这个数量的消息 MaxMessageCount uint32 `protobuf:"varint,1,opt,name=maxMessageCount,proto3" json:"maxMessageCount,omitempty"` // 绝对最大字节数:批处理中允许的序列化消息的绝对最大字节数 // // 最大块大小是这个值加上相关元数据的大小(通常是几个KB,这取决于签名标识的大小) // // 任何大于此值的事务将被orderer拒绝 // // 如果选择了“kafka”OrdererType,则设置“message.max”。字节数”和“replica.fetch.max。在Kafka代理上设置一个比这个更大的值 AbsoluteMaxBytes uint32 `protobuf:"varint,2,opt,name=absoluteMaxBytes,proto3" json:"absoluteMaxBytes,omitempty"` // 首选最大字节:批处理中序列化消息所允许的首选最大字节数 // // 大致上,这个字段可以被认为是批处理的最大努力 // // 批处理将填充消息,直到达到这个大小(或超过最大消息数,或超过批处理超时) // // 如果向批处理添加新消息会导致批处理超过首选的最大字节,那么将关闭当前批处理并将其写入一个块,并创建一个包含新消息的新批处理 // // 如果接收到的消息大于首选的最大字节,则其批处理将仅包含该消息 // // 因为消息可能大于首选的最大字节(直到AbsoluteMaxBytes),所以某些批可能超过首选的最大字节,但始终只包含一个事务 PreferredMaxBytes uint32 `protobuf:"varint,3,opt,name=preferredMaxBytes,proto3" json:"preferredMaxBytes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
批处理大小:控制成批处理到一个块中的消息的数量
orderer不透明地查看消息,但是通常,消息可能被认为是Fabric事务
“批处理”是块的“数据”字段中的一组消息。当应用签名、散列和其他元数据时,块将比批处理大小大几kb
func (*BatchSize) Descriptor ¶
func (*BatchSize) GetAbsoluteMaxBytes ¶
func (*BatchSize) GetMaxMessageCount ¶
func (*BatchSize) GetPreferredMaxBytes ¶
func (*BatchSize) ProtoMessage ¶
func (*BatchSize) ProtoMessage()
func (*BatchSize) XXX_DiscardUnknown ¶
func (m *BatchSize) XXX_DiscardUnknown()
func (*BatchSize) XXX_Marshal ¶
func (*BatchSize) XXX_Unmarshal ¶
type Consenter ¶
type Consenter struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` ClientTlsCert []byte `protobuf:"bytes,3,opt,name=clientTlsCert,proto3" json:"clientTlsCert,omitempty"` ServerTlsCert []byte `protobuf:"bytes,4,opt,name=serverTlsCert,proto3" json:"serverTlsCert,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
fabric网络中基于raft的orderer单个节点信息
func (*Consenter) Descriptor ¶
func (*Consenter) GetClientTlsCert ¶
func (*Consenter) GetServerTlsCert ¶
func (*Consenter) ProtoMessage ¶
func (*Consenter) ProtoMessage()
func (*Consenter) XXX_DiscardUnknown ¶
func (m *Consenter) XXX_DiscardUnknown()
func (*Consenter) XXX_Marshal ¶
func (*Consenter) XXX_Unmarshal ¶
type Consortium ¶
type Consortium struct { // consortium名称 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // 联盟下非orderer组织集合 PeerOrgs []*PeerOrg `protobuf:"bytes,2,rep,name=peerOrgs,proto3" json:"peerOrgs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Consortium 暂定翻译成协会
协会是区块链网络上的除了orderer组织以外的组织集合。
这些组织形成一个协会,协会内组织拥有自己的节点并能够加入相同通道。
虽然一个区块链网络可以有多个协会,但大多数区块链网络只有一个协会。
在通道创建时,添加到通道的所有组织都必须是协会的一部分。但是,没有在协会中定义的组织可以添加到现有的通道中。
func (*Consortium) Descriptor ¶
func (*Consortium) Descriptor() ([]byte, []int)
func (*Consortium) GetName ¶
func (m *Consortium) GetName() string
func (*Consortium) GetPeerOrgs ¶
func (m *Consortium) GetPeerOrgs() []*PeerOrg
func (*Consortium) ProtoMessage ¶
func (*Consortium) ProtoMessage()
func (*Consortium) Reset ¶
func (m *Consortium) Reset()
func (*Consortium) String ¶
func (m *Consortium) String() string
func (*Consortium) XXX_DiscardUnknown ¶
func (m *Consortium) XXX_DiscardUnknown()
func (*Consortium) XXX_Marshal ¶
func (m *Consortium) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Consortium) XXX_Merge ¶
func (m *Consortium) XXX_Merge(src proto.Message)
func (*Consortium) XXX_Size ¶
func (m *Consortium) XXX_Size() int
func (*Consortium) XXX_Unmarshal ¶
func (m *Consortium) XXX_Unmarshal(b []byte) error
type EtcdRaft ¶
type EtcdRaft struct { // 这个网络的一组raft副本 // // 对于基于etcd/raft的实现,fabric网络中每个副本都是一个OSN // // 因此,此列表中枚举的host:port项的一个子集应该在Orderer.Addresses下复制 Consenters []*Consenter `protobuf:"bytes,1,rep,name=consenters,proto3" json:"consenters,omitempty"` // 为所有etcd/raft节点指定的选项。这里的值是所有新通道的默认值,可以通过配置更新对每个通道进行修改 Options *Options `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
EtcdRaft定义了在选择“EtcdRaft”orderertype时必须设置的配置
func (*EtcdRaft) Descriptor ¶
func (*EtcdRaft) GetConsenters ¶
func (*EtcdRaft) GetOptions ¶
func (*EtcdRaft) ProtoMessage ¶
func (*EtcdRaft) ProtoMessage()
func (*EtcdRaft) XXX_DiscardUnknown ¶
func (m *EtcdRaft) XXX_DiscardUnknown()
func (*EtcdRaft) XXX_Marshal ¶
func (*EtcdRaft) XXX_Unmarshal ¶
type GenesisClient ¶
type GenesisClient interface { // 生成创世区块 CreateGenesisBlock(ctx context.Context, in *ReqGenesisBlock, opts ...grpc.CallOption) (*RespGenesisBlock, error) // 生成通道/账本初始区块 CreateChannelTx(ctx context.Context, in *ReqChannelTx, opts ...grpc.CallOption) (*RespChannelTx, error) }
GenesisClient is the client API for Genesis service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewGenesisClient ¶
func NewGenesisClient(cc *grpc.ClientConn) GenesisClient
type GenesisServer ¶
type GenesisServer interface { // 生成创世区块 CreateGenesisBlock(context.Context, *ReqGenesisBlock) (*RespGenesisBlock, error) // 生成通道/账本初始区块 CreateChannelTx(context.Context, *ReqChannelTx) (*RespChannelTx, error) }
GenesisServer is the server API for Genesis service.
type League ¶
type League struct { // 联盟根域名 Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"` // fabric版本号 Version Version `protobuf:"varint,2,opt,name=version,proto3,enum=genesis.Version" json:"version,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
fabric联盟基本信息
func (*League) Descriptor ¶
func (*League) GetVersion ¶
func (*League) ProtoMessage ¶
func (*League) ProtoMessage()
func (*League) XXX_DiscardUnknown ¶
func (m *League) XXX_DiscardUnknown()
func (*League) XXX_Marshal ¶
func (*League) XXX_Unmarshal ¶
type MspCert ¶
type MspCert struct { // 组织管理员证书 AdminCert []byte `protobuf:"bytes,1,opt,name=adminCert,proto3" json:"adminCert,omitempty"` // 组织根证书 CaCert []byte `protobuf:"bytes,2,opt,name=caCert,proto3" json:"caCert,omitempty"` // 组织tls根证书 TlsCaCert []byte `protobuf:"bytes,3,opt,name=tlsCaCert,proto3" json:"tlsCaCert,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
组织证书信息
func (*MspCert) Descriptor ¶
func (*MspCert) GetAdminCert ¶
func (*MspCert) GetTlsCaCert ¶
func (*MspCert) ProtoMessage ¶
func (*MspCert) ProtoMessage()
func (*MspCert) XXX_DiscardUnknown ¶
func (m *MspCert) XXX_DiscardUnknown()
func (*MspCert) XXX_Marshal ¶
func (*MspCert) XXX_Unmarshal ¶
type Options ¶
type Options struct { // TickInterval是两个节点之间的时间间隔 TickInterval string `protobuf:"bytes,1,opt,name=TickInterval,proto3" json:"TickInterval,omitempty"` // ElectionTick是节点的数量 // // 在两次选举之间必须通过的调用。也就是说,如果一个追随者在选举结束前没有收到任何现任领导人的信息,他将成为候选人并开始选举 // // 选举的节奏必须比心跳的节奏快 ElectionTick uint32 `protobuf:"varint,2,opt,name=ElectionTick,proto3" json:"ElectionTick,omitempty"` // 心跳次数是心跳之间必须传递的节点次数。也就是说,领导者在每一次心跳时都发送心跳信息以保持其领导力 HeartbeatTick uint32 `protobuf:"varint,3,opt,name=HeartbeatTick,proto3" json:"HeartbeatTick,omitempty"` // MaxInflightBlocks在乐观复制阶段限制动态附加消息的最大数量 MaxInflightBlocks uint32 `protobuf:"varint,4,opt,name=MaxInflightBlocks,proto3" json:"MaxInflightBlocks,omitempty"` // SnapshotIntervalSize定义每个快照的字节数 SnapshotIntervalSize uint32 `protobuf:"varint,5,opt,name=SnapshotIntervalSize,proto3" json:"SnapshotIntervalSize,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
为所有etcd/raft节点指定的选项。这里的值是所有新通道的默认值,可以通过配置更新对每个通道进行修改
func (*Options) Descriptor ¶
func (*Options) GetElectionTick ¶
func (*Options) GetHeartbeatTick ¶
func (*Options) GetMaxInflightBlocks ¶
func (*Options) GetSnapshotIntervalSize ¶
func (*Options) GetTickInterval ¶
func (*Options) ProtoMessage ¶
func (*Options) ProtoMessage()
func (*Options) XXX_DiscardUnknown ¶
func (m *Options) XXX_DiscardUnknown()
func (*Options) XXX_Marshal ¶
func (*Options) XXX_Unmarshal ¶
type Orderer ¶
type Orderer struct { // 地址过去是client和peer可以连接的orderer地址列表 // // 但是,这并不允许client关联orderer地址和orderer组织,这对于诸如TLS验证之类的事情是非常有用的 // // 指定orderer地址的首选方法是现在在您的org定义中包含ordererendpoint项 Addresses []string `protobuf:"bytes,3,rep,name=addresses,proto3" json:"addresses,omitempty"` // 批处理超时:创建批处理之前等待的时间量 BatchTimeout int64 `protobuf:"varint,4,opt,name=BatchTimeout,proto3" json:"BatchTimeout,omitempty"` // 批处理大小:控制成批处理到一个块中的消息的数量 BatchSize *BatchSize `protobuf:"bytes,5,opt,name=batchSize,proto3" json:"batchSize,omitempty"` // EtcdRaft定义了在选择“EtcdRaft”orderertype时必须设置的配置 EtcdRaft *EtcdRaft `protobuf:"bytes,6,opt,name=etcdRaft,proto3" json:"etcdRaft,omitempty"` // 最大通道是orderer网络上允许的最大通道数。当设置为0时,这意味着没有最大通道数 MaxChannels uint64 `protobuf:"varint,7,opt,name=MaxChannels,proto3" json:"MaxChannels,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
联盟部署信息
func (*Orderer) Descriptor ¶
func (*Orderer) GetAddresses ¶
func (*Orderer) GetBatchSize ¶
func (*Orderer) GetBatchTimeout ¶
func (*Orderer) GetEtcdRaft ¶
func (*Orderer) GetMaxChannels ¶
func (*Orderer) ProtoMessage ¶
func (*Orderer) ProtoMessage()
func (*Orderer) XXX_DiscardUnknown ¶
func (m *Orderer) XXX_DiscardUnknown()
func (*Orderer) XXX_Marshal ¶
func (*Orderer) XXX_Unmarshal ¶
type OrdererOrg ¶
type OrdererOrg struct { // 组织主域名 Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"` // 组织名称 Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // ordererendpoint是这个组织运行的所有orderers的列表 // // client和peer可以分别连接到这些orderers来推动事务和接收块,如:127.0.0.1:7050 OrdererEndpoints []string `protobuf:"bytes,5,rep,name=ordererEndpoints,proto3" json:"ordererEndpoints,omitempty"` // 组织证书信息 Cert *MspCert `protobuf:"bytes,6,opt,name=cert,proto3" json:"cert,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
请求生成指定联盟默认orderer服务集合
func (*OrdererOrg) Descriptor ¶
func (*OrdererOrg) Descriptor() ([]byte, []int)
func (*OrdererOrg) GetCert ¶
func (m *OrdererOrg) GetCert() *MspCert
func (*OrdererOrg) GetDomain ¶
func (m *OrdererOrg) GetDomain() string
func (*OrdererOrg) GetName ¶
func (m *OrdererOrg) GetName() string
func (*OrdererOrg) GetOrdererEndpoints ¶
func (m *OrdererOrg) GetOrdererEndpoints() []string
func (*OrdererOrg) ProtoMessage ¶
func (*OrdererOrg) ProtoMessage()
func (*OrdererOrg) Reset ¶
func (m *OrdererOrg) Reset()
func (*OrdererOrg) String ¶
func (m *OrdererOrg) String() string
func (*OrdererOrg) XXX_DiscardUnknown ¶
func (m *OrdererOrg) XXX_DiscardUnknown()
func (*OrdererOrg) XXX_Marshal ¶
func (m *OrdererOrg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OrdererOrg) XXX_Merge ¶
func (m *OrdererOrg) XXX_Merge(src proto.Message)
func (*OrdererOrg) XXX_Size ¶
func (m *OrdererOrg) XXX_Size() int
func (*OrdererOrg) XXX_Unmarshal ¶
func (m *OrdererOrg) XXX_Unmarshal(b []byte) error
type PeerOrg ¶
type PeerOrg struct { // 组织主域名 Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"` // 组织名称 Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // ordererendpoint是这个组织运行的所有orderers的列表 // // client和peer可以分别连接到这些orderers来推动事务和接收块,如:127.0.0.1:7050 OrdererEndpoints []string `protobuf:"bytes,5,rep,name=ordererEndpoints,proto3" json:"ordererEndpoints,omitempty"` // 组织证书信息 Cert *MspCert `protobuf:"bytes,6,opt,name=cert,proto3" json:"cert,omitempty"` // 锚节点定义了节点的位置,这些节点可用于跨组织的gossip通信。注意,这个值只在应用程序部分上下文的genesis块中编码 AnchorPeers []*AnchorPeer `protobuf:"bytes,7,rep,name=anchorPeers,proto3" json:"anchorPeers,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
请求生成指定联盟默认org服务集合
func (*PeerOrg) Descriptor ¶
func (*PeerOrg) GetAnchorPeers ¶
func (m *PeerOrg) GetAnchorPeers() []*AnchorPeer
func (*PeerOrg) GetOrdererEndpoints ¶
func (*PeerOrg) ProtoMessage ¶
func (*PeerOrg) ProtoMessage()
func (*PeerOrg) XXX_DiscardUnknown ¶
func (m *PeerOrg) XXX_DiscardUnknown()
func (*PeerOrg) XXX_Marshal ¶
func (*PeerOrg) XXX_Unmarshal ¶
type ReqChannelTx ¶
type ReqChannelTx struct { // fabric联盟基本信息 League *League `protobuf:"bytes,1,opt,name=league,proto3" json:"league,omitempty"` // 联盟下协会 Consortium string `protobuf:"bytes,2,opt,name=consortium,proto3" json:"consortium,omitempty"` // 联盟下通道 ChannelID string `protobuf:"bytes,3,opt,name=channelID,proto3" json:"channelID,omitempty"` // 联盟下非orderer组织集合 PeerOrgs []*PeerOrg `protobuf:"bytes,4,rep,name=peerOrgs,proto3" json:"peerOrgs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReqChannelTx) Descriptor ¶
func (*ReqChannelTx) Descriptor() ([]byte, []int)
func (*ReqChannelTx) GetChannelID ¶
func (m *ReqChannelTx) GetChannelID() string
func (*ReqChannelTx) GetConsortium ¶
func (m *ReqChannelTx) GetConsortium() string
func (*ReqChannelTx) GetLeague ¶
func (m *ReqChannelTx) GetLeague() *League
func (*ReqChannelTx) GetPeerOrgs ¶
func (m *ReqChannelTx) GetPeerOrgs() []*PeerOrg
func (*ReqChannelTx) ProtoMessage ¶
func (*ReqChannelTx) ProtoMessage()
func (*ReqChannelTx) Reset ¶
func (m *ReqChannelTx) Reset()
func (*ReqChannelTx) String ¶
func (m *ReqChannelTx) String() string
func (*ReqChannelTx) XXX_DiscardUnknown ¶
func (m *ReqChannelTx) XXX_DiscardUnknown()
func (*ReqChannelTx) XXX_Marshal ¶
func (m *ReqChannelTx) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReqChannelTx) XXX_Merge ¶
func (m *ReqChannelTx) XXX_Merge(src proto.Message)
func (*ReqChannelTx) XXX_Size ¶
func (m *ReqChannelTx) XXX_Size() int
func (*ReqChannelTx) XXX_Unmarshal ¶
func (m *ReqChannelTx) XXX_Unmarshal(b []byte) error
type ReqGenesisBlock ¶
type ReqGenesisBlock struct { // fabric联盟基本信息 League *League `protobuf:"bytes,1,opt,name=league,proto3" json:"league,omitempty"` // 联盟部署信息 Orderer *Orderer `protobuf:"bytes,2,opt,name=orderer,proto3" json:"orderer,omitempty"` // 跟随创世区块一同创建的默认通道 DefaultChannelID string `protobuf:"bytes,3,opt,name=defaultChannelID,proto3" json:"defaultChannelID,omitempty"` // 联盟下排序服务集合 OrdererOrgs []*OrdererOrg `protobuf:"bytes,4,rep,name=ordererOrgs,proto3" json:"ordererOrgs,omitempty"` // 联盟下协会集合 Consortiums []*Consortium `protobuf:"bytes,5,rep,name=consortiums,proto3" json:"consortiums,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReqGenesisBlock) Descriptor ¶
func (*ReqGenesisBlock) Descriptor() ([]byte, []int)
func (*ReqGenesisBlock) GetConsortiums ¶
func (m *ReqGenesisBlock) GetConsortiums() []*Consortium
func (*ReqGenesisBlock) GetDefaultChannelID ¶
func (m *ReqGenesisBlock) GetDefaultChannelID() string
func (*ReqGenesisBlock) GetLeague ¶
func (m *ReqGenesisBlock) GetLeague() *League
func (*ReqGenesisBlock) GetOrderer ¶
func (m *ReqGenesisBlock) GetOrderer() *Orderer
func (*ReqGenesisBlock) GetOrdererOrgs ¶
func (m *ReqGenesisBlock) GetOrdererOrgs() []*OrdererOrg
func (*ReqGenesisBlock) ProtoMessage ¶
func (*ReqGenesisBlock) ProtoMessage()
func (*ReqGenesisBlock) Reset ¶
func (m *ReqGenesisBlock) Reset()
func (*ReqGenesisBlock) String ¶
func (m *ReqGenesisBlock) String() string
func (*ReqGenesisBlock) XXX_DiscardUnknown ¶
func (m *ReqGenesisBlock) XXX_DiscardUnknown()
func (*ReqGenesisBlock) XXX_Marshal ¶
func (m *ReqGenesisBlock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReqGenesisBlock) XXX_Merge ¶
func (m *ReqGenesisBlock) XXX_Merge(src proto.Message)
func (*ReqGenesisBlock) XXX_Size ¶
func (m *ReqGenesisBlock) XXX_Size() int
func (*ReqGenesisBlock) XXX_Unmarshal ¶
func (m *ReqGenesisBlock) XXX_Unmarshal(b []byte) error
type RespChannelTx ¶
type RespChannelTx struct { // 请求返回结果:success=0;fail=1 Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=genesis.Code" json:"code,omitempty"` // 当且仅当返回码为1时,此处包含错误信息 ErrMsg string `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"` // 通道区块数据,解析使用InspectChannelCreateTx即可 ChannelTxData []byte `protobuf:"bytes,3,opt,name=channelTxData,proto3" json:"channelTxData,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RespChannelTx) Descriptor ¶
func (*RespChannelTx) Descriptor() ([]byte, []int)
func (*RespChannelTx) GetChannelTxData ¶
func (m *RespChannelTx) GetChannelTxData() []byte
func (*RespChannelTx) GetCode ¶
func (m *RespChannelTx) GetCode() Code
func (*RespChannelTx) GetErrMsg ¶
func (m *RespChannelTx) GetErrMsg() string
func (*RespChannelTx) ProtoMessage ¶
func (*RespChannelTx) ProtoMessage()
func (*RespChannelTx) Reset ¶
func (m *RespChannelTx) Reset()
func (*RespChannelTx) String ¶
func (m *RespChannelTx) String() string
func (*RespChannelTx) XXX_DiscardUnknown ¶
func (m *RespChannelTx) XXX_DiscardUnknown()
func (*RespChannelTx) XXX_Marshal ¶
func (m *RespChannelTx) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RespChannelTx) XXX_Merge ¶
func (m *RespChannelTx) XXX_Merge(src proto.Message)
func (*RespChannelTx) XXX_Size ¶
func (m *RespChannelTx) XXX_Size() int
func (*RespChannelTx) XXX_Unmarshal ¶
func (m *RespChannelTx) XXX_Unmarshal(b []byte) error
type RespGenesisBlock ¶
type RespGenesisBlock struct { // 请求返回结果:success=0;fail=1 Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=genesis.Code" json:"code,omitempty"` // 当且仅当返回码为1时,此处包含错误信息 ErrMsg string `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"` // 创世区块数据,解析使用InspectBlock即可 BlockData []byte `protobuf:"bytes,3,opt,name=blockData,proto3" json:"blockData,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RespGenesisBlock) Descriptor ¶
func (*RespGenesisBlock) Descriptor() ([]byte, []int)
func (*RespGenesisBlock) GetBlockData ¶
func (m *RespGenesisBlock) GetBlockData() []byte
func (*RespGenesisBlock) GetCode ¶
func (m *RespGenesisBlock) GetCode() Code
func (*RespGenesisBlock) GetErrMsg ¶
func (m *RespGenesisBlock) GetErrMsg() string
func (*RespGenesisBlock) ProtoMessage ¶
func (*RespGenesisBlock) ProtoMessage()
func (*RespGenesisBlock) Reset ¶
func (m *RespGenesisBlock) Reset()
func (*RespGenesisBlock) String ¶
func (m *RespGenesisBlock) String() string
func (*RespGenesisBlock) XXX_DiscardUnknown ¶
func (m *RespGenesisBlock) XXX_DiscardUnknown()
func (*RespGenesisBlock) XXX_Marshal ¶
func (m *RespGenesisBlock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RespGenesisBlock) XXX_Merge ¶
func (m *RespGenesisBlock) XXX_Merge(src proto.Message)
func (*RespGenesisBlock) XXX_Size ¶
func (m *RespGenesisBlock) XXX_Size() int
func (*RespGenesisBlock) XXX_Unmarshal ¶
func (m *RespGenesisBlock) XXX_Unmarshal(b []byte) error