fftypes

package

Go to main page

Versions in this module

v1

v1.0.5

Sep 26, 2022

v1.0.4

Aug 18, 2022

v1.0.3

Jul 7, 2022

Changes in this version

type TokenTransfer

+ Config JSONObject

v1.0.2

May 27, 2022

v1.0.1

May 9, 2022

v1.0.0

Apr 26, 2022

Changes in this version

+ var EventTypeBlockchainInvokeOpFailed = ffEnum("eventtype", "blockchain_invoke_op_failed")

+ var EventTypeBlockchainInvokeOpSucceeded = ffEnum("eventtype", "blockchain_invoke_op_succeeded")

+ var EventTypePoolOpFailed = ffEnum("eventtype", "token_pool_op_failed")

+ var WSChangeEventCommandTypeStart = ffEnum("changeevent_cmd_type", "start")

+ type BlockchainTransactionRef struct

+ BlockchainID string

+ ID *UUID

+ Type TransactionType

type ChangeEvent

+ DroppedCount int64

+ DroppedSince *FFTime

+ type ChangeEventFilter struct

+ Namespaces []string

+ Types []ChangeEventType

type ChangeEventType

+ const ChangeEventTypeDropped

type ChartHistogram

+ IsCapped bool

type ContractCallRequest

+ MethodPath string

type ContractListener

+ BackendID string

+ Signature string

type ContractListenerInput

+ EventPath string

type EnrichedEvent

+ Operation *Operation

type FFBigInt

+ func (i *FFBigInt) Int64() int64

+ func (i *FFBigInt) Uint64() uint64

type FFIEvent

+ Interface *UUID

+ Signature string

type FFIMethod

+ Interface *UUID

+ type IdentityWithVerifiers struct

+ Verifiers []*VerifierRef

type NodeStatus

+ Plugins NodeStatusPlugins

type NodeStatusOrg

+ Verifiers []*VerifierRef

+ type NodeStatusPlugin struct

+ Name string

+ PluginType string

+ type NodeStatusPlugins struct

+ Blockchain []*NodeStatusPlugin

+ DataExchange []*NodeStatusPlugin

+ Database []*NodeStatusPlugin

+ Events []*NodeStatusPlugin

+ Identity []*NodeStatusPlugin

+ SharedStorage []*NodeStatusPlugin

+ Tokens []*NodeStatusPlugin

type Nonce

+ Hash *Bytes32

type PreparedOperation

+ Namespace string

type TokenApproval

+ Active bool

+ Subject string

type TokenPool

+ Decimals int

+ Locator string

type UUID

+ func (u *UUID) HashBucket(buckets int) int

+ type WSChangeEventCommand struct

+ Collections []string

+ Filter ChangeEventFilter

+ Type WSChangeEventCommandType

+ type WSChangeEventCommandType = FFEnum

+ type WSConnectionStatus struct

+ ID string

+ RemoteAddress string

+ Subscriptions []*WSSubscriptionStatus

+ UserAgent string

+ type WSSubscriptionStatus struct

+ Ephemeral bool

+ Name string

+ Namespace string

+ type WebSocketStatus struct

+ Connections []*WSConnectionStatus

+ Enabled bool

v1.0.0-rc.7

Apr 27, 2022

v1.0.0-rc.6

Apr 26, 2022

v1.0.0-rc.5

Apr 20, 2022

v1.0.0-rc.4

Apr 13, 2022

v1.0.0-rc.3

Apr 11, 2022

v1.0.0-rc.2

Apr 9, 2022

v1.0.0-rc.1

Apr 8, 2022

v0

v0.14.1

Mar 28, 2022

Changes in this version

type EnrichedEvent

+ ContractAPI *ContractAPI

+ ContractInterface *FFI

+ Datatype *Datatype

+ Identity *Identity

+ NamespaceDetails *Namespace

+ TokenApproval *TokenApproval

+ TokenPool *TokenPool

+ TokenTransfer *TokenTransfer

v0.14.0

Mar 22, 2022

Changes in this version

+ const DIDPrefix

+ const DeprecatedSystemTagDefineNode

+ const DeprecatedSystemTagDefineOrganization

+ const FireFlyCustomDIDPrefix

+ const FireFlyDIDPrefix

+ const FireFlyNodeDIDPrefix

+ const FireFlyOrgDIDPrefix

+ const ManifestVersion1

+ const ManifestVersionUnset

+ const SystemBatchPinTopic

+ const SystemTagIdentityClaim

+ const SystemTagIdentityUpdate

+ const SystemTagIdentityVerification

+ const SystemTopicDefinitions

+ var BatchTypeBroadcast = ffEnum("batchtype", "broadcast")

+ var BatchTypePrivate = ffEnum("batchtype", "private")

+ var EventTypeBlockchainEventReceived = ffEnum("eventtype", "blockchain_event_received")

+ var EventTypeIdentityConfirmed = ffEnum("eventtype", "identity_confirmed")

+ var EventTypeIdentityUpdated = ffEnum("eventtype", "identity_updated")

+ var IdentityTypeCustom = ffEnum("identitytype", "custom")

+ var IdentityTypeNode = ffEnum("identitytype", "node")

+ var IdentityTypeOrg = ffEnum("identitytype", "org")

+ var OpTypeBlockchainPinBatch = ffEnum("optype", "blockchain_pin_batch")

+ var OpTypeDataExchangeSendBatch = ffEnum("optype", "dataexchange_send_batch")

+ var OpTypeDataExchangeSendBlob = ffEnum("optype", "dataexchange_send_blob")

+ var OpTypeSharedStorageDownloadBatch = ffEnum("optype", "sharedstorage_download_batch")

+ var OpTypeSharedStorageDownloadBlob = ffEnum("optype", "sharedstorage_download_blob")

+ var OpTypeSharedStorageUploadBatch = ffEnum("optype", "sharedstorage_upload_batch")

+ var OpTypeSharedStorageUploadBlob = ffEnum("optype", "sharedstorage_upload_blob")

+ var VerifierTypeEthAddress = ffEnum("verifiertype", "ethereum_address")

+ var VerifierTypeFFDXPeerID = ffEnum("verifiertype", "dx_peer_id")

+ var VerifierTypeMSPIdentity = ffEnum("verifiertype", "fabric_msp_id")

+ type BatchHeader struct

+ Created *FFTime

+ Group *Bytes32

+ ID *UUID

+ Namespace string

+ Node *UUID

+ Type BatchType

+ type BatchManifest struct

+ Data DataRefs

+ ID *UUID

+ Messages []*MessageManifestEntry

+ TX TransactionRef

+ Version uint

+ func (bm *BatchManifest) String() string

type BatchPayload

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

+ type BatchPersisted struct

+ Confirmed *FFTime

+ Hash *Bytes32

+ Manifest *JSONAny

+ PayloadRef string

+ TX TransactionRef

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

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

+ type BatchType = FFEnum

type BlobRef

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

type BlockchainEvent

+ Listener *UUID

+ type BlockchainEventFilter struct

+ Listener string

+ Name string

type Bytes32

+ func HashString(s string) *Bytes32

type ChartHistogram

+ Types []*ChartHistogramType

+ type ChartHistogramType struct

+ Count string

+ Type string

+ type ContractListener struct

+ Created *FFTime

+ Event *FFISerializedEvent

+ ID *UUID

+ Interface *FFIReference

+ Location *JSONAny

+ Name string

+ Namespace string

+ Options *ContractListenerOptions

+ ProtocolID string

+ Topic string

+ type ContractListenerInput struct

+ EventID *UUID

+ type ContractListenerOptions struct

+ FirstEvent string

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

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

type Data

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

+ type DataArray []*Data

+ func (da DataArray) Refs() DataRefs

+ type DeprecatedDXInfo struct

+ Endpoint JSONObject

+ Peer string

+ type DeprecatedNode struct

+ Created *FFTime

+ DX DeprecatedDXInfo

+ Description string

+ ID *UUID

+ Message *UUID

+ Name string

+ Owner string

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

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

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

+ func (node *DeprecatedNode) Topic() string

+ type DeprecatedOrganization struct

+ Created *FFTime

+ Description string

+ ID *UUID

+ Identity string

+ Message *UUID

+ Name string

+ Parent string

+ Profile JSONObject

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

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

+ func (org *DeprecatedOrganization) Topic() string

+ type EnrichedEvent struct

+ BlockchainEvent *BlockchainEvent

+ Message *Message

+ Transaction *Transaction

type Event

+ Correlator *UUID

+ Topic string

+ type IDAndSequence struct

+ ID UUID

+ Sequence int64

type Identity

+ Created *FFTime

+ Messages IdentityMessages

+ Updated *FFTime

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

+ type IdentityBase struct

+ DID string

+ ID *UUID

+ Name string

+ Namespace string

+ Parent *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 *UUID)

+ func (ic *IdentityClaim) Topic() string

+ type IdentityCreateDTO struct

+ Key string

+ Name string

+ Parent string

+ Type IdentityType

+ type IdentityMessages struct

+ Claim *UUID

+ Update *UUID

+ Verification *UUID

+ type IdentityProfile struct

+ Description string

+ Profile JSONObject

+ type IdentityType = FFEnum

+ type IdentityUpdate struct

+ Identity IdentityBase

+ Updates IdentityProfile

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

+ func (iu *IdentityUpdate) Topic() string

+ type IdentityUpdateDTO struct

+ type IdentityVerification struct

+ Claim MessageRef

+ Identity IdentityBase

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

+ func (iv *IdentityVerification) Topic() string

type JSONAny

+ func (h *JSONAny) Unmarshal(ctx context.Context, v interface{}) error

+ func (h *JSONAny) Value() (driver.Value, error)

type Message

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

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

+ type MessageFilter struct

+ Author string

+ Group string

+ Tag string

+ type MessageManifestEntry struct

+ Topics int

type NodeStatusOrg

+ DID string

type Operation

+ Retry *UUID

type Pin

+ BatchHash *Bytes32

+ Signer string

+ type PreparedOperation struct

+ Data interface{}

+ ID *UUID

+ Type OpType

+ type SignerRef struct

+ Author string

+ Key string

type SubscriptionFilter

+ BlockchainEvent BlockchainEventFilter

+ DeprecatedAuthor string

+ DeprecatedGroup string

+ DeprecatedTag string

+ DeprecatedTopics 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 TokenPool

+ Info JSONObject

type Transaction

+ func (tx *Transaction) Size() int64

+ type TransactionFilter struct

+ Type string

+ type Verifier struct

+ Created *FFTime

+ Hash *Bytes32

+ Identity *UUID

+ Namespace string

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

+ type VerifierRef struct

+ Type VerifierType

+ Value string

+ type VerifierType = FFEnum

v0.13.1

Mar 1, 2022

Changes in this version

+ var TransactionTypeTokenApproval TransactionType = ffEnum("txtype", "token_approval")

+ type ContractCallResponse struct

+ ID *UUID

type Event

+ Transaction *UUID

type EventType

+ var EventTypeApprovalConfirmed EventType = ffEnum("eventtype", "token_approval_confirmed")

+ var EventTypeApprovalOpFailed EventType = ffEnum("eventtype", "token_approval_op_failed")

+ type FFIGenerationRequest struct

+ Description string

+ Input *JSONAny

+ Name string

+ Namespace string

+ Version string

type OpType

+ var OpTypeTokenApproval OpType = ffEnum("optype", "token_approval")

+ type TokenApproval struct

+ Approved bool

+ BlockchainEvent *UUID

+ Config JSONObject

+ Connector string

+ Created *FFTime

+ Info JSONObject

+ Key string

+ LocalID *UUID

+ Namespace string

+ Operator string

+ Pool *UUID

+ ProtocolID string

+ TX TransactionRef

+ TokenIndex string

+ type TokenApprovalInput struct

+ Pool string

type TransactionStatusType

+ var TransactionStatusTypeTokenApproval TransactionStatusType = "TokenApproval"

type TransportStatusUpdate

+ Hash string

v0.13.0

Feb 14, 2022

Changes in this version

+ var TransactionTypeUnpinned TransactionType = ffEnum("txtype", "unpinned")

+ func NewFFISchemaCompiler() *jsonschema.Compiler

+ type BaseFFIParamValidator struct

+ func (v *BaseFFIParamValidator) GetExtensionName() string

+ func (v *BaseFFIParamValidator) GetMetaSchema() *jsonschema.Schema

+ func (v BaseFFIParamValidator) Compile(ctx jsonschema.CompilerContext, m map[string]interface{}) (jsonschema.ExtSchema, error)

type MessageState

+ var MessageStateSent MessageState = ffEnum("messagestate", "sent")

type OpType

+ var OpTypeBlockchainInvoke OpType = ffEnum("optype", "blockchain_invoke")

+ var OpTypeTokenActivatePool OpType = ffEnum("optype", "token_activate_pool")

type Operation

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

v0.12.0

Feb 2, 2022

Changes in this version

+ const FFStringArrayStandardMax

+ const FFStringNameItemsMax

+ const HTTPHeadersBlobHashSHA256

+ const HTTPHeadersBlobSize

+ const MaxFFBigIntHexLength

+ const NullString

+ var TransactionTypeContractInvoke OpType = ffEnum("txtype", "contract_invoke")

+ func ValidateSafeCharsOnly(ctx context.Context, str string, fieldName string) error

type Batch

+ func (b *Batch) Manifest() *Manifest

type Blob

+ Size int64

type BlobRef

+ Name string

+ Size int64

+ type BlockchainEvent struct

+ ID *UUID

+ Info JSONObject

+ Name string

+ Namespace string

+ Output JSONObject

+ ProtocolID string

+ Sequence int64

+ Source string

+ Subscription *UUID

+ TX TransactionRef

+ Timestamp *FFTime

type Bytes32

+ func MustParseBytes32(hexStr string) *Bytes32

+ type ContractAPI struct

+ ID *UUID

+ Interface *FFIReference

+ Ledger *JSONAny

+ Location *JSONAny

+ Message *UUID

+ Name string

+ Namespace string

+ URLs ContractURLs

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

+ func (c *ContractAPI) SetBroadcastMessage(msgID *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 *UUID

+ Key string

+ Ledger *JSONAny

+ Location *JSONAny

+ Method *FFIMethod

+ Type ContractCallType

+ type ContractCallType = FFEnum

+ var CallTypeInvoke ContractCallType = ffEnum("contractcalltype", "invoke")

+ var CallTypeQuery ContractCallType = ffEnum("contractcalltype", "query")

+ type ContractSubscribeRequest struct

+ Event *FFIEvent

+ Interface *UUID

+ Location *JSONAny

+ type ContractSubscription struct

+ Created *FFTime

+ Event *FFISerializedEvent

+ ID *UUID

+ Interface *FFIReference

+ Location *JSONAny

+ Name string

+ Namespace string

+ ProtocolID string

+ type ContractSubscriptionInput struct

+ EventID *UUID

+ type ContractURLs struct

+ OpenAPI string

+ UI string

type Data

+ ValueSize int64

+ func (d *Data) EstimateSize() int64

type DataRef

+ ValueSize int64

type EventType

+ var EventTypeBlockchainEvent EventType = ffEnum("eventtype", "blockchain_event")

+ var EventTypeContractAPIConfirmed EventType = ffEnum("eventtype", "contract_api_confirmed")

+ var EventTypeContractAPIRejected EventType = ffEnum("eventtype", "contract_api_rejected")

+ var EventTypeContractInterfaceConfirmed EventType = ffEnum("eventtype", "contract_interface_confirmed")

+ var EventTypeContractInterfaceRejected EventType = ffEnum("eventtype", "contract_interface_rejected")

+ var EventTypeTransactionSubmitted EventType = ffEnum("eventtype", "transaction_submitted")

+ type FFBigInt big.Int

+ func NewFFBigInt(x int64) *FFBigInt

+ func (i *FFBigInt) Equals(i2 *FFBigInt) bool

+ func (i *FFBigInt) Int() *big.Int

+ func (i *FFBigInt) Scan(src interface{}) error

+ func (i *FFBigInt) UnmarshalJSON(b []byte) error

+ func (i FFBigInt) MarshalText() ([]byte, error)

+ func (i FFBigInt) Value() (driver.Value, error)

+ type FFI struct

+ Description string

+ Events []*FFIEvent

+ ID *UUID

+ Message *UUID

+ Methods []*FFIMethod

+ Name string

+ Namespace string

+ Version string

+ func (f *FFI) SetBroadcastMessage(msgID *UUID)

+ func (f *FFI) Topic() string

+ func (f *FFI) Validate(ctx context.Context, existing bool) (err error)

+ type FFIEvent struct

+ Contract *UUID

+ ID *UUID

+ Namespace string

+ Pathname string

+ type FFIEventDefinition struct

+ Description string

+ Name string

+ Params FFIParams

+ type FFIMethod struct

+ Contract *UUID

+ Description string

+ ID *UUID

+ Name string

+ Namespace string

+ Params FFIParams

+ Pathname string

+ Returns FFIParams

+ type FFIParam struct

+ Name string

+ Schema *JSONAny

+ type FFIParamValidator interface

+ Compile func(ctx jsonschema.CompilerContext, m map[string]interface{}) (jsonschema.ExtSchema, error)

+ GetExtensionName func() string

+ GetMetaSchema func() *jsonschema.Schema

+ type FFIParams []*FFIParam

+ func (m *FFIParams) Scan(src interface{}) error

+ func (m FFIParams) Value() (driver.Value, error)

+ type FFIReference struct

+ ID *UUID

+ Name string

+ Version string

+ 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) error

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

type FFTime

+ func ParseTimeString(str string) (*FFTime, error)

+ type JSONAny string

+ func JSONAnyPtr(str string) *JSONAny

+ func JSONAnyPtrBytes(b []byte) *JSONAny

+ func (h *JSONAny) Bytes() []byte

+ func (h *JSONAny) Hash() *Bytes32

+ func (h *JSONAny) IsNil() bool

+ func (h *JSONAny) JSONObject() JSONObject

+ func (h *JSONAny) JSONObjectNowarn() JSONObject

+ func (h *JSONAny) JSONObjectOk(noWarn ...bool) (JSONObject, bool)

+ func (h *JSONAny) Length() int64

+ func (h *JSONAny) Scan(src interface{}) error

+ func (h *JSONAny) String() string

+ func (h *JSONAny) UnmarshalJSON(b []byte) error

+ func (h JSONAny) MarshalJSON() ([]byte, error)

type JSONObject

+ func (jd JSONObject) GetInt64(key string) int64

+ func (jd JSONObject) GetInteger(key string) *big.Int

+ type Manifest struct

+ Data []DataRef

+ Messages []MessageRef

+ func (mf *Manifest) String() string

type Message

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

type OpType

+ var OpTypeContractInvoke OpType = ffEnum("optype", "contract_invoke")

type SystemTag

+ const SystemTagDefineContractAPI

+ const SystemTagDefineFFI

type TokenPoolAnnouncement

+ Event *BlockchainEvent

type TokenTransfer

+ BlockchainEvent *UUID

type Transaction

+ BlockchainIDs FFStringArray

+ Namespace string

+ Type TransactionType

+ type TransactionStatus struct

+ Details []*TransactionStatusDetails

+ Status OpStatus

+ type TransactionStatusDetails struct

+ Error string

+ ID *UUID

+ Info JSONObject

+ Status OpStatus

+ SubType string

+ Timestamp *FFTime

+ Type TransactionStatusType

+ type TransactionStatusType string

+ var TransactionStatusTypeBatch TransactionStatusType = "Batch"

+ var TransactionStatusTypeBlockchainEvent TransactionStatusType = "BlockchainEvent"

+ var TransactionStatusTypeOperation TransactionStatusType = "Operation"

+ var TransactionStatusTypeTokenPool TransactionStatusType = "TokenPool"

+ var TransactionStatusTypeTokenTransfer TransactionStatusType = "TokenTransfer"

+ type TransportStatusUpdate struct

+ Error string

+ Info string

+ Manifest string

type TransportWrapper

+ func (tw *TransportWrapper) Manifest() *Manifest

v0.11.5

Jan 24, 2022

v0.11.4

Dec 29, 2021

Changes in this version

+ const FFNameArrayMax

+ const OrgTopic

+ func ValidateFFNameFieldNoUUID(ctx context.Context, str string, fieldName string) error

v0.11.3

Dec 21, 2021

v0.11.2

Dec 14, 2021

Changes in this version

+ const ChartHistogramMaxBuckets

+ const ChartHistogramMinBuckets

+ type ChartHistogram struct

+ Count string

+ Timestamp *FFTime

+ type ChartHistogramInterval struct

+ EndTime *FFTime

+ StartTime *FFTime

v0.11.1

Dec 1, 2021

Changes in this version

type TokenBalance

+ URI string

type TokenTransfer

+ URI string

v0.11.0

Nov 22, 2021

Changes in this version

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

type Batch

+ Node *UUID

type BigInt

+ func NewBigInt(x int64) *BigInt

type EventType

+ var EventTypeTransferOpFailed EventType = ffEnum("eventtype", "token_transfer_op_failed")

type FFTime

+ func (ft *FFTime) Time() *time.Time

type Message

+ State MessageState

+ type MessageState = FFEnum

+ var MessageStateConfirmed MessageState = ffEnum("messagestate", "confirmed")

+ var MessageStatePending MessageState = ffEnum("messagestate", "pending")

+ var MessageStateReady MessageState = ffEnum("messagestate", "ready")

+ var MessageStateRejected MessageState = ffEnum("messagestate", "rejected")

+ var MessageStateStaged MessageState = ffEnum("messagestate", "staged")

type TokenAccount

+ Key string

+ type TokenAccountPool struct

+ Pool *UUID

+ type TokenBalance struct

+ Balance BigInt

+ Connector string

+ Key string

+ Namespace string

+ Pool *UUID

+ TokenIndex string

+ Updated *FFTime

+ func (t *TokenBalance) Identifier() string

+ type TokenConnector struct

+ Name string

type TokenPool

+ Standard string

+ State TokenPoolState

type TokenPoolAnnouncement

+ Pool *TokenPool

+ TX *Transaction

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

+ func (t *TokenPoolAnnouncement) Topic() string

+ type TokenPoolState = FFEnum

+ var TokenPoolStateConfirmed TokenPoolState = ffEnum("tokenpoolstate", "confirmed")

+ var TokenPoolStatePending TokenPoolState = ffEnum("tokenpoolstate", "pending")

+ var TokenPoolStateUnknown TokenPoolState = ffEnum("tokenpoolstate", "unknown")

type TokenTransfer

+ Connector string

+ Message *UUID

+ Namespace string

+ Pool *UUID

type TokenTransferInput

+ Pool string

v0.10.1

Oct 15, 2021

Changes in this version

type MessageType

+ var MessageTypeTransferBroadcast MessageType = ffEnum("messagetype", "transfer_broadcast")

+ var MessageTypeTransferPrivate MessageType = ffEnum("messagetype", "transfer_private")

+ type TokenTransferInput struct

+ Message *MessageInOut

v0.10.1-20211025-01

Oct 21, 2021

v0.10.0

Oct 14, 2021

v0.9.0

Oct 13, 2021

Changes in this version

+ const DefaultTopic

+ const FireflyOrgDIDPrefix

+ const MaxBigIntHexLength

+ const ShortIDlphabet

+ const SystemNamespace

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

+ func FFEnumValues(t string) []interface

+ func ParseToByteSize(byteString string) int64

+ func ParseToDuration(durationString string) time.Duration

+ func SafeHashCompare(h1 *Bytes32, h2 *Bytes32) bool

+ func ShortID() string

+ func ToStringArray(unknown interface{}) ([]string, bool)

+ func TokenAccountIdentifier(protocolID, tokenIndex, identity string) string

+ func ValidateFFNameField(ctx context.Context, str string, fieldName string) error

+ func ValidateLength(ctx context.Context, str string, fieldName string, max int) error

+ type Batch struct

+ Blobs []*Bytes32

+ Confirmed *FFTime

+ Created *FFTime

+ Group *Bytes32

+ Hash *Bytes32

+ ID *UUID

+ Namespace string

+ Payload BatchPayload

+ PayloadRef string

+ Type MessageType

+ type BatchPayload struct

+ Data []*Data

+ Messages []*Message

+ TX TransactionRef

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

+ func (ma *BatchPayload) Scan(src interface{}) error

+ func (ma BatchPayload) Value() (driver.Value, error)

+ type BigInt big.Int

+ func (i *BigInt) Equals(i2 *BigInt) bool

+ func (i *BigInt) Int() *big.Int

+ func (i *BigInt) Scan(src interface{}) error

+ func (i *BigInt) UnmarshalJSON(b []byte) error

+ func (i BigInt) MarshalText() ([]byte, error)

+ func (i BigInt) Value() (driver.Value, error)

+ type Blob struct

+ Created *FFTime

+ Hash *Bytes32

+ PayloadRef string

+ Peer string

+ Sequence int64

+ type BlobRef struct

+ Hash *Bytes32

+ Public string

+ type Byteable []byte

+ func (h *Byteable) Scan(src interface{}) error

+ func (h *Byteable) UnmarshalJSON(b []byte) error

+ func (h Byteable) Hash() *Bytes32

+ func (h Byteable) JSONObject() JSONObject

+ func (h Byteable) JSONObjectOk() (JSONObject, bool)

+ func (h Byteable) MarshalJSON() ([]byte, error)

+ func (h Byteable) String() string

+ type Bytes32 [32]byte

+ func HashResult(hash hash.Hash) *Bytes32

+ func NewRandB32() *Bytes32

+ func ParseBytes32(ctx context.Context, hexStr string) (*Bytes32, error)

+ func UUIDBytes(u *UUID) *Bytes32

+ func (b32 *Bytes32) Equals(b2 *Bytes32) bool

+ func (b32 *Bytes32) Scan(src interface{}) error

+ func (b32 *Bytes32) String() string

+ func (b32 *Bytes32) UnmarshalText(b []byte) error

+ func (b32 *Bytes32) Value() (driver.Value, error)

+ func (b32 Bytes32) MarshalText() ([]byte, error)

+ type ChangeEvent struct

+ Collection string

+ Hash *Bytes32

+ ID *UUID

+ Namespace string

+ Sequence *int64

+ Type ChangeEventType

+ type ChangeEventType string

+ const ChangeEventTypeCreated

+ const ChangeEventTypeDeleted

+ const ChangeEventTypeUpdated

+ type ConfigRecord struct

+ Key string

+ Value Byteable

+ type DXInfo struct

+ Endpoint JSONObject

+ Peer string

+ type Data struct

+ Blob *BlobRef

+ Created *FFTime

+ Datatype *DatatypeRef

+ Hash *Bytes32

+ ID *UUID

+ Namespace string

+ Validator ValidatorType

+ Value Byteable

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

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

+ type DataAndBlob struct

+ Blob *Blob

+ Data *Data

+ type DataRef struct

+ Hash *Bytes32

+ ID *UUID

+ type DataRefOrValue struct

+ Blob *BlobRef

+ Datatype *DatatypeRef

+ Validator ValidatorType

+ Value Byteable

+ type DataRefs []*DataRef

+ func (d DataRefs) Hash() *Bytes32

+ type Datatype struct

+ Created *FFTime

+ Hash *Bytes32

+ ID *UUID

+ Message *UUID

+ Name string

+ Namespace string

+ Validator ValidatorType

+ Value Byteable

+ Version string

+ func (dt *Datatype) SetBroadcastMessage(msgID *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 *UUID)

+ Topic func() string

+ type EmptyInput struct

+ type Event struct

+ Created *FFTime

+ ID *UUID

+ Namespace string

+ Reference *UUID

+ Sequence int64

+ Type EventType

+ func NewEvent(t EventType, ns string, ref *UUID) *Event

+ func (e *Event) LocalSequence() int64

+ type EventDelivery struct

+ Message *Message

+ Subscription SubscriptionRef

+ type EventDeliveryResponse struct

+ ID *UUID

+ Info string

+ Rejected bool

+ Reply *MessageInOut

+ Subscription SubscriptionRef

+ type EventType = FFEnum

+ var EventTypeDatatypeConfirmed EventType = ffEnum("eventtype", "datatype_confirmed")

+ var EventTypeGroupConfirmed EventType = ffEnum("eventtype", "group_confirmed")

+ var EventTypeMessageConfirmed EventType = ffEnum("eventtype", "message_confirmed")

+ var EventTypeMessageRejected EventType = ffEnum("eventtype", "message_rejected")

+ var EventTypeNamespaceConfirmed EventType = ffEnum("eventtype", "namespace_confirmed")

+ var EventTypePoolConfirmed EventType = ffEnum("eventtype", "token_pool_confirmed")

+ var EventTypePoolRejected EventType = ffEnum("eventtype", "token_pool_rejected")

+ var EventTypeTransferConfirmed EventType = ffEnum("eventtype", "token_transfer_confirmed")

+ type FFDuration time.Duration

+ func ParseDurationString(durationString string, def time.Duration) (FFDuration, error)

+ func (fd *FFDuration) MarshalJSON() ([]byte, error)

+ func (fd *FFDuration) Scan(src interface{}) error

+ func (fd *FFDuration) String() string

+ func (fd *FFDuration) UnmarshalJSON(b []byte) error

+ func (fd *FFDuration) Value() (driver.Value, error)

+ type FFEnum string

+ func (ts *FFEnum) UnmarshalText(b []byte) error

+ func (ts FFEnum) Equals(ts2 FFEnum) bool

+ func (ts FFEnum) Lower() FFEnum

+ func (ts FFEnum) String() string

+ func (ts FFEnum) Value() (driver.Value, error)

+ type FFNameArray []string

+ func (na *FFNameArray) Scan(src interface{}) error

+ func (na FFNameArray) String() string

+ func (na FFNameArray) Validate(ctx context.Context, fieldName string) error

+ func (na FFNameArray) Value() (driver.Value, error)

+ type FFTime time.Time

+ func Now() *FFTime

+ func ParseString(str string) (*FFTime, error)

+ func UnixTime(unixTime int64) *FFTime

+ func ZeroTime() FFTime

+ func (ft *FFTime) Equal(ft2 *FFTime) bool

+ func (ft *FFTime) MarshalJSON() ([]byte, error)

+ func (ft *FFTime) Scan(src interface{}) error

+ func (ft *FFTime) UnixNano() int64

+ func (ft *FFTime) UnmarshalText(b []byte) error

+ func (ft FFTime) String() string

+ func (ft FFTime) Value() (driver.Value, error)

+ type Group struct

+ Created *FFTime

+ Hash *Bytes32

+ Message *UUID

+ func (group *Group) Seal()

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

+ func (group *Group) Topic() string

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

+ type GroupIdentity struct

+ Ledger *UUID

+ Members Members

+ Name string

+ Namespace string

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

+ type HexUUID = Bytes32

+ type Identity struct

+ Author string

+ Key string

+ type InlineData []*DataRefOrValue

+ type InputGroup struct

+ Ledger *UUID

+ Members []MemberInput

+ Name string

+ type JSONObject map[string]interface

+ func (jd *JSONObject) Scan(src interface{}) error

+ func (jd JSONObject) GetBool(key string) bool

+ func (jd JSONObject) GetObject(key string) JSONObject

+ func (jd JSONObject) GetObjectArray(key string) JSONObjectArray

+ func (jd JSONObject) GetObjectArrayOk(key string) (JSONObjectArray, bool)

+ func (jd JSONObject) GetObjectOk(key string) (JSONObject, bool)

+ func (jd JSONObject) GetString(key string) string

+ func (jd JSONObject) GetStringArray(key string) []string

+ func (jd JSONObject) GetStringArrayOk(key string) ([]string, bool)

+ func (jd JSONObject) GetStringOk(key string) (string, bool)

+ func (jd JSONObject) Hash(jsonDesc string) (*Bytes32, error)

+ func (jd JSONObject) String() string

+ func (jd JSONObject) Value() (driver.Value, error)

+ type JSONObjectArray []JSONObject

+ func ToJSONObjectArray(unknown interface{}) (JSONObjectArray, bool)

+ func (jd *JSONObjectArray) Scan(src interface{}) error

+ func (jd JSONObjectArray) Hash(jsonDesc string) (*Bytes32, error)

+ func (jd JSONObjectArray) String() string

+ func (jd JSONObjectArray) Value() (driver.Value, error)

+ type LocallySequenced interface

+ LocalSequence func() int64

+ type Member struct

+ Identity string

+ Node *UUID

+ 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 *UUID

+ Confirmed *FFTime

+ Data DataRefs

+ Hash *Bytes32

+ Header MessageHeader

+ Local bool

+ Pending SortableBool

+ Pins FFNameArray

+ Rejected bool

+ Sequence int64

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

+ func (m *Message) LocalSequence() int64

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

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

+ type MessageHeader struct

+ CID *UUID

+ Created *FFTime

+ DataHash *Bytes32

+ Group *Bytes32

+ ID *UUID

+ Namespace string

+ Tag string

+ Topics FFNameArray

+ TxType TransactionType

+ Type MessageType

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

+ type MessageInOut struct

+ Group *InputGroup

+ InlineData InlineData

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

+ type MessageRef struct

+ Hash *Bytes32

+ ID *UUID

+ Sequence int64

+ type MessageType = FFEnum

+ var MessageTypeBroadcast MessageType = ffEnum("messagetype", "broadcast")

+ var MessageTypeDefinition MessageType = ffEnum("messagetype", "definition")

+ var MessageTypeGroupInit MessageType = ffEnum("messagetype", "groupinit")

+ var MessageTypePrivate MessageType = ffEnum("messagetype", "private")

+ type Multipart struct

+ Data io.Reader

+ Filename string

+ Mimetype string

+ type Named interface

+ Name func() string

+ type Namespace struct

+ Created *FFTime

+ Description string

+ ID *UUID

+ Message *UUID

+ Name string

+ Type NamespaceType

+ func (ns *Namespace) SetBroadcastMessage(msgID *UUID)

+ func (ns *Namespace) Topic() string

+ func (ns *Namespace) Validate(ctx context.Context, existing bool) (err error)

+ type NamespaceType = FFEnum

+ var NamespaceTypeBroadcast NamespaceType = ffEnum("namespacetype", "broadcast")

+ var NamespaceTypeLocal NamespaceType = ffEnum("namespacetype", "local")

+ var NamespaceTypeSystem NamespaceType = ffEnum("namespacetype", "system")

+ type NextPin struct

+ Context *Bytes32

+ Hash *Bytes32

+ Identity string

+ Nonce int64

+ Sequence int64

+ type Node struct

+ Created *FFTime

+ DX DXInfo

+ Description string

+ ID *UUID

+ Message *UUID

+ Name string

+ Owner string

+ func (n *Node) SetBroadcastMessage(msgID *UUID)

+ func (n *Node) Topic() string

+ func (n *Node) Validate(ctx context.Context, existing bool) (err error)

+ type NodeStatus struct

+ Defaults NodeStatusDefaults

+ Node NodeStatusNode

+ Org NodeStatusOrg

+ type NodeStatusDefaults struct

+ Namespace string

+ type NodeStatusNode struct

+ ID *UUID

+ Name string

+ Registered bool

+ type NodeStatusOrg struct

+ ID *UUID

+ Identity string

+ Name string

+ Registered bool

+ type Nonce struct

+ Context *Bytes32

+ Group *Bytes32

+ Nonce int64

+ Topic string

+ type Offset struct

+ Current int64

+ Name string

+ RowID int64

+ Type OffsetType

+ type OffsetType = FFEnum

+ var OffsetTypeAggregator OffsetType = ffEnum("offsettype", "aggregator")

+ var OffsetTypeBatch OffsetType = ffEnum("offsettype", "batch")

+ var OffsetTypeSubscription OffsetType = ffEnum("offsettype", "subscription")

+ type OpStatus string

+ const OpStatusFailed

+ const OpStatusPending

+ const OpStatusSucceeded

+ type OpType = FFEnum

+ var OpTypeBlockchainBatchPin OpType = ffEnum("optype", "blockchain_batch_pin")

+ var OpTypeDataExchangeBatchSend OpType = ffEnum("optype", "dataexchange_batch_send")

+ var OpTypeDataExchangeBlobSend OpType = ffEnum("optype", "dataexchange_blob_send")

+ var OpTypePublicStorageBatchBroadcast OpType = ffEnum("optype", "publicstorage_batch_broadcast")

+ var OpTypeTokenAnnouncePool OpType = ffEnum("optype", "token_announce_pool")

+ var OpTypeTokenCreatePool OpType = ffEnum("optype", "token_create_pool")

+ var OpTypeTokenTransfer OpType = ffEnum("optype", "token_transfer")

+ type Operation struct

+ BackendID string

+ Created *FFTime

+ Error string

+ ID *UUID

+ Input JSONObject

+ Member string

+ Namespace string

+ Output JSONObject

+ Plugin string

+ Status OpStatus

+ Transaction *UUID

+ Type OpType

+ Updated *FFTime

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

+ type Organization struct

+ Created *FFTime

+ Description string

+ ID *UUID

+ Identity string

+ Message *UUID

+ Name string

+ Parent string

+ Profile JSONObject

+ func (org *Organization) GetDID() string

+ func (org *Organization) SetBroadcastMessage(msgID *UUID)

+ func (org *Organization) Topic() string

+ func (org *Organization) Validate(ctx context.Context, existing bool) (err error)

+ type Pin struct

+ Batch *UUID

+ Created *FFTime

+ Dispatched bool

+ Hash *Bytes32

+ Index int64

+ Masked bool

+ Sequence int64

+ func (p *Pin) LocalSequence() int64

+ type RESTError struct

+ Error string

+ type SortableBool bool

+ func (sb *SortableBool) Scan(src interface{}) error

+ func (sb SortableBool) Value() (driver.Value, error)

+ type SubOptsFirstEvent string

+ const SubOptsFirstEventNewest

+ const SubOptsFirstEventOldest

+ type Subscription struct

+ Created *FFTime

+ Ephemeral bool

+ Filter SubscriptionFilter

+ Options SubscriptionOptions

+ Transport string

+ Updated *FFTime

+ type SubscriptionCoreOptions struct

+ FirstEvent *SubOptsFirstEvent

+ ReadAhead *uint16

+ WithData *bool

+ type SubscriptionFilter struct

+ Author string

+ Events string

+ Group string

+ Tag string

+ Topics string

+ type SubscriptionOptions struct

+ ChangeEvents bool

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

+ func (so *SubscriptionOptions) TransportOptions() 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 *UUID

+ Name string

+ Namespace string

+ type SystemTag string

+ const SystemTagDefineDatatype

+ const SystemTagDefineGroup

+ const SystemTagDefineNamespace

+ const SystemTagDefineNode

+ const SystemTagDefineOrganization

+ const SystemTagDefinePool

+ type TokenAccount struct

+ Balance BigInt

+ Identity string

+ PoolProtocolID string

+ TokenIndex string

+ func (t *TokenAccount) Identifier() string

+ type TokenBalanceChange struct

+ Amount BigInt

+ Identity string

+ PoolProtocolID string

+ TokenIndex string

+ type TokenPool struct

+ Config JSONObject

+ Connector string

+ Created *FFTime

+ ID *UUID

+ Key string

+ Message *UUID

+ Name string

+ Namespace string

+ ProtocolID string

+ Symbol string

+ TX TransactionRef

+ Type TokenType

+ func (t *TokenPool) SetBroadcastMessage(msgID *UUID)

+ func (t *TokenPool) Topic() string

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

+ type TokenPoolAnnouncement struct

+ ProtocolTxID string

+ type TokenTransfer struct

+ Amount BigInt

+ Created *FFTime

+ From string

+ Key string

+ LocalID *UUID

+ MessageHash *Bytes32

+ PoolProtocolID string

+ ProtocolID string

+ TX TransactionRef

+ To string

+ TokenIndex string

+ Type TokenTransferType

+ type TokenTransferType = FFEnum

+ type TokenType = FFEnum

+ var TokenTransferTypeBurn TokenType = ffEnum("tokentransfertype", "burn")

+ var TokenTransferTypeMint TokenType = ffEnum("tokentransfertype", "mint")

+ var TokenTransferTypeTransfer TokenType = ffEnum("tokentransfertype", "transfer")

+ var TokenTypeFungible TokenType = ffEnum("tokentype", "fungible")

+ var TokenTypeNonFungible TokenType = ffEnum("tokentype", "nonfungible")

+ type Transaction struct

+ Created *FFTime

+ Hash *Bytes32

+ ID *UUID

+ Info JSONObject

+ ProtocolID string

+ Status OpStatus

+ Subject TransactionSubject

+ type TransactionRef struct

+ ID *UUID

+ Type TransactionType

+ type TransactionSubject struct

+ Namespace string

+ Reference *UUID

+ Signer string

+ Type TransactionType

+ func (t *TransactionSubject) Hash() *Bytes32

+ type TransactionType = FFEnum

+ var TransactionTypeBatchPin TransactionType = ffEnum("txtype", "batch_pin")

+ var TransactionTypeNone TransactionType = ffEnum("txtype", "none")

+ var TransactionTypeTokenPool TransactionType = ffEnum("txtype", "token_pool")

+ var TransactionTypeTokenTransfer TransactionType = ffEnum("txtype", "token_transfer")

+ type TransportPayloadType = FFEnum

+ var TransportPayloadTypeBatch TransportPayloadType = ffEnum("transportpayload", "batch")

+ var TransportPayloadTypeMessage TransportPayloadType = ffEnum("transportpayload", "message")

+ type TransportWrapper struct

+ Batch *Batch

+ Data []*Data

+ Group *Group

+ Message *Message

+ Type TransportPayloadType

+ type UUID uuid.UUID

+ func MustParseUUID(uuidStr string) *UUID

+ func NewUUID() *UUID

+ func ParseUUID(ctx context.Context, uuidStr string) (*UUID, error)

+ func (u *UUID) Equals(u2 *UUID) bool

+ func (u *UUID) Scan(src interface{}) error

+ func (u *UUID) String() string

+ func (u *UUID) UnmarshalBinary(b []byte) error

+ func (u *UUID) UnmarshalText(b []byte) error

+ func (u *UUID) Value() (driver.Value, error)

+ func (u UUID) MarshalBinary() ([]byte, error)

+ func (u UUID) MarshalText() ([]byte, error)

+ type ValidatorType = FFEnum

+ var ValidatorTypeJSON ValidatorType = ffEnum("validatortype", "json")

+ var ValidatorTypeNone ValidatorType = ffEnum("validatortype", "none")

+ var ValidatorTypeSystemDefinition ValidatorType = ffEnum("validatortype", "definition")

+ type WSChangeNotification struct

+ ChangeEvent *ChangeEvent

+ type WSClientActionAckPayload struct

+ ID *UUID

+ Subscription *SubscriptionRef

+ type WSClientActionBase struct

+ Type WSClientPayloadType

+ type WSClientActionStartPayload struct

+ AutoAck *bool

+ ChangeEvents string

+ Ephemeral bool

+ Filter SubscriptionFilter

+ Name string

+ Namespace string

+ Options SubscriptionOptions

+ type WSClientPayloadType = FFEnum

+ var WSClientActionAck WSClientPayloadType = ffEnum("wstype", "ack")

+ var WSClientActionChangeNotifcation WSClientPayloadType = ffEnum("wstype", "change_notification")

+ var WSClientActionStart WSClientPayloadType = ffEnum("wstype", "start")

+ var WSProtocolErrorEventType WSClientPayloadType = ffEnum("wstype", "protocol_error")

+ type WSProtocolErrorPayload struct

+ Error string

+ Type WSClientPayloadType

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