genesis

package
v0.0.0-...-2b16687 Latest Latest
Warning

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

Go to latest
Published: May 6, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Code_name = map[int32]string{
	0: "Success",
	1: "Fail",
}
View Source
var Code_value = map[string]int32{
	"Success": 0,
	"Fail":    1,
}
View Source
var OrgType_name = map[int32]string{
	0: "Order",
	1: "Peer",
}
View Source
var OrgType_value = map[string]int32{
	"Order": 0,
	"Peer":  1,
}
View Source
var Version_name = map[int32]string{
	0: "V1_1",
	1: "V1_2",
	2: "V1_3",
	3: "V1_4",
	4: "V2_0",
}
View Source
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) 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 (m *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 Code

type Code int32

网络请求返回码

const (
	Code_Success Code = 0
	Code_Fail    Code = 1
)

func (Code) EnumDescriptor

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

func (Code) String

func (x Code) String() string

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) Descriptor() ([]byte, []int)

func (*Consenter) GetClientTlsCert

func (m *Consenter) GetClientTlsCert() []byte

func (*Consenter) GetHost

func (m *Consenter) GetHost() string

func (*Consenter) GetPort

func (m *Consenter) GetPort() uint32

func (*Consenter) GetServerTlsCert

func (m *Consenter) GetServerTlsCert() []byte

func (*Consenter) ProtoMessage

func (*Consenter) ProtoMessage()

func (*Consenter) Reset

func (m *Consenter) Reset()

func (*Consenter) String

func (m *Consenter) String() string

func (*Consenter) XXX_DiscardUnknown

func (m *Consenter) XXX_DiscardUnknown()

func (*Consenter) XXX_Marshal

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

func (*Consenter) XXX_Merge

func (m *Consenter) XXX_Merge(src proto.Message)

func (*Consenter) XXX_Size

func (m *Consenter) XXX_Size() int

func (*Consenter) XXX_Unmarshal

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

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) Descriptor() ([]byte, []int)

func (*EtcdRaft) GetConsenters

func (m *EtcdRaft) GetConsenters() []*Consenter

func (*EtcdRaft) GetOptions

func (m *EtcdRaft) GetOptions() *Options

func (*EtcdRaft) ProtoMessage

func (*EtcdRaft) ProtoMessage()

func (*EtcdRaft) Reset

func (m *EtcdRaft) Reset()

func (*EtcdRaft) String

func (m *EtcdRaft) String() string

func (*EtcdRaft) XXX_DiscardUnknown

func (m *EtcdRaft) XXX_DiscardUnknown()

func (*EtcdRaft) XXX_Marshal

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

func (*EtcdRaft) XXX_Merge

func (m *EtcdRaft) XXX_Merge(src proto.Message)

func (*EtcdRaft) XXX_Size

func (m *EtcdRaft) XXX_Size() int

func (*EtcdRaft) XXX_Unmarshal

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

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) Descriptor() ([]byte, []int)

func (*League) GetDomain

func (m *League) GetDomain() string

func (*League) GetVersion

func (m *League) GetVersion() Version

func (*League) ProtoMessage

func (*League) ProtoMessage()

func (*League) Reset

func (m *League) Reset()

func (*League) String

func (m *League) String() string

func (*League) XXX_DiscardUnknown

func (m *League) XXX_DiscardUnknown()

func (*League) XXX_Marshal

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

func (*League) XXX_Merge

func (m *League) XXX_Merge(src proto.Message)

func (*League) XXX_Size

func (m *League) XXX_Size() int

func (*League) XXX_Unmarshal

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

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) Descriptor() ([]byte, []int)

func (*MspCert) GetAdminCert

func (m *MspCert) GetAdminCert() []byte

func (*MspCert) GetCaCert

func (m *MspCert) GetCaCert() []byte

func (*MspCert) GetTlsCaCert

func (m *MspCert) GetTlsCaCert() []byte

func (*MspCert) ProtoMessage

func (*MspCert) ProtoMessage()

func (*MspCert) Reset

func (m *MspCert) Reset()

func (*MspCert) String

func (m *MspCert) String() string

func (*MspCert) XXX_DiscardUnknown

func (m *MspCert) XXX_DiscardUnknown()

func (*MspCert) XXX_Marshal

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

func (*MspCert) XXX_Merge

func (m *MspCert) XXX_Merge(src proto.Message)

func (*MspCert) XXX_Size

func (m *MspCert) XXX_Size() int

func (*MspCert) XXX_Unmarshal

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

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) Descriptor() ([]byte, []int)

func (*Options) GetElectionTick

func (m *Options) GetElectionTick() uint32

func (*Options) GetHeartbeatTick

func (m *Options) GetHeartbeatTick() uint32

func (*Options) GetMaxInflightBlocks

func (m *Options) GetMaxInflightBlocks() uint32

func (*Options) GetSnapshotIntervalSize

func (m *Options) GetSnapshotIntervalSize() uint32

func (*Options) GetTickInterval

func (m *Options) GetTickInterval() string

func (*Options) ProtoMessage

func (*Options) ProtoMessage()

func (*Options) Reset

func (m *Options) Reset()

func (*Options) String

func (m *Options) String() string

func (*Options) XXX_DiscardUnknown

func (m *Options) XXX_DiscardUnknown()

func (*Options) XXX_Marshal

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

func (*Options) XXX_Merge

func (m *Options) XXX_Merge(src proto.Message)

func (*Options) XXX_Size

func (m *Options) XXX_Size() int

func (*Options) XXX_Unmarshal

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

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) Descriptor() ([]byte, []int)

func (*Orderer) GetAddresses

func (m *Orderer) GetAddresses() []string

func (*Orderer) GetBatchSize

func (m *Orderer) GetBatchSize() *BatchSize

func (*Orderer) GetBatchTimeout

func (m *Orderer) GetBatchTimeout() int64

func (*Orderer) GetEtcdRaft

func (m *Orderer) GetEtcdRaft() *EtcdRaft

func (*Orderer) GetMaxChannels

func (m *Orderer) GetMaxChannels() uint64

func (*Orderer) ProtoMessage

func (*Orderer) ProtoMessage()

func (*Orderer) Reset

func (m *Orderer) Reset()

func (*Orderer) String

func (m *Orderer) String() string

func (*Orderer) XXX_DiscardUnknown

func (m *Orderer) XXX_DiscardUnknown()

func (*Orderer) XXX_Marshal

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

func (*Orderer) XXX_Merge

func (m *Orderer) XXX_Merge(src proto.Message)

func (*Orderer) XXX_Size

func (m *Orderer) XXX_Size() int

func (*Orderer) XXX_Unmarshal

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

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 OrgType

type OrgType int32

组织类型

const (
	OrgType_Order OrgType = 0
	OrgType_Peer  OrgType = 1
)

func (OrgType) EnumDescriptor

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

func (OrgType) String

func (x OrgType) String() string

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) Descriptor() ([]byte, []int)

func (*PeerOrg) GetAnchorPeers

func (m *PeerOrg) GetAnchorPeers() []*AnchorPeer

func (*PeerOrg) GetCert

func (m *PeerOrg) GetCert() *MspCert

func (*PeerOrg) GetDomain

func (m *PeerOrg) GetDomain() string

func (*PeerOrg) GetName

func (m *PeerOrg) GetName() string

func (*PeerOrg) GetOrdererEndpoints

func (m *PeerOrg) GetOrdererEndpoints() []string

func (*PeerOrg) ProtoMessage

func (*PeerOrg) ProtoMessage()

func (*PeerOrg) Reset

func (m *PeerOrg) Reset()

func (*PeerOrg) String

func (m *PeerOrg) String() string

func (*PeerOrg) XXX_DiscardUnknown

func (m *PeerOrg) XXX_DiscardUnknown()

func (*PeerOrg) XXX_Marshal

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

func (*PeerOrg) XXX_Merge

func (m *PeerOrg) XXX_Merge(src proto.Message)

func (*PeerOrg) XXX_Size

func (m *PeerOrg) XXX_Size() int

func (*PeerOrg) XXX_Unmarshal

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

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

type Version

type Version int32

fabric版本号

const (
	Version_V1_1 Version = 0
	Version_V1_2 Version = 1
	Version_V1_3 Version = 2
	Version_V1_4 Version = 3
	Version_V2_0 Version = 4
)

func (Version) EnumDescriptor

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

func (Version) String

func (x Version) String() string

Jump to

Keyboard shortcuts

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