chaincode

Documentation

Index

• type Broadcaster
• type Chaincode
  • func NewChaincode(name string, networkConfig driver.ConfigService, ...) *Chaincode
  • func (c *Chaincode) IsAvailable() (bool, error)
  • func (c *Chaincode) IsPrivate() bool
  • func (c *Chaincode) NewDiscover() driver.ChaincodeDiscover
  • func (c *Chaincode) NewInvocation(function string, args ...interface{}) driver.ChaincodeInvocation
  • func (c *Chaincode) Version() (string, error)
• type Discovery
  • func NewDiscovery(chaincode *Chaincode) *Discovery
  • func (d *Discovery) Call() ([]driver.DiscoveredPeer, error)
  • func (d *Discovery) ChaincodeVersion() (string, error)
  • func (d *Discovery) GetEndorsers() ([]driver.DiscoveredPeer, error)
  • func (d *Discovery) GetPeers() ([]driver.DiscoveredPeer, error)
  • func (d *Discovery) Response() (discovery.Response, error)
  • func (d *Discovery) WithFilterByMSPIDs(mspIDs ...string) driver.ChaincodeDiscover
  • func (d *Discovery) WithForQuery() driver.ChaincodeDiscover
  • func (d *Discovery) WithImplicitCollections(mspIDs ...string) driver.ChaincodeDiscover
• type Invoke
  • func NewInvoke(chaincode *Chaincode, function string, args ...interface{}) *Invoke
  • func (i *Invoke) Endorse() (driver.Envelope, error)
  • func (i *Invoke) Query() ([]byte, error)
  • func (i *Invoke) Submit() (string, []byte, error)
  • func (i *Invoke) WithContext(context context.Context) driver.ChaincodeInvocation
  • func (i *Invoke) WithDiscoveredEndorsersByEndpoints(endpoints ...string) driver.ChaincodeInvocation
  • func (i *Invoke) WithEndorsersByConnConfig(ccs ...*grpc.ConnectionConfig) driver.ChaincodeInvocation
  • func (i *Invoke) WithEndorsersByMSPIDs(mspIDs ...string) driver.ChaincodeInvocation
  • func (i *Invoke) WithEndorsersFromMyOrg() driver.ChaincodeInvocation
  • func (i *Invoke) WithImplicitCollections(mspIDs ...string) driver.ChaincodeInvocation
  • func (i *Invoke) WithMatchEndorsementPolicy() driver.ChaincodeInvocation
  • func (i *Invoke) WithNumRetries(numRetries uint) driver.ChaincodeInvocation
  • func (i *Invoke) WithRetrySleep(duration time.Duration) driver.ChaincodeInvocation
  • func (i *Invoke) WithSignerIdentity(id view.Identity) driver.ChaincodeInvocation
  • func (i *Invoke) WithTransientEntry(k string, v interface{}) (driver.ChaincodeInvocation, error)
  • func (i *Invoke) WithTxID(id driver.TxID) driver.ChaincodeInvocation
• type MSPProvider
• type Manager
  • func NewManager(networkID string, channelID string, configService driver.ConfigService, ...) *Manager
  • func (c *Manager) Chaincode(name string) driver.Chaincode
• type SerializableSigner
• type Services

Types

type Broadcaster

type Broadcaster interface {
	Broadcast(context context.Context, blob interface{}) error
}

type Chaincode

type Chaincode struct {
	NetworkID       string
	ChannelID       string
	ConfigService   driver.ConfigService
	ChannelConfig   driver.ChannelConfig
	NumRetries      uint
	RetrySleep      time.Duration
	LocalMembership driver.LocalMembership
	Services        Services
	SignerService   driver.SignerService
	Broadcaster     Broadcaster
	Finality        driver.Finality
	MSPProvider     MSPProvider
	// contains filtered or unexported fields
}

func NewChaincode

func NewChaincode(
	name string,
	networkConfig driver.ConfigService,
	channelConfig driver.ChannelConfig,
	localMembership driver.LocalMembership,
	peerManager Services,
	signerService driver.SignerService,
	broadcaster Broadcaster,
	finality driver.Finality,
	MSPProvider MSPProvider,
) *Chaincode

func (*Chaincode) IsAvailable

func (c *Chaincode) IsAvailable() (bool, error)

func (*Chaincode) IsPrivate

func (c *Chaincode) IsPrivate() bool

func (*Chaincode) NewDiscover

func (c *Chaincode) NewDiscover() driver.ChaincodeDiscover

func (*Chaincode) NewInvocation

func (c *Chaincode) NewInvocation(function string, args ...interface{}) driver.ChaincodeInvocation

func (*Chaincode) Version

func (c *Chaincode) Version() (string, error)

Version returns the version of this chaincode. It uses discovery to extract this information from the endorsers

type Discovery

type Discovery struct {
	FilterByMSPIDs      []string
	ImplicitCollections []string
	QueryForPeers       bool

	DefaultTTL time.Duration
	// contains filtered or unexported fields
}

func NewDiscovery

func NewDiscovery(chaincode *Chaincode) *Discovery

func (*Discovery) Call

func (d *Discovery) Call() ([]driver.DiscoveredPeer, error)

func (*Discovery) ChaincodeVersion

func (d *Discovery) ChaincodeVersion() (string, error)

func (*Discovery) GetEndorsers

func (d *Discovery) GetEndorsers() ([]driver.DiscoveredPeer, error)

func (*Discovery) GetPeers

func (d *Discovery) GetPeers() ([]driver.DiscoveredPeer, error)

func (*Discovery) Response

func (d *Discovery) Response() (discovery.Response, error)

func (*Discovery) WithFilterByMSPIDs

func (d *Discovery) WithFilterByMSPIDs(mspIDs ...string) driver.ChaincodeDiscover

func (*Discovery) WithForQuery

func (d *Discovery) WithForQuery() driver.ChaincodeDiscover

func (*Discovery) WithImplicitCollections

func (d *Discovery) WithImplicitCollections(mspIDs ...string) driver.ChaincodeDiscover

type Invoke

type Invoke struct {
	Chaincode                      *Chaincode
	TxID                           driver.TxID
	SignerIdentity                 view.Identity
	ChaincodePath                  string
	ChaincodeName                  string
	ChaincodeVersion               string
	TransientMap                   map[string][]byte
	EndorsersMSPIDs                []string
	ImplicitCollectionMSPIDs       []string
	EndorsersFromMyOrg             bool
	EndorsersByConnConfig          []*grpc.ConnectionConfig
	DiscoveredEndorsersByEndpoints []string
	Function                       string
	Args                           []interface{}
	MatchEndorsementPolicy         bool
	NumRetries                     int
	RetrySleep                     time.Duration
	Context                        context.Context
}

func NewInvoke

func NewInvoke(chaincode *Chaincode, function string, args ...interface{}) *Invoke

func (*Invoke) Endorse

func (i *Invoke) Endorse() (driver.Envelope, error)

func (*Invoke) Query

func (i *Invoke) Query() ([]byte, error)

func (*Invoke) Submit

func (i *Invoke) Submit() (string, []byte, error)

func (*Invoke) WithContext

func (i *Invoke) WithContext(context context.Context) driver.ChaincodeInvocation

func (*Invoke) WithDiscoveredEndorsersByEndpoints

func (i *Invoke) WithDiscoveredEndorsersByEndpoints(endpoints ...string) driver.ChaincodeInvocation

WithDiscoveredEndorsersByEndpoints sets the endpoints to be used to filter the result of discovery. Discovery is used to identify the chaincode's endorsers, if not set otherwise.

func (*Invoke) WithEndorsersByConnConfig

func (i *Invoke) WithEndorsersByConnConfig(ccs ...*grpc.ConnectionConfig) driver.ChaincodeInvocation

func (*Invoke) WithEndorsersByMSPIDs

func (i *Invoke) WithEndorsersByMSPIDs(mspIDs ...string) driver.ChaincodeInvocation

func (*Invoke) WithEndorsersFromMyOrg

func (i *Invoke) WithEndorsersFromMyOrg() driver.ChaincodeInvocation

func (*Invoke) WithImplicitCollections

func (i *Invoke) WithImplicitCollections(mspIDs ...string) driver.ChaincodeInvocation

func (*Invoke) WithMatchEndorsementPolicy

func (i *Invoke) WithMatchEndorsementPolicy() driver.ChaincodeInvocation

func (*Invoke) WithNumRetries

func (i *Invoke) WithNumRetries(numRetries uint) driver.ChaincodeInvocation

func (*Invoke) WithRetrySleep

func (i *Invoke) WithRetrySleep(duration time.Duration) driver.ChaincodeInvocation

func (*Invoke) WithSignerIdentity

func (i *Invoke) WithSignerIdentity(id view.Identity) driver.ChaincodeInvocation

func (*Invoke) WithTransientEntry

func (i *Invoke) WithTransientEntry(k string, v interface{}) (driver.ChaincodeInvocation, error)

func (*Invoke) WithTxID

func (i *Invoke) WithTxID(id driver.TxID) driver.ChaincodeInvocation

type MSPProvider

type MSPProvider interface {
	MSPManager() driver.MSPManager
}

type Manager

type Manager struct {
	NetworkID       string
	ChannelID       string
	ConfigService   driver.ConfigService
	ChannelConfig   driver.ChannelConfig
	NumRetries      uint
	RetrySleep      time.Duration
	LocalMembership driver.LocalMembership
	PeerManager     Services
	SignerService   driver.SignerService
	Broadcaster     Broadcaster
	Finality        driver.Finality
	MSPProvider     MSPProvider

	// chaincodes
	ChaincodesLock sync.RWMutex
	Chaincodes     map[string]driver.Chaincode
}

func NewManager

func NewManager(
	networkID string,
	channelID string,
	configService driver.ConfigService,
	channelConfig driver.ChannelConfig,
	numRetries uint,
	retrySleep time.Duration,
	localMembership driver.LocalMembership,
	peerManager Services,
	signerService driver.SignerService,
	broadcaster Broadcaster,
	finality driver.Finality,
	MSPProvider MSPProvider,
) *Manager

func (*Manager) Chaincode

func (c *Manager) Chaincode(name string) driver.Chaincode

Chaincode returns a chaincode handler for the passed chaincode name

type SerializableSigner

type SerializableSigner interface {
	Sign(message []byte) ([]byte, error)

	Serialize() ([]byte, error)
}

type Services

type Services interface {
	NewPeerClient(cc grpc.ConnectionConfig) (services.PeerClient, error)
}