Documentation
¶
Index ¶
- func WithClientCert(keyPEM, certPEM []byte) func(client *grpcclient.ClientConfig)
- func WithClientCertPath(keyPEMPath, certPEMPath string) func(client *grpcclient.ClientConfig)
- func WithTLS(caPEM []byte) func(client *grpcclient.ClientConfig)
- func WithTLSPath(caPEMPath string) func(client *grpcclient.ClientConfig)
- func WithTimeout(duration time.Duration) func(client *grpcclient.ClientConfig)
- type Client
- type Endpoint
- type Group
- func (g *Group) AddOrdererClient(d Endpoint) error
- func (g *Group) AddPeerClient(d Endpoint) error
- func (g *Group) AddSigner(mspID, mspPath string) error
- func (g *Group) DeleteOrdererClient(address string)
- func (g *Group) DeletePeerClient(address string)
- func (g *Group) DeleteSigner(mspID string)
- func (g *Group) EndorserProposal(endorserAddress []string, sp *peer.SignedProposal) *peer.ProposalResponse
- func (g *Group) GetOrdererClient(address string) *OrdererClient
- func (g *Group) GetOrderersClients() []*OrdererClient
- func (g *Group) GetPeerClient(address string) *PeerClient
- func (g *Group) GetPeerClients() []*PeerClient
- func (g *Group) GetSigner(mspID string) *msp.SigningIdentity
- type GrpcTLSOpt
- type OrdererClient
- type PeerClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithClientCert ¶
func WithClientCert(keyPEM, certPEM []byte) func(client *grpcclient.ClientConfig)
WithClientCert for require client auth cert
func WithClientCertPath ¶
func WithClientCertPath(keyPEMPath, certPEMPath string) func(client *grpcclient.ClientConfig)
WithClientCertPath for require client auth cert
func WithTLSPath ¶
func WithTLSPath(caPEMPath string) func(client *grpcclient.ClientConfig)
WithTLSPath tls ca
func WithTimeout ¶
func WithTimeout(duration time.Duration) func(client *grpcclient.ClientConfig)
WithTimeout grpc connect timeout
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client grpc client
func NewClient ¶
func NewClient(address, override string, Opt ...func(config *grpcclient.ClientConfig)) (*Client, error)
NewClient new grpc client
func (*Client) Certificate ¶
func (c *Client) Certificate() tls.Certificate
Certificate get all certificates
type Endpoint ¶
type Endpoint struct {
Address string
GrpcTLSOpt
}
Endpoint endpoint, such as: peer and orderer
type Group ¶
type Group struct {
// contains filtered or unexported fields
}
Group peer and orderer group
func (*Group) AddOrdererClient ¶
AddOrdererClient add a orderer client
func (*Group) AddPeerClient ¶
AddPeerClient add a peer client
func (*Group) DeleteOrdererClient ¶
DeleteOrdererClient delete a orderer client
func (*Group) DeletePeerClient ¶
DeletePeerClient delete a peer client
func (*Group) DeleteSigner ¶
DeleteSigner delete a msp TODO can't use fabric msp load
func (*Group) EndorserProposal ¶
func (g *Group) EndorserProposal(endorserAddress []string, sp *peer.SignedProposal) *peer.ProposalResponse
EndorserProposal endorse proposal
func (*Group) GetOrdererClient ¶
func (g *Group) GetOrdererClient(address string) *OrdererClient
GetOrdererClient get one orderer client
func (*Group) GetOrderersClients ¶
func (g *Group) GetOrderersClients() []*OrdererClient
GetOrderersClients get all orderers' clients
func (*Group) GetPeerClient ¶
func (g *Group) GetPeerClient(address string) *PeerClient
GetPeerClient get one peer client
func (*Group) GetPeerClients ¶
func (g *Group) GetPeerClients() []*PeerClient
GetPeerClients get all peers' clients
type GrpcTLSOpt ¶
type GrpcTLSOpt struct {
ClientCrt []byte
ClientKey []byte
Ca []byte
ServerNameOverride string
Timeout time.Duration
}
GrpcTLSOpt grpc tls opt(cert is []byte)
type OrdererClient ¶
type OrdererClient struct {
Client
}
OrdererClient orderer client use grpc
func NewOrdererClient ¶
func NewOrdererClient(address, override string, Opt ...func(config *grpcclient.ClientConfig)) (o *OrdererClient, err error)
NewOrdererClient create new orderer client
func NewOrdererClientSelf ¶
func NewOrdererClientSelf(address, override string, Opt ...func(config *grpcclient.ClientConfig)) (*OrdererClient, error)
NewOrdererClientSelf create new orderer client
func (*OrdererClient) Broadcast ¶
func (o *OrdererClient) Broadcast() (ordererProtos.AtomicBroadcast_BroadcastClient, error)
Broadcast orderer broadcast client
func (*OrdererClient) Deliver ¶
func (o *OrdererClient) Deliver() (ordererProtos.AtomicBroadcast_DeliverClient, error)
Deliver orderer deliver client
type PeerClient ¶
type PeerClient struct {
Client
}
PeerClient peer client
func NewPeerClient ¶
func NewPeerClient(address, override string, Opt ...func(*grpcclient.ClientConfig)) (p *PeerClient, err error)
NewPeerClient create new peer client by fabric internal grpc client
func NewPeerClientSelf ¶
func NewPeerClientSelf(address, override string, Opt ...func(config *grpcclient.ClientConfig)) (*PeerClient, error)
NewPeerClientSelf create new peer client by self function
func (*PeerClient) Deliver ¶
func (pc *PeerClient) Deliver() (peer.Deliver_DeliverClient, error)
Deliver returns a client for the Deliver service
func (*PeerClient) Endorser ¶
func (pc *PeerClient) Endorser() (peer.EndorserClient, error)
Endorser returns a client for the Endorser service
func (*PeerClient) PeerDeliver ¶
func (pc *PeerClient) PeerDeliver() (peer.DeliverClient, error)
PeerDeliver returns a client for the Deliver service for peer-specific use cases (i.e. DeliverFiltered)
func (*PeerClient) SnapshotClient ¶
func (pc *PeerClient) SnapshotClient() (peer.SnapshotClient, error)
SnapshotClient returns a client for the snapshot service
Source Files
Directories