Documentation
¶
Index ¶
- func GetNamespaceFromSubName(subName string) string
- func HandleReceipt(ctx context.Context, plugin core.Named, reply *BlockchainReceiptNotification, ...) error
- type BatchPinParams
- type BlockchainCallbacks
- type BlockchainReceiptHeaders
- type BlockchainReceiptNotification
- type FireflySubscriptions
- type SubscriptionInfo
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetNamespaceFromSubName ¶
func HandleReceipt ¶ added in v1.1.3
func HandleReceipt(ctx context.Context, plugin core.Named, reply *BlockchainReceiptNotification, callbacks BlockchainCallbacks) error
Common function for handling receipts from blockchain connectors.
Types ¶
type BatchPinParams ¶
type BlockchainCallbacks ¶
type BlockchainCallbacks interface {
SetHandler(namespace string, handler blockchain.Callbacks)
SetOperationalHandler(namespace string, handler core.OperationCallbacks)
OperationUpdate(ctx context.Context, plugin core.Named, nsOpID string, status core.OpStatus, blockchainTXID, errorMessage string, opOutput fftypes.JSONObject)
BatchPinOrNetworkAction(ctx context.Context, subInfo *SubscriptionInfo, location *fftypes.JSONAny, event *blockchain.Event, signingKey *core.VerifierRef, params *BatchPinParams) error
BlockchainEvent(ctx context.Context, namespace string, event *blockchain.EventWithSubscription) error
}
func NewBlockchainCallbacks ¶
func NewBlockchainCallbacks() BlockchainCallbacks
type BlockchainReceiptHeaders ¶ added in v1.1.3
type BlockchainReceiptNotification ¶ added in v1.1.3
type BlockchainReceiptNotification struct {
Headers BlockchainReceiptHeaders `json:"headers,omitempty"`
TxHash string `json:"transactionHash,omitempty"`
Message string `json:"errorMessage,omitempty"`
ProtocolID string `json:"protocolId,omitempty"`
ContractLocation *fftypes.JSONAny `json:"contractLocation,omitempty"`
}
type FireflySubscriptions ¶
type FireflySubscriptions interface {
AddSubscription(ctx context.Context, namespace *core.Namespace, version int, subID string, extra interface{})
RemoveSubscription(ctx context.Context, subID string)
GetSubscription(subID string) *SubscriptionInfo
}
func NewFireflySubscriptions ¶
func NewFireflySubscriptions() FireflySubscriptions
type SubscriptionInfo ¶
type SubscriptionInfo struct {
Version int
V1Namespace map[string][]string
V2Namespace string
Extra interface{}
}
A single subscription on network version 1 may receive events from many remote namespaces, which in turn map to one or more local namespaces. A subscription on network version 2 is always specific to a single local namespace.
Click to show internal directories.
Click to hide internal directories.