Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

client

package

Go to main page

Versions in this module

v0

v0.0.3

Feb 3, 2020

v0.0.2

Feb 3, 2020

v0.0.1

Jan 31, 2020

Changes in this version

+ func BroadcastReceive(broadcast Broadcast, addr string, responses chan common.Status, ...)

+ func BroadcastSend(broadcast Broadcast, addr string, envelope *common.Envelope) error

+ func BroadcastWaitForResponse(responses chan common.Status, errs chan error) (common.Status, error)

+ func CreateDeliverEnvelope(channelId string, creator []byte, signer SignerIdentity, cert *tls.Certificate) (*common.Envelope, error)

+ func CreateEnvelope(data []byte, header *common.Header, signer SignerIdentity) (*common.Envelope, error)

+ func CreateHeader(txType common.HeaderType, channelId string, creator []byte, tlsCertHash []byte) (string, *common.Header, error)

+ func DeliverReceive(df DeliverFiltered, address string, txid string, eventCh chan TxEvent) error

+ func DeliverSend(df DeliverFiltered, address string, envelope *common.Envelope) error

+ func DeliverWaitForResponse(ctx context.Context, eventCh chan TxEvent, txid string) (bool, error)

+ func ValidateClientConfig(config *ClientConfig) error

+ type Broadcast interface

+ CloseSend func() error

+ Recv func() (*ab.BroadcastResponse, error)

+ Send func(m *common.Envelope) error

+ type Client struct

+ Prover Prover

+ SigningIdentity tk.SigningIdentity

+ TxSubmitter FabricTxSubmitter

+ func (c *Client) Issue(tokensToIssue []*token.TokenToIssue) ([]byte, error)

+ func (c *Client) Transfer(tokenIDs [][]byte, shares []*token.RecipientTransferShare) ([]byte, error)

+ type ClientConfig struct

+ ChannelId string

+ CommitPeerCfg ConnectionConfig

+ MspDir string

+ MspId string

+ OrdererCfg ConnectionConfig

+ ProverPeerCfg ConnectionConfig

+ TlsEnabled bool

+ type ConnectionConfig struct

+ Address string

+ ServerNameOverride string

+ TlsRootCertFile string

+ type DeliverClient interface

+ Certificate func() *tls.Certificate

+ NewDeliverFiltered func(ctx context.Context, opts ...grpc.CallOption) (DeliverFiltered, error)

+ func NewDeliverClient(config *ClientConfig) (DeliverClient, error)

+ type DeliverFiltered interface

+ CloseSend func() error

+ Recv func() (*pb.DeliverResponse, error)

+ Send func(*common.Envelope) error

+ type FabricTxSubmitter interface

+ Submit func(tx []byte) error

+ type OrdererClient interface

+ Certificate func() *tls.Certificate

+ NewBroadcast func(ctx context.Context, opts ...grpc.CallOption) (Broadcast, error)

+ func NewOrdererClient(config *ClientConfig) (OrdererClient, error)

+ type Prover interface

+ RequestImport func(tokensToIssue []*token.TokenToIssue, signingIdentity tk.SigningIdentity) ([]byte, error)

+ RequestTransfer func(tokenIDs [][]byte, shares []*token.RecipientTransferShare, ...) ([]byte, error)

+ type ProverPeer struct

+ ChannelID string

+ ProverClient token.ProverClient

+ RandomnessReader io.Reader

+ Time TimeFunc

+ func (prover *ProverPeer) CreateSignedCommand(payload interface{}, signingIdentity tk.SigningIdentity) (*token.SignedCommand, error)

+ func (prover *ProverPeer) RequestImport(tokensToIssue []*token.TokenToIssue, signingIdentity tk.SigningIdentity) ([]byte, error)

+ func (prover *ProverPeer) RequestTransfer(tokenIDs [][]byte, shares []*token.RecipientTransferShare, ...) ([]byte, error)

+ type Signer interface

+ Sign func([]byte) ([]byte, error)

+ type SignerIdentity interface

+ Serialize func() ([]byte, error)

+ type TimeFunc func() time.Time

+ type TxEvent struct

+ CommitPeer string

+ Committed bool

+ Err error

+ Txid string

+ type TxSubmitter struct

+ Config *ClientConfig

+ Creator []byte

+ DeliverClient DeliverClient

+ OrdererClient OrdererClient

+ Signer SignerIdentity

+ func NewTxSubmitter(config *ClientConfig) (*TxSubmitter, error)

+ func (s *TxSubmitter) CreateTxEnvelope(txBytes []byte) (string, *common.Envelope, error)

+ func (s *TxSubmitter) SubmitTransaction(txEnvelope *common.Envelope, waitTimeInSeconds int) (committed bool, txId string, err error)

+ func (s *TxSubmitter) SubmitTransactionWithChan(txEnvelope *common.Envelope, eventCh chan TxEvent) (committed bool, txId string, err error)