core

package

Go to main page

Versions in this module

v1

v1.3.0

Apr 25, 2024

Changes in this version

+ const DeployContract

+ const SystemTagGapFill

+ var MessageStateCancelled = fftypes.FFEnumValue("messagestate", "cancelled")

+ var MessageTypeDeprecatedApprovalBroadcast = fftypes.FFEnumValue("messagetype", "approval_broadcast")

+ var MessageTypeDeprecatedApprovalPrivate = fftypes.FFEnumValue("messagetype", "approval_private")

+ var MessageTypeDeprecatedTransferBroadcast = fftypes.FFEnumValue("messagetype", "transfer_broadcast")

+ var MessageTypeDeprecatedTransferPrivate = fftypes.FFEnumValue("messagetype", "transfer_private")

+ var TransactionTypeContractInvokePin = fftypes.FFEnumValue("txtype", "contract_invoke_pin")

+ var VerifierTypeTezosAddress = fftypes.FFEnumValue("verifiertype", "tezos_address")

+ var WSEventBatchType = fftypes.FFEnumValue("wstype", "event_batch")

+ func IsPinned(t TransactionType) bool

type BlobRef

+ Path string

+ type CombinedEventDataDelivery struct

+ Data DataArray

+ Event *EventDelivery

type ContractAPI

+ NetworkName string

+ Published bool

type ContractCallRequest

+ Message *MessageInOut

type ContractURLs

+ API string

type Data

+ func (d *Data) CalcPath()

+ type DefinitionPublish struct

+ NetworkName string

type Message

+ RejectReason string

+ TransactionID *fftypes.UUID

+ type MessageAction int

+ const ActionConfirm

+ const ActionReject

+ const ActionRetry

+ const ActionWait

+ func (dma MessageAction) String() string

type MessageHeader

+ TxParent *TransactionRef

type Namespace

+ TLSConfigs map[string]*tls.Config

+ type NamespaceWithInitStatus struct

+ InitializationError string

+ Initializing bool

+ type OpPhase int

+ const OpPhaseComplete

+ const OpPhaseInitializing

+ const OpPhasePending

type OpStatus

+ const OpStatusInitialized

type SubscriptionCoreOptions

+ Batch *bool

+ BatchTimeout *string

type TokenPool

+ Active bool

+ NetworkName string

+ PluginData string

+ Published bool

+ type TokenPoolDefinition struct

+ Pool *TokenPool

+ func (t *TokenPoolDefinition) SetBroadcastMessage(msgID *fftypes.UUID)

+ func (t *TokenPoolDefinition) Topic() string

+ type WSEventBatch struct

+ Events []*EventDelivery

+ ID *fftypes.UUID

+ Subscription SubscriptionRef

+ Type WSClientPayloadType

type WSSubscriptionStatus

+ Filter SubscriptionFilter

+ StartTime *fftypes.FFTime

+ type WebhookHTTPOptions struct

+ HTTPConnectionTimeout string

+ HTTPExpectContinueTimeout string

+ HTTPIdleConnTimeout string

+ HTTPMaxIdleConns int

+ HTTPProxyURL *string

+ HTTPRequestTimeout string

+ HTTPTLSHandshakeTimeout string

+ type WebhookRetryOptions struct

+ Count int

+ Enabled bool

+ InitialDelay string

+ MaximumDelay string

type WebhookSubOptions

+ HTTPOptions WebhookHTTPOptions

+ RestyClient *resty.Client

+ Retry WebhookRetryOptions

+ TLSConfig *tls.Config

+ TLSConfigName string

v1.3.0-rc.2

Apr 12, 2024

v1.3.0-rc.1

Mar 4, 2024

v1.2.2

Jul 27, 2023

v1.2.1

Jul 11, 2023

v1.2.0

Feb 5, 2023

Changes in this version

type Blob

+ DataID *fftypes.UUID

+ Namespace string

+ type OperationDetailError struct

+ StatusError string

+ type OperationWithDetail struct

+ Detail interface{}

v1.2.0-rc.4

Feb 3, 2023

v1.2.0-rc.3

Feb 2, 2023

v1.2.0-rc.2

Feb 1, 2023

v1.2.0-rc.1

Jan 30, 2023

v1.2.0-alpha.1

Jan 20, 2023

v1.2.0-2023-04-17-002

Apr 17, 2023

v1.1.4

Apr 17, 2023

v1.1.3

Jan 6, 2023

Changes in this version

+ var MessageTypeApprovalBroadcast = fftypes.FFEnumValue("messagetype", "approval_broadcast")

+ var MessageTypeApprovalPrivate = fftypes.FFEnumValue("messagetype", "approval_private")

+ var TokenInterfaceFormatABI = fftypes.FFEnumValue("tokeninterfaceformat", "abi")

+ var TokenInterfaceFormatFFI = fftypes.FFEnumValue("tokeninterfaceformat", "ffi")

type ContractCallRequest

+ Errors []*fftypes.FFIError

type Operation

+ func (op *Operation) IsBlockchainOperation() bool

+ func (op *Operation) IsTokenOperation() bool

+ type OperationDetailedStatusError struct

+ StatusError string

+ type OperationWithDetailedStatus struct

+ DetailedStatus interface{}

type TokenApproval

+ Message *fftypes.UUID

+ MessageHash *fftypes.Bytes32

type TokenApprovalInput

+ Message *MessageInOut

+ type TokenInterfaceFormat = fftypes.FFEnum

type TokenPool

+ Interface *fftypes.FFIReference

+ InterfaceFormat TokenInterfaceFormat

+ Methods *fftypes.JSONAny

v1.1.2

Nov 18, 2022

Changes in this version

+ var EventTypeBlockchainContractDeployOpFailed = fftypes.FFEnumValue("eventtype", "blockchain_contract_deploy_op_failed")

+ var EventTypeBlockchainContractDeployOpSucceeded = fftypes.FFEnumValue("eventtype", "blockchain_contract_deploy_op_succeeded")

+ var OpTypeBlockchainContractDeploy = fftypes.FFEnumValue("optype", "blockchain_deploy")

+ var TransactionTypeContractDeploy = fftypes.FFEnumValue("txtype", "contract_deploy")

type ContractCallRequest

+ IdempotencyKey IdempotencyKey

+ type ContractDeployRequest struct

+ Contract *fftypes.JSONAny

+ Definition *fftypes.JSONAny

+ IdempotencyKey IdempotencyKey

+ Input []interface{}

+ Key string

+ Options map[string]interface{}

+ type IdempotencyKey string

+ func (ik *IdempotencyKey) Scan(src interface{}) error

+ func (ik IdempotencyKey) Value() (driver.Value, error)

type Message

+ IdempotencyKey IdempotencyKey

+ type PublishInput struct

+ IdempotencyKey IdempotencyKey

type TokenApprovalInput

+ IdempotencyKey IdempotencyKey

+ type TokenPoolInput struct

+ IdempotencyKey IdempotencyKey

type TokenTransferInput

+ IdempotencyKey IdempotencyKey

type Transaction

+ IdempotencyKey IdempotencyKey

v1.1.1

Oct 5, 2022

v1.1.0

Sep 12, 2022

Changes in this version

+ const ChartHistogramMaxBuckets

+ const ChartHistogramMinBuckets

+ const DIDPrefix

+ const DefaultTopic

+ const DeprecatedSystemTagDefineNode

+ const DeprecatedSystemTagDefineOrganization

+ const FFStringArrayStandardMax

+ const FFStringNameItemsMax

+ const FireFlyCustomDIDPrefix

+ const FireFlyDIDPrefix

+ const FireFlyNodeDIDPrefix

+ const FireFlyOrgDIDPrefix

+ const HTTPHeadersBlobHashSHA256

+ const HTTPHeadersBlobSize

+ const LegacySystemNamespace

+ const ManifestVersion1

+ const ManifestVersionUnset

+ const SystemBatchPinTopic

+ const SystemTagDefineContractAPI

+ const SystemTagDefineDatatype

+ const SystemTagDefineFFI

+ const SystemTagDefineGroup

+ const SystemTagDefinePool

+ const SystemTagIdentityClaim

+ const SystemTagIdentityUpdate

+ const SystemTagIdentityVerification

+ const SystemTopicDefinitions

+ var BatchTypeBroadcast = fftypes.FFEnumValue("batchtype", "broadcast")

+ var BatchTypePrivate = fftypes.FFEnumValue("batchtype", "private")

+ var CallTypeInvoke = fftypes.FFEnumValue("contractcalltype", "invoke")

+ var CallTypeQuery = fftypes.FFEnumValue("contractcalltype", "query")

+ var EventTypeApprovalConfirmed = fftypes.FFEnumValue("eventtype", "token_approval_confirmed")

+ var EventTypeApprovalOpFailed = fftypes.FFEnumValue("eventtype", "token_approval_op_failed")

+ var EventTypeBlockchainEventReceived = fftypes.FFEnumValue("eventtype", "blockchain_event_received")

+ var EventTypeBlockchainInvokeOpFailed = fftypes.FFEnumValue("eventtype", "blockchain_invoke_op_failed")

+ var EventTypeBlockchainInvokeOpSucceeded = fftypes.FFEnumValue("eventtype", "blockchain_invoke_op_succeeded")

+ var EventTypeContractAPIConfirmed = fftypes.FFEnumValue("eventtype", "contract_api_confirmed")

+ var EventTypeContractInterfaceConfirmed = fftypes.FFEnumValue("eventtype", "contract_interface_confirmed")

+ var EventTypeDatatypeConfirmed = fftypes.FFEnumValue("eventtype", "datatype_confirmed")

+ var EventTypeIdentityConfirmed = fftypes.FFEnumValue("eventtype", "identity_confirmed")

+ var EventTypeIdentityUpdated = fftypes.FFEnumValue("eventtype", "identity_updated")

+ var EventTypeMessageConfirmed = fftypes.FFEnumValue("eventtype", "message_confirmed")

+ var EventTypeMessageRejected = fftypes.FFEnumValue("eventtype", "message_rejected")

+ var EventTypePoolConfirmed = fftypes.FFEnumValue("eventtype", "token_pool_confirmed")

+ var EventTypePoolOpFailed = fftypes.FFEnumValue("eventtype", "token_pool_op_failed")

+ var EventTypeTransactionSubmitted = fftypes.FFEnumValue("eventtype", "transaction_submitted")

+ var EventTypeTransferConfirmed = fftypes.FFEnumValue("eventtype", "token_transfer_confirmed")

+ var EventTypeTransferOpFailed = fftypes.FFEnumValue("eventtype", "token_transfer_op_failed")

+ var IdentityTypeCustom = fftypes.FFEnumValue("identitytype", "custom")

+ var IdentityTypeNode = fftypes.FFEnumValue("identitytype", "node")

+ var IdentityTypeOrg = fftypes.FFEnumValue("identitytype", "org")

+ var MessageStateConfirmed = fftypes.FFEnumValue("messagestate", "confirmed")

+ var MessageStatePending = fftypes.FFEnumValue("messagestate", "pending")

+ var MessageStateReady = fftypes.FFEnumValue("messagestate", "ready")

+ var MessageStateRejected = fftypes.FFEnumValue("messagestate", "rejected")

+ var MessageStateSent = fftypes.FFEnumValue("messagestate", "sent")

+ var MessageStateStaged = fftypes.FFEnumValue("messagestate", "staged")

+ var MessageTypeBroadcast = fftypes.FFEnumValue("messagetype", "broadcast")

+ var MessageTypeDefinition = fftypes.FFEnumValue("messagetype", "definition")

+ var MessageTypeGroupInit = fftypes.FFEnumValue("messagetype", "groupinit")

+ var MessageTypePrivate = fftypes.FFEnumValue("messagetype", "private")

+ var MessageTypeTransferBroadcast = fftypes.FFEnumValue("messagetype", "transfer_broadcast")

+ var MessageTypeTransferPrivate = fftypes.FFEnumValue("messagetype", "transfer_private")

+ var NetworkActionTerminate = fftypes.FFEnumValue("networkactiontype", "terminate")

+ var OffsetTypeAggregator = fftypes.FFEnumValue("offsettype", "aggregator")

+ var OffsetTypeBatch = fftypes.FFEnumValue("offsettype", "batch")

+ var OffsetTypeSubscription = fftypes.FFEnumValue("offsettype", "subscription")

+ var OpTypeBlockchainInvoke = fftypes.FFEnumValue("optype", "blockchain_invoke")

+ var OpTypeBlockchainNetworkAction = fftypes.FFEnumValue("optype", "blockchain_network_action")

+ var OpTypeBlockchainPinBatch = fftypes.FFEnumValue("optype", "blockchain_pin_batch")

+ var OpTypeDataExchangeSendBatch = fftypes.FFEnumValue("optype", "dataexchange_send_batch")

+ var OpTypeDataExchangeSendBlob = fftypes.FFEnumValue("optype", "dataexchange_send_blob")

+ var OpTypeSharedStorageDownloadBatch = fftypes.FFEnumValue("optype", "sharedstorage_download_batch")

+ var OpTypeSharedStorageDownloadBlob = fftypes.FFEnumValue("optype", "sharedstorage_download_blob")

+ var OpTypeSharedStorageUploadBatch = fftypes.FFEnumValue("optype", "sharedstorage_upload_batch")

+ var OpTypeSharedStorageUploadBlob = fftypes.FFEnumValue("optype", "sharedstorage_upload_blob")

+ var OpTypeSharedStorageUploadValue = fftypes.FFEnumValue("optype", "sharedstorage_upload_value")

+ var OpTypeTokenActivatePool = fftypes.FFEnumValue("optype", "token_activate_pool")

+ var OpTypeTokenApproval = fftypes.FFEnumValue("optype", "token_approval")

+ var OpTypeTokenCreatePool = fftypes.FFEnumValue("optype", "token_create_pool")

+ var OpTypeTokenTransfer = fftypes.FFEnumValue("optype", "token_transfer")

+ var TokenPoolStateConfirmed = fftypes.FFEnumValue("tokenpoolstate", "confirmed")

+ var TokenPoolStatePending = fftypes.FFEnumValue("tokenpoolstate", "pending")

+ var TokenPoolStateUnknown = fftypes.FFEnumValue("tokenpoolstate", "unknown")

+ var TokenTransferTypeBurn = fftypes.FFEnumValue("tokentransfertype", "burn")

+ var TokenTransferTypeMint = fftypes.FFEnumValue("tokentransfertype", "mint")

+ var TokenTransferTypeTransfer = fftypes.FFEnumValue("tokentransfertype", "transfer")

+ var TokenTypeFungible = fftypes.FFEnumValue("tokentype", "fungible")

+ var TokenTypeNonFungible = fftypes.FFEnumValue("tokentype", "nonfungible")

+ var TransactionTypeBatchPin = fftypes.FFEnumValue("txtype", "batch_pin")

+ var TransactionTypeContractInvoke = fftypes.FFEnumValue("txtype", "contract_invoke")

+ var TransactionTypeDataPublish = fftypes.FFEnumValue("txtype", "data_publish")

+ var TransactionTypeNetworkAction = fftypes.FFEnumValue("txtype", "network_action")

+ var TransactionTypeNone = fftypes.FFEnumValue("txtype", "none")

+ var TransactionTypeTokenApproval = fftypes.FFEnumValue("txtype", "token_approval")

+ var TransactionTypeTokenPool = fftypes.FFEnumValue("txtype", "token_pool")

+ var TransactionTypeTokenTransfer = fftypes.FFEnumValue("txtype", "token_transfer")

+ var TransactionTypeUnpinned = fftypes.FFEnumValue("txtype", "unpinned")

+ var TransportPayloadTypeBatch = fftypes.FFEnumValue("transportpayload", "batch")

+ var TransportPayloadTypeMessage = fftypes.FFEnumValue("transportpayload", "message")

+ var ValidatorTypeJSON = fftypes.FFEnumValue("validatortype", "json")

+ var ValidatorTypeNone = fftypes.FFEnumValue("validatortype", "none")

+ var ValidatorTypeSystemDefinition = fftypes.FFEnumValue("validatortype", "definition")

+ var VerifierTypeEthAddress = fftypes.FFEnumValue("verifiertype", "ethereum_address")

+ var VerifierTypeFFDXPeerID = fftypes.FFEnumValue("verifiertype", "dx_peer_id")

+ var VerifierTypeMSPIdentity = fftypes.FFEnumValue("verifiertype", "fabric_msp_id")

+ var WSChangeEventCommandTypeStart = fftypes.FFEnumValue("changeevent_cmd_type", "start")

+ var WSClientActionAck = fftypes.FFEnumValue("wstype", "ack")

+ var WSClientActionStart = fftypes.FFEnumValue("wstype", "start")

+ var WSProtocolErrorEventType = fftypes.FFEnumValue("wstype", "protocol_error")

+ func CheckValidatorType(ctx context.Context, validator ValidatorType) error

+ func ParseNamespacedOpID(ctx context.Context, nsIDStr string) (string, *fftypes.UUID, error)

+ func TokenBalanceIdentifier(pool *fftypes.UUID, tokenIndex, identity string) string

+ type Authorizer interface

+ Authorize func(ctx context.Context, authReq *fftypes.AuthReq) error

+ type Batch struct

+ Hash *fftypes.Bytes32

+ Payload BatchPayload

+ func (b *Batch) Confirmed() (*BatchPersisted, *BatchManifest)

+ type BatchHeader struct

+ Created *fftypes.FFTime

+ Group *fftypes.Bytes32

+ ID *fftypes.UUID

+ Namespace string

+ Node *fftypes.UUID

+ Type BatchType

+ type BatchManifest struct

+ Data DataRefs

+ ID *fftypes.UUID

+ Messages []*MessageManifestEntry

+ TX TransactionRef

+ Version uint

+ func (bm *BatchManifest) String() string

+ type BatchPayload struct

+ Data DataArray

+ Messages []*Message

+ TX TransactionRef

+ func (ma *BatchPayload) Hash() *fftypes.Bytes32

+ func (ma *BatchPayload) Manifest(id *fftypes.UUID) *BatchManifest

+ type BatchPersisted struct

+ Confirmed *fftypes.FFTime

+ Hash *fftypes.Bytes32

+ Manifest *fftypes.JSONAny

+ TX TransactionRef

+ func (b *BatchPersisted) GenInflight(messages []*Message, data DataArray) *Batch

+ func (b *BatchPersisted) GenManifest(messages []*Message, data DataArray) *BatchManifest

+ type BatchState struct

+ ConfirmedDIDClaims []string

+ Finalize []func(ctx context.Context) error

+ PendingConfirms map[fftypes.UUID]*Message

+ PreFinalize []func(ctx context.Context) error

+ func (bs *BatchState) AddConfirmedDIDClaim(did string)

+ func (bs *BatchState) AddFinalize(action func(ctx context.Context) error)

+ func (bs *BatchState) AddPendingConfirm(id *fftypes.UUID, message *Message)

+ func (bs *BatchState) AddPreFinalize(action func(ctx context.Context) error)

+ func (bs *BatchState) RunFinalize(ctx context.Context) error

+ func (bs *BatchState) RunPreFinalize(ctx context.Context) error

+ type BatchType = fftypes.FFEnum

+ type Blob struct

+ Created *fftypes.FFTime

+ Hash *fftypes.Bytes32

+ PayloadRef string

+ Peer string

+ Sequence int64

+ Size int64

+ type BlobRef struct

+ Hash *fftypes.Bytes32

+ Name string

+ Public string

+ Size int64

+ func (br *BlobRef) BatchBlobRef(batchType BatchType) *BlobRef

+ type BlockchainEvent struct

+ ID *fftypes.UUID

+ Info fftypes.JSONObject

+ Listener *fftypes.UUID

+ Name string

+ Namespace string

+ Output fftypes.JSONObject

+ ProtocolID string

+ Source string

+ TX BlockchainTransactionRef

+ Timestamp *fftypes.FFTime

+ type BlockchainEventFilter struct

+ Listener string

+ Name string

+ type BlockchainTransactionRef struct

+ BlockchainID string

+ ID *fftypes.UUID

+ Type TransactionType

+ type ChangeEvent struct

+ Collection string

+ DroppedCount int64

+ DroppedSince *fftypes.FFTime

+ Hash *fftypes.Bytes32

+ ID *fftypes.UUID

+ Namespace string

+ Sequence *int64

+ Type ChangeEventType

+ type ChangeEventFilter struct

+ Namespaces []string

+ Types []ChangeEventType

+ type ChangeEventType string

+ const ChangeEventTypeCreated

+ const ChangeEventTypeDeleted

+ const ChangeEventTypeDropped

+ const ChangeEventTypeUpdated

+ type ChartHistogram struct

+ Count string

+ IsCapped bool

+ Timestamp *fftypes.FFTime

+ Types []*ChartHistogramType

+ type ChartHistogramInterval struct

+ EndTime *fftypes.FFTime

+ StartTime *fftypes.FFTime

+ type ChartHistogramType struct

+ Count string

+ Type string

+ type ContractAPI struct

+ ID *fftypes.UUID

+ Interface *fftypes.FFIReference

+ Location *fftypes.JSONAny

+ Message *fftypes.UUID

+ Name string

+ Namespace string

+ URLs ContractURLs

+ func (c *ContractAPI) LocationAndLedgerEquals(a *ContractAPI) bool

+ func (c *ContractAPI) SetBroadcastMessage(msgID *fftypes.UUID)

+ func (c *ContractAPI) Topic() string

+ func (c *ContractAPI) Validate(ctx context.Context, existing bool) (err error)

+ type ContractCallRequest struct

+ Input map[string]interface{}

+ Interface *fftypes.UUID

+ Key string

+ Location *fftypes.JSONAny

+ Method *fftypes.FFIMethod

+ MethodPath string

+ Options map[string]interface{}

+ Type ContractCallType

+ type ContractCallType = fftypes.FFEnum

+ type ContractListener struct

+ BackendID string

+ Created *fftypes.FFTime

+ Event *FFISerializedEvent

+ ID *fftypes.UUID

+ Interface *fftypes.FFIReference

+ Location *fftypes.JSONAny

+ Name string

+ Namespace string

+ Options *ContractListenerOptions

+ Signature string

+ Topic string

+ type ContractListenerInput struct

+ EventPath string

+ type ContractListenerOptions struct

+ FirstEvent string

+ func (o *ContractListenerOptions) Scan(src interface{}) error

+ func (o ContractListenerOptions) Value() (driver.Value, error)

+ type ContractListenerWithStatus struct

+ Status interface{}

+ type ContractURLs struct

+ OpenAPI string

+ UI string

+ type Data struct

+ Blob *BlobRef

+ Created *fftypes.FFTime

+ Datatype *DatatypeRef

+ Hash *fftypes.Bytes32

+ ID *fftypes.UUID

+ Namespace string

+ Public string

+ Validator ValidatorType

+ Value *fftypes.JSONAny

+ ValueSize int64

+ func (d *Data) BatchData(batchType BatchType) *Data

+ func (d *Data) CalcHash(ctx context.Context) (*fftypes.Bytes32, error)

+ func (d *Data) EstimateSize() int64

+ func (d *Data) Seal(ctx context.Context, blob *Blob) (err error)

+ type DataAndBlob struct

+ Blob *Blob

+ Data *Data

+ type DataArray []*Data

+ func (da DataArray) Refs() DataRefs

+ type DataRef struct

+ Hash *fftypes.Bytes32

+ ID *fftypes.UUID

+ ValueSize int64

+ type DataRefOrValue struct

+ Blob *BlobRef

+ Datatype *DatatypeRef

+ Validator ValidatorType

+ Value *fftypes.JSONAny

+ type DataRefs []*DataRef

+ func (d DataRefs) Hash() *fftypes.Bytes32

+ type Datatype struct

+ Created *fftypes.FFTime

+ Hash *fftypes.Bytes32

+ ID *fftypes.UUID

+ Message *fftypes.UUID

+ Name string

+ Namespace string

+ Validator ValidatorType

+ Value *fftypes.JSONAny

+ Version string

+ func (dt *Datatype) SetBroadcastMessage(msgID *fftypes.UUID)

+ func (dt *Datatype) Topic() string

+ func (dt *Datatype) Validate(ctx context.Context, existing bool) (err error)

+ type DatatypeRef struct

+ Name string

+ Version string

+ func (dr *DatatypeRef) String() string

+ type Definition interface

+ SetBroadcastMessage func(msgID *fftypes.UUID)

+ Topic func() string

+ type DeprecatedDXInfo struct

+ Endpoint fftypes.JSONObject

+ Peer string

+ type DeprecatedNode struct

+ Created *fftypes.FFTime

+ DX DeprecatedDXInfo

+ Description string

+ ID *fftypes.UUID

+ Message *fftypes.UUID

+ Name string

+ Owner string

+ func (node *DeprecatedNode) AddMigratedParent(parentID *fftypes.UUID) *IdentityClaim

+ func (node *DeprecatedNode) Migrated() *IdentityClaim

+ func (node *DeprecatedNode) SetBroadcastMessage(msgID *fftypes.UUID)

+ func (node *DeprecatedNode) Topic() string

+ type DeprecatedOrganization struct

+ Created *fftypes.FFTime

+ Description string

+ ID *fftypes.UUID

+ Identity string

+ Message *fftypes.UUID

+ Name string

+ Parent string

+ Profile fftypes.JSONObject

+ func (org *DeprecatedOrganization) Migrated() *IdentityClaim

+ func (org *DeprecatedOrganization) SetBroadcastMessage(msgID *fftypes.UUID)

+ func (org *DeprecatedOrganization) Topic() string

+ type EmptyInput map[string]interface

+ type EnrichedEvent struct

+ BlockchainEvent *BlockchainEvent

+ ContractAPI *ContractAPI

+ ContractInterface *fftypes.FFI

+ Datatype *Datatype

+ Identity *Identity

+ Message *Message

+ Operation *Operation

+ TokenApproval *TokenApproval

+ TokenPool *TokenPool

+ TokenTransfer *TokenTransfer

+ Transaction *Transaction

+ type Event struct

+ Correlator *fftypes.UUID

+ Created *fftypes.FFTime

+ ID *fftypes.UUID

+ Namespace string

+ Reference *fftypes.UUID

+ Sequence int64

+ Topic string

+ Transaction *fftypes.UUID

+ Type EventType

+ func NewEvent(t EventType, ns string, ref *fftypes.UUID, tx *fftypes.UUID, topic string) *Event

+ func (e *Event) LocalSequence() int64

+ type EventDelivery struct

+ Subscription SubscriptionRef

+ type EventDeliveryResponse struct

+ ID *fftypes.UUID

+ Info string

+ Rejected bool

+ Reply *MessageInOut

+ Subscription SubscriptionRef

+ type EventType = fftypes.FFEnum

+ type FFISerializedEvent struct

+ func (fse *FFISerializedEvent) Scan(src interface{}) error

+ func (fse FFISerializedEvent) Value() (driver.Value, error)

+ type FFStringArray []string

+ func NewFFStringArray(initialContent ...string) FFStringArray

+ func (sa *FFStringArray) Scan(src interface{}) error

+ func (sa FFStringArray) AddToSortedSet(newValues ...string) (res FFStringArray, changed bool)

+ func (sa FFStringArray) String() string

+ func (sa FFStringArray) Validate(ctx context.Context, fieldName string, isName bool, maxItems int) error

+ func (sa FFStringArray) Value() (driver.Value, error)

+ type Group struct

+ Created *fftypes.FFTime

+ Hash *fftypes.Bytes32

+ LocalNamespace string

+ Message *fftypes.UUID

+ func (group *Group) Seal()

+ func (group *Group) SetBroadcastMessage(msgID *fftypes.UUID)

+ func (group *Group) Topic() string

+ func (group *Group) Validate(ctx context.Context, existing bool) (err error)

+ type GroupIdentity struct

+ Members Members

+ Name string

+ Namespace string

+ func (man *GroupIdentity) Hash() *fftypes.Bytes32

+ type IDAndSequence struct

+ ID fftypes.UUID

+ Sequence int64

+ type Identity struct

+ Created *fftypes.FFTime

+ Messages IdentityMessages

+ Updated *fftypes.FFTime

+ func (identity *Identity) Validate(ctx context.Context) (err error)

+ type IdentityBase struct

+ DID string

+ ID *fftypes.UUID

+ Name string

+ Namespace string

+ Parent *fftypes.UUID

+ Type IdentityType

+ func (i *IdentityBase) Equals(ctx context.Context, i2 *IdentityBase) bool

+ func (i *IdentityBase) GenerateDID(ctx context.Context) (string, error)

+ func (i *IdentityBase) Topic() string

+ func (i *IdentityBase) Validate(ctx context.Context) (err error)

+ type IdentityClaim struct

+ Identity *Identity

+ func (ic *IdentityClaim) SetBroadcastMessage(msgID *fftypes.UUID)

+ func (ic *IdentityClaim) Topic() string

+ type IdentityCreateDTO struct

+ Key string

+ Name string

+ Parent string

+ Type IdentityType

+ type IdentityMessages struct

+ Claim *fftypes.UUID

+ Update *fftypes.UUID

+ Verification *fftypes.UUID

+ type IdentityProfile struct

+ Description string

+ Profile fftypes.JSONObject

+ type IdentityType = fftypes.FFEnum

+ type IdentityUpdate struct

+ Identity IdentityBase

+ Updates IdentityProfile

+ func (iu *IdentityUpdate) SetBroadcastMessage(msgID *fftypes.UUID)

+ func (iu *IdentityUpdate) Topic() string

+ type IdentityUpdateDTO struct

+ type IdentityVerification struct

+ Claim MessageRef

+ Identity IdentityBase

+ func (iv *IdentityVerification) SetBroadcastMessage(msgID *fftypes.UUID)

+ func (iv *IdentityVerification) Topic() string

+ type IdentityWithVerifiers struct

+ Verifiers []*VerifierRef

+ type InlineData []*DataRefOrValue

+ type InputGroup struct

+ Members []MemberInput

+ Name string

+ type ListenerStatusError struct

+ StatusError string

+ type LocallySequenced interface

+ LocalSequence func() int64

+ type Member struct

+ Identity string

+ Node *fftypes.UUID

+ func (m *Member) Equals(m2 *Member) bool

+ type MemberInput struct

+ Identity string

+ Node string

+ type Members []*Member

+ func (m Members) Len() int

+ func (m Members) Less(i, j int) bool

+ func (m Members) Swap(i, j int)

+ type Message struct

+ BatchID *fftypes.UUID

+ Confirmed *fftypes.FFTime

+ Data DataRefs

+ Hash *fftypes.Bytes32

+ Header MessageHeader

+ LocalNamespace string

+ Pins FFStringArray

+ Sequence int64

+ State MessageState

+ func (m *Message) BatchMessage() *Message

+ func (m *Message) DupDataCheck(ctx context.Context) (err error)

+ func (m *Message) EstimateSize(includeDataRefs bool) int64

+ func (m *Message) LocalSequence() int64

+ func (m *Message) Seal(ctx context.Context) (err error)

+ func (m *Message) Verify(ctx context.Context) error

+ func (m *Message) VerifyFields(ctx context.Context) error

+ type MessageFilter struct

+ Author string

+ Group string

+ Tag string

+ type MessageHeader struct

+ CID *fftypes.UUID

+ Created *fftypes.FFTime

+ DataHash *fftypes.Bytes32

+ Group *fftypes.Bytes32

+ ID *fftypes.UUID

+ Namespace string

+ Tag string

+ Topics FFStringArray

+ TxType TransactionType

+ Type MessageType

+ func (h *MessageHeader) Hash() *fftypes.Bytes32

+ type MessageInOut struct

+ Group *InputGroup

+ InlineData InlineData

+ func (m *MessageInOut) SetInlineData(data []*Data)

+ type MessageManifestEntry struct

+ Topics int

+ type MessageRef struct

+ Hash *fftypes.Bytes32

+ ID *fftypes.UUID

+ type MessageState = fftypes.FFEnum

+ type MessageType = fftypes.FFEnum

+ type MultipartyContract struct

+ FirstEvent string

+ Index int

+ Info MultipartyContractInfo

+ Location *fftypes.JSONAny

+ type MultipartyContractInfo struct

+ FinalEvent string

+ Subscription string

+ Version int

+ type MultipartyContracts struct

+ Active *MultipartyContract

+ Terminated []*MultipartyContract

+ func (fc *MultipartyContracts) Scan(src interface{}) error

+ func (fc MultipartyContracts) Value() (driver.Value, error)

+ type Named interface

+ Name func() string

+ type Namespace struct

+ Contracts *MultipartyContracts

+ Created *fftypes.FFTime

+ Description string

+ Name string

+ NetworkName string

+ type NamespaceStatus struct

+ Multiparty NamespaceStatusMultiparty

+ Namespace *Namespace

+ Node *NamespaceStatusNode

+ Org *NamespaceStatusOrg

+ Plugins NamespaceStatusPlugins

+ type NamespaceStatusMultiparty struct

+ Contracts *MultipartyContracts

+ Enabled bool

+ type NamespaceStatusNode struct

+ ID *fftypes.UUID

+ Name string

+ Registered bool

+ type NamespaceStatusOrg struct

+ DID string

+ ID *fftypes.UUID

+ Name string

+ Registered bool

+ Verifiers []*VerifierRef

+ type NamespaceStatusPlugin struct

+ Name string

+ PluginType string

+ type NamespaceStatusPlugins struct

+ Blockchain []*NamespaceStatusPlugin

+ DataExchange []*NamespaceStatusPlugin

+ Database []*NamespaceStatusPlugin

+ Events []*NamespaceStatusPlugin

+ Identity []*NamespaceStatusPlugin

+ SharedStorage []*NamespaceStatusPlugin

+ Tokens []*NamespaceStatusPlugin

+ type NetworkAction struct

+ Type NetworkActionType

+ type NetworkActionType = fftypes.FFEnum

+ type NextPin struct

+ Context *fftypes.Bytes32

+ Hash *fftypes.Bytes32

+ Identity string

+ Namespace string

+ Nonce int64

+ Sequence int64

+ type Nonce struct

+ Hash *fftypes.Bytes32

+ Nonce int64

+ type Offset struct

+ Current int64

+ Name string

+ RowID int64

+ Type OffsetType

+ type OffsetType = fftypes.FFEnum

+ type OpStatus string

+ const OpStatusFailed

+ const OpStatusPending

+ const OpStatusSucceeded

+ type OpType = fftypes.FFEnum

+ type Operation struct

+ Created *fftypes.FFTime

+ Error string

+ ID *fftypes.UUID

+ Input fftypes.JSONObject

+ Namespace string

+ Output fftypes.JSONObject

+ Plugin string

+ Retry *fftypes.UUID

+ Status OpStatus

+ Transaction *fftypes.UUID

+ Type OpType

+ Updated *fftypes.FFTime

+ func NewOperation(plugin Named, namespace string, tx *fftypes.UUID, opType OpType) *Operation

+ type OperationCallbacks interface

+ OperationUpdate func(update *OperationUpdate)

+ type OperationUpdate struct

+ BlockchainTXID string

+ DXHash string

+ DXManifest string

+ ErrorMessage string

+ NamespacedOpID string

+ OnComplete func()

+ Output fftypes.JSONObject

+ Plugin string

+ Status OpStatus

+ VerifyManifest bool

+ type OperationUpdateDTO struct

+ Error *string

+ Output fftypes.JSONObject

+ Status OpStatus

+ type Pin struct

+ Batch *fftypes.UUID

+ BatchHash *fftypes.Bytes32

+ Created *fftypes.FFTime

+ Dispatched bool

+ Hash *fftypes.Bytes32

+ Index int64

+ Masked bool

+ Namespace string

+ Sequence int64

+ Signer string

+ func (p *Pin) LocalSequence() int64

+ type PinRewind struct

+ Batch *fftypes.UUID

+ Sequence int64

+ type PreparedOperation struct

+ Data interface{}

+ ID *fftypes.UUID

+ Namespace string

+ Plugin string

+ Type OpType

+ func (po *PreparedOperation) NamespacedIDString() string

+ type SignerRef struct

+ Author string

+ Key string

+ type SubOptsFirstEvent string

+ const SubOptsFirstEventNewest

+ const SubOptsFirstEventOldest

+ type Subscription struct

+ Created *fftypes.FFTime

+ Ephemeral bool

+ Filter SubscriptionFilter

+ Options SubscriptionOptions

+ Transport string

+ Updated *fftypes.FFTime

+ type SubscriptionCoreOptions struct

+ FirstEvent *SubOptsFirstEvent

+ ReadAhead *uint16

+ WithData *bool

+ type SubscriptionFilter struct

+ BlockchainEvent BlockchainEventFilter

+ DeprecatedAuthor string

+ DeprecatedGroup string

+ DeprecatedTag string

+ DeprecatedTopics string

+ Events string

+ Message MessageFilter

+ Topic string

+ Transaction TransactionFilter

+ func NewSubscriptionFilterFromQuery(query url.Values) SubscriptionFilter

+ func (sf *SubscriptionFilter) Scan(src interface{}) error

+ func (sf SubscriptionFilter) Value() (driver.Value, error)

+ type SubscriptionOptions struct

+ func (so *SubscriptionOptions) Scan(src interface{}) error

+ func (so *SubscriptionOptions) TransportOptions() fftypes.JSONObject

+ func (so *SubscriptionOptions) UnmarshalJSON(b []byte) error

+ func (so SubscriptionOptions) MarshalJSON() ([]byte, error)

+ func (so SubscriptionOptions) Value() (driver.Value, error)

+ type SubscriptionRef struct

+ ID *fftypes.UUID

+ Name string

+ Namespace string

+ type SubscriptionStatus struct

+ CurrentOffset int64

+ type SubscriptionWithStatus struct

+ Status SubscriptionStatus

+ type TokenAccount struct

+ Key string

+ type TokenAccountPool struct

+ Pool *fftypes.UUID

+ type TokenApproval struct

+ Active bool

+ Approved bool

+ BlockchainEvent *fftypes.UUID

+ Config fftypes.JSONObject

+ Connector string

+ Created *fftypes.FFTime

+ Info fftypes.JSONObject

+ Key string

+ LocalID *fftypes.UUID

+ Namespace string

+ Operator string

+ Pool *fftypes.UUID

+ ProtocolID string

+ Subject string

+ TX TransactionRef

+ type TokenApprovalInput struct

+ Pool string

+ type TokenBalance struct

+ Balance fftypes.FFBigInt

+ Connector string

+ Key string

+ Namespace string

+ Pool *fftypes.UUID

+ TokenIndex string

+ URI string

+ Updated *fftypes.FFTime

+ func (t *TokenBalance) Identifier() string

+ type TokenConnector struct

+ Name string

+ type TokenPool struct

+ Config fftypes.JSONObject

+ Connector string

+ Created *fftypes.FFTime

+ Decimals int

+ ID *fftypes.UUID

+ Info fftypes.JSONObject

+ Key string

+ Locator string

+ Message *fftypes.UUID

+ Name string

+ Namespace string

+ Standard string

+ State TokenPoolState

+ Symbol string

+ TX TransactionRef

+ Type TokenType

+ func (t *TokenPool) Validate(ctx context.Context) (err error)

+ type TokenPoolAnnouncement struct

+ Pool *TokenPool

+ func (t *TokenPoolAnnouncement) SetBroadcastMessage(msgID *fftypes.UUID)

+ func (t *TokenPoolAnnouncement) Topic() string

+ type TokenPoolState = fftypes.FFEnum

+ type TokenTransfer struct

+ Amount fftypes.FFBigInt

+ BlockchainEvent *fftypes.UUID

+ Config fftypes.JSONObject

+ Connector string

+ Created *fftypes.FFTime

+ From string

+ Key string

+ LocalID *fftypes.UUID

+ Message *fftypes.UUID

+ MessageHash *fftypes.Bytes32

+ Namespace string

+ Pool *fftypes.UUID

+ ProtocolID string

+ TX TransactionRef

+ To string

+ TokenIndex string

+ Type TokenTransferType

+ URI string

+ type TokenTransferInput struct

+ Message *MessageInOut

+ Pool string

+ type TokenTransferType = fftypes.FFEnum

+ type TokenType = fftypes.FFEnum

+ type Transaction struct

+ BlockchainIDs FFStringArray

+ Created *fftypes.FFTime

+ ID *fftypes.UUID

+ Namespace string

+ Type TransactionType

+ func (tx *Transaction) Size() int64

+ type TransactionFilter struct

+ Type string

+ type TransactionRef struct

+ ID *fftypes.UUID

+ Type TransactionType

+ type TransactionStatus struct

+ Details []*TransactionStatusDetails

+ Status OpStatus

+ type TransactionStatusDetails struct

+ Error string

+ ID *fftypes.UUID

+ Info fftypes.JSONObject

+ Status OpStatus

+ SubType string

+ Timestamp *fftypes.FFTime

+ Type TransactionStatusType

+ type TransactionStatusType string

+ var TransactionStatusTypeBatch TransactionStatusType = "Batch"

+ var TransactionStatusTypeBlockchainEvent TransactionStatusType = "BlockchainEvent"

+ var TransactionStatusTypeOperation TransactionStatusType = "Operation"

+ var TransactionStatusTypeTokenApproval TransactionStatusType = "TokenApproval"

+ var TransactionStatusTypeTokenPool TransactionStatusType = "TokenPool"

+ var TransactionStatusTypeTokenTransfer TransactionStatusType = "TokenTransfer"

+ type TransactionType = fftypes.FFEnum

+ type TransportPayloadType = fftypes.FFEnum

+ type TransportWrapper struct

+ Batch *Batch

+ Group *Group

+ type ValidatorType = fftypes.FFEnum

+ type Verifier struct

+ Created *fftypes.FFTime

+ Hash *fftypes.Bytes32

+ Identity *fftypes.UUID

+ Namespace string

+ func (v *Verifier) Seal() *Verifier

+ type VerifierRef struct

+ Type VerifierType

+ Value string

+ type VerifierType = fftypes.FFEnum

+ type WSAck struct

+ ID *fftypes.UUID

+ Subscription *SubscriptionRef

+ type WSActionBase struct

+ Type WSClientPayloadType

+ type WSChangeEventCommand struct

+ Collections []string

+ Filter ChangeEventFilter

+ Type WSChangeEventCommandType

+ type WSChangeEventCommandType = fftypes.FFEnum

+ type WSClientPayloadType = fftypes.FFEnum

+ type WSConnectionStatus struct

+ ID string

+ RemoteAddress string

+ Subscriptions []*WSSubscriptionStatus

+ UserAgent string

+ type WSError struct

+ Error string

+ Type WSClientPayloadType

+ type WSStart struct

+ AutoAck *bool

+ Ephemeral bool

+ Filter SubscriptionFilter

+ Name string

+ Namespace string

+ Options SubscriptionOptions

+ type WSSubscriptionStatus struct

+ Ephemeral bool

+ Name string

+ Namespace string

+ type WebSocketStatus struct

+ Connections []*WSConnectionStatus

+ Enabled bool

+ type WebhookInputOptions struct

+ Body string

+ Headers string

+ Path string

+ Query string

+ ReplyTX string

+ type WebhookSubOptions struct

+ Fastack bool

+ Headers map[string]string

+ Input WebhookInputOptions

+ JSON bool

+ Method string

+ Query map[string]string

+ Reply bool

+ ReplyTX string

+ ReplyTag string

+ URL string

v1.1.0-rc.4

Sep 9, 2022

v1.1.0-rc.3

Sep 3, 2022

v1.1.0-rc.2

Sep 1, 2022

v1.1.0-rc.1

Aug 24, 2022

v1.1.0-alpha.4

Aug 23, 2022

v1.1.0-alpha.3

Aug 15, 2022

v1.1.0-alpha.2

Jun 8, 2022

v1.1.0-alpha.1

Jun 2, 2022

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL