mtg

Jan 25, 2024

Changes in this version

type Configuration

+ LoopWaitDuration int64

Apr 20, 2023

Changes in this version

+ const StorageAssetId

+ const StorageReceiverId

+ var CompressionVersionLatest = CompressionVersionZero

+ var CompressionVersionZero = []byte

+ func CompressMsgpackMarshalPanic(val any) []byte

+ func DecompressMsgpackUnmarshal(data []byte, val any) error

type Group

+ func (grp *Group) BuildStorageTransaction(ctx context.Context, data []byte, groupId string) (*Transaction, error)

+ func (grp *Group) BuildTransactionWithReferences(ctx context.Context, assetId string, receivers []string, threshold int, ...) error

type Transaction

+ References []crypto.Hash

Apr 17, 2023

Changes in this version

type Store

+ DeleteTransaction func(tx *Transaction) error

Apr 14, 2023

Changes in this version

type Store

+ WriteOutputTraceId func(utxo *Output, traceId string) error

Apr 14, 2023

Changes in this version

+ const CompactionTransactionMemo

type Group

+ func (grp *Group) BuildTransactionWithStorage(ctx context.Context, assetId string, receivers []string, threshold int, ...) error

Feb 15, 2023

Changes in this version

type Group

+ func (grp *Group) ListOutputsForTransaction(traceId string) ([]*Output, error)

Feb 15, 2023

Changes in this version

type Group

+ func (grp *Group) Synced() (bool, error)

Jan 21, 2023

Changes in this version

+ const ActionStateDone

+ const ActionStateInitial

+ const CollectibleMetaTokenId

+ const CollectibleMixinAssetId

+ const IterationActionAdd

+ const IterationActionRemove

+ const NMPrefix

+ const NMVersion

+ const OutputStateSigned

+ const OutputStateSpent

+ const OutputStateUnspent

+ const OutputTypeCollectible

+ const OutputTypeMultisig

+ const OutputsBatchSize

+ const TransactionStateInitial

+ const TransactionStateSigned

+ const TransactionStateSigning

+ const TransactionStateSnapshot

+ var NMDefaultChain uuid.UUID

+ var NMDefaultClass []byte

+ var NMDefaultCollectionKey = uuid.Nil.Bytes()

+ func BuildExtraNFO(extra []byte) []byte

+ func BuildMintNFO(collection string, token []byte, hash crypto.Hash) []byte

+ func DecodeMixinExtra(memo string) *mixinExtraPack

+ func EncodeMixinExtra(groupId, traceId, memo string) string

+ func MsgpackMarshalPanic(val any) []byte

+ func MsgpackUnmarshal(data []byte, val any) error

+ type Action struct

+ CreatedAt time.Time

+ State int

+ UTXOID string

+ type Clock struct

+ func NewClock(store Store) (*Clock, error)

+ func (c *Clock) Now() time.Time

+ type CollectibleOutput struct

+ Amount decimal.Decimal

+ CreatedAt time.Time

+ Memo string

+ OutputId string

+ OutputIndex int

+ Receivers []string

+ ReceiversThreshold int64

+ Senders []string

+ SendersThreshold int64

+ SignedBy string

+ SignedTx string

+ State int

+ TokenId string

+ TransactionHash crypto.Hash

+ Type string

+ UpdatedAt time.Time

+ UserId string

+ func (o *CollectibleOutput) Unified() *UnifiedOutput

+ func (out *CollectibleOutput) StateName() string

+ type CollectibleTransaction struct

+ Amount string

+ Hash crypto.Hash

+ NFO []byte

+ Raw []byte

+ Receivers []string

+ State int

+ Threshold int

+ TokenId string

+ TraceId string

+ UpdatedAt time.Time

+ type Configuration struct

+ App struct{ ... }

+ Genesis struct{ ... }

+ GroupSize int

+ func Setup(path string) (*Configuration, error)

+ type Group struct

+ func BuildGroup(ctx context.Context, store Store, conf *Configuration) (*Group, error)

+ func (grp *Group) AddNode(id string, threshold int, timestamp time.Time) error

+ func (grp *Group) AddWorker(wkr Worker)

+ func (grp *Group) BuildCollectibleMintTransaction(ctx context.Context, receivers []string, threshold int, nfo []byte) error

+ func (grp *Group) BuildCollectibleTransferTransaction(ctx context.Context, receivers []string, threshold int, memo string, ...) error

+ func (grp *Group) BuildTransaction(ctx context.Context, assetId string, receivers []string, threshold int, ...) error

+ func (grp *Group) GenesisId() string

+ func (grp *Group) GetMembers() []string

+ func (grp *Group) GetThreshold() int

+ func (grp *Group) ListActiveNodes() ([]string, int, time.Time, error)

+ func (grp *Group) ListOutputsForAsset(groupId, assetId, state string, limit int) ([]*Output, error)

+ func (grp *Group) RemoveNode(id string, threshold int, timestamp time.Time) error

+ func (grp *Group) Run(ctx context.Context)

+ func (grp *Group) SetOutputGrouper(per func(out *Output) string)

+ type Iteration struct

+ Action int

+ CreatedAt time.Time

+ NodeId string

+ Threshold int

+ type NFOMemo struct

+ Chain uuid.UUID

+ Class []byte

+ Collection uuid.UUID

+ Extra []byte

+ Mask uint64

+ Prefix string

+ Token []byte

+ Version byte

+ func DecodeNFOMemo(b []byte) (*NFOMemo, error)

+ func (nm *NFOMemo) Encode() []byte

+ func (nm *NFOMemo) Indexes() []int

+ func (nm *NFOMemo) Mark(indexes []int)

+ func (nm *NFOMemo) WillMint() bool

+ type Output struct

+ Amount decimal.Decimal

+ AssetID string

+ CreatedAt time.Time

+ GroupId string

+ Members []string

+ Memo string

+ OutputIndex int

+ Sender string

+ SignedBy string

+ SignedTx string

+ State int

+ Threshold uint8

+ TransactionHash crypto.Hash

+ UTXOID string

+ UpdatedAt time.Time

+ UserID string

+ func (o *Output) Unified() *UnifiedOutput

+ func (out *Output) StateName() string

+ type Store interface

+ ListActions func(limit int) ([]*UnifiedOutput, error)

+ ListCollectibleOutputsForToken func(state, tokenId string, limit int) ([]*CollectibleOutput, error)

+ ListCollectibleOutputsForTransaction func(traceId string) ([]*CollectibleOutput, error)

+ ListCollectibleTransactions func(state int, limit int) ([]*CollectibleTransaction, error)

+ ListIterations func() ([]*Iteration, error)

+ ListOutputsForAsset func(groupId string, state, assetId string, limit int) ([]*Output, error)

+ ListOutputsForTransaction func(traceId string) ([]*Output, error)

+ ListTransactions func(state int, limit int) ([]*Transaction, error)

+ ReadCollectibleTransaction func(traceId string) (*CollectibleTransaction, error)

+ ReadCollectibleTransactionByHash func(hash crypto.Hash) (*CollectibleTransaction, error)

+ ReadProperty func(key []byte) ([]byte, error)

+ ReadTransactionByHash func(hash crypto.Hash) (*Transaction, error)

+ ReadTransactionByTraceId func(traceId string) (*Transaction, error)

+ WriteAction func(act *Action) error

+ WriteCollectibleOutput func(utxo *CollectibleOutput, traceId string) error

+ WriteCollectibleOutputs func(utxos []*CollectibleOutput, traceId string) error

+ WriteCollectibleTransaction func(traceId string, tx *CollectibleTransaction) error

+ WriteIteration func(ir *Iteration) error

+ WriteOutput func(utxo *Output, traceId string) error

+ WriteOutputs func(utxos []*Output, traceId string) error

+ WriteProperty func(key, val []byte) error

+ WriteTransaction func(tx *Transaction) error

+ type Transaction struct

+ Amount string

+ AssetId string

+ GroupId string

+ Hash crypto.Hash

+ Memo string

+ Raw []byte

+ Receivers []string

+ State int

+ Threshold int

+ TraceId string

+ UpdatedAt time.Time

+ type UnifiedOutput struct

+ Amount decimal.Decimal

+ CreatedAt time.Time

+ Memo string

+ OutputIndex int

+ SignedBy string

+ SignedTx string

+ State string

+ TransactionHash crypto.Hash

+ Type string

+ UnifiedAssetId string

+ UnifiedMembers []string

+ UnifiedOutputId string

+ UnifiedReceivers []string

+ UnifiedReceiversThreshold int64

+ UnifiedSender string

+ UnifiedSenders []string

+ UnifiedSendersThreshold int64

+ UnifiedThreshold int64

+ UnifiedTokenId string

+ UnifiedUTXOID string

+ UpdatedAt time.Time

+ UserId string

+ func (o *UnifiedOutput) AsCollectible() *CollectibleOutput

+ func (o *UnifiedOutput) AsMultisig() *Output

+ func (o *UnifiedOutput) UniqueId() string

+ type Worker interface

+ ProcessCollectibleOutput func(context.Context, *CollectibleOutput)

+ ProcessOutput func(context.Context, *Output)