Documentation
¶
Index ¶
- Constants
- type Broadcaster
- type Chaincode
- type 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 (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.TxIDComponents) driver.ChaincodeInvocation
- type MSPProvider
- type Manager
- type SerializableSigner
- type Services
Constants ¶
View Source
const (
DiscoveryCacheTimeout = time.Minute
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Broadcaster ¶ added in v0.4.0
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 (*Chaincode) NewDiscover ¶
func (c *Chaincode) NewDiscover() driver.ChaincodeDiscover
func (*Chaincode) NewInvocation ¶
func (c *Chaincode) NewInvocation(function string, args ...interface{}) driver.ChaincodeInvocation
type Discovery ¶
type Discovery struct {
FilterByMSPIDs []string
ImplicitCollections []string
QueryForPeers bool
// contains filtered or unexported fields
}
func NewDiscovery ¶
NewDiscovery create a discovery client that helps to fetch peer information.
Discovery results are cached. The TTL of the cached results can be set via the `ChannelConfig.DiscoveryTimeout()` of the chaincode parameter. If not set, the default `DiscoveryCacheTimeout` is used.
func (*Discovery) ChaincodeVersion ¶
func (*Discovery) GetEndorsers ¶
func (d *Discovery) GetEndorsers() ([]driver.DiscoveredPeer, 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.TxIDComponents
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 (*Invoke) WithContext ¶ added in v0.3.0
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 ¶ added in v0.2.0
func (i *Invoke) WithMatchEndorsementPolicy() driver.ChaincodeInvocation
func (*Invoke) WithNumRetries ¶ added in v0.2.0
func (i *Invoke) WithNumRetries(numRetries uint) driver.ChaincodeInvocation
func (*Invoke) WithRetrySleep ¶ added in v0.2.0
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.TxIDComponents) driver.ChaincodeInvocation
type MSPProvider ¶ added in v0.4.0
type MSPProvider interface {
MSPManager() driver.MSPManager
}
type Manager ¶ added in v0.4.0
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 ¶ added in v0.4.0
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
type SerializableSigner ¶
type Services ¶ added in v0.4.0
type Services interface {
NewPeerClient(cc grpc.ConnectionConfig) (services.PeerClient, error)
}
Click to show internal directories.
Click to hide internal directories.