client

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
  • func NewClient(address, override string, Opt ...func(config *grpcclient.ClientConfig)) (*Client, error)
  • func (c *Client) Certificate() tls.Certificate
  • func (c *Client) Close() error
• type Endpoint
• type Group
  • func NewGroup() *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
  • func NewOrdererClient(address, override string, Opt ...func(config *grpcclient.ClientConfig)) (o *OrdererClient, err error)
  • func NewOrdererClientSelf(address, override string, Opt ...func(config *grpcclient.ClientConfig)) (*OrdererClient, error)
  • func (o *OrdererClient) Broadcast() (ordererProtos.AtomicBroadcast_BroadcastClient, error)
  • func (o *OrdererClient) Deliver() (ordererProtos.AtomicBroadcast_DeliverClient, error)
• type PeerClient
  • func NewPeerClient(address, override string, Opt ...func(*grpcclient.ClientConfig)) (p *PeerClient, err error)
  • func NewPeerClientSelf(address, override string, Opt ...func(config *grpcclient.ClientConfig)) (*PeerClient, error)
  • func (pc *PeerClient) Deliver() (peer.Deliver_DeliverClient, error)
  • func (pc *PeerClient) Endorser() (peer.EndorserClient, error)
  • func (pc *PeerClient) PeerDeliver() (peer.DeliverClient, error)
  • func (pc *PeerClient) SnapshotClient() (peer.SnapshotClient, error)

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 WithTLS

func WithTLS(caPEM []byte) func(client *grpcclient.ClientConfig)

WithTLS tls ca

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

func (*Client) Close

func (c *Client) Close() error

Close close grpc connection

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 NewGroup

func NewGroup() *Group

NewGroup new clients group

func (*Group) AddOrdererClient

func (g *Group) AddOrdererClient(d Endpoint) error

AddOrdererClient add a orderer client

func (*Group) AddPeerClient

func (g *Group) AddPeerClient(d Endpoint) error

AddPeerClient add a peer client

func (*Group) AddSigner

func (g *Group) AddSigner(mspID, mspPath string) error

AddSigner add a msp

func (*Group) DeleteOrdererClient

func (g *Group) DeleteOrdererClient(address string)

DeleteOrdererClient delete a orderer client

func (*Group) DeletePeerClient

func (g *Group) DeletePeerClient(address string)

DeletePeerClient delete a peer client

func (*Group) DeleteSigner

func (g *Group) DeleteSigner(mspID string)

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

func (*Group) GetSigner

func (g *Group) GetSigner(mspID string) *msp.SigningIdentity

GetSigner get map signing

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