mtg

Aug 12, 2024

Changes in this version

type UnifiedOutput

+ SequencerCreatedAt time.Time

Aug 12, 2024

Changes in this version

+ func GetKernelTransaction(rpc, hash string) (*common.VersionedTransaction, string, error)

type Action

+ func (a *Action) TestAttachActionToGroup(g *Group)

+ func (act *Action) BuildStorageTransaction(ctx context.Context, extra []byte) *Transaction

+ func (act *Action) BuildTransaction(ctx context.Context, traceId, opponentAppId, assetId, amount, memo string, ...) *Transaction

+ func (act *Action) BuildTransactionWithReference(ctx context.Context, traceId, opponentAppId, assetId, amount, memo string, ...) *Transaction

+ func (act *Action) BuildTransactionWithStorageTraceId(ctx context.Context, traceId, opponentAppId, assetId, amount, memo string, ...) *Transaction

+ func (act *Action) CheckAssetBalanceAt(ctx context.Context, assetId string) decimal.Decimal

+ func (act *Action) CheckAssetBalanceForStorageAt(ctx context.Context, extra []byte) bool

type Group

+ func (grp *Group) ReadKernelTransactionUntilSufficient(ctx context.Context, txHash string) (*common.VersionedTransaction, error)

+ func (grp *Group) SetKernelRPC(rpc string)

type SQLite3Store

+ func (s *SQLite3Store) ReadCache(ctx context.Context, k string) (string, error)

+ func (s *SQLite3Store) WriteCache(ctx context.Context, k, v string) error

type SafeUtxoState

+ const SafeUtxoStateAssigned

type UnifiedOutput

+ TransactionRequestId string

Aug 4, 2024

Changes in this version

type Transaction

+ func (tx *Transaction) RequestID() string

Aug 4, 2024

Changes in this version

type SQLite3Store

+ func (s *SQLite3Store) ReadOutputByHashAndIndex(ctx context.Context, hash string, index uint) (*UnifiedOutput, error)

Jul 10, 2024

Changes in this version

+ func ReplayCheck(a *Action, txs1, txs2 []*Transaction, asset1, asset2 string)

type Transaction

+ func Deserialize(rb []byte) (*Transaction, error)

+ func (tx *Transaction) Serialize() []byte

Jul 9, 2024

Changes in this version

+ func SerializeTransactions(txs []*Transaction) []byte

type Group

+ func (grp *Group) EnableDebug()

type Transaction

+ func DeserializeTransactions(tb []byte) ([]*Transaction, error)

+ func (t *Transaction) Equal(tx *Transaction) bool

Jul 5, 2024

Changes in this version

type Group

+ func (grp *Group) CheckAssetBalanceForStorageAt(ctx context.Context, appId string, extra []byte, sequence uint64) bool

Jul 4, 2024

Changes in this version

+ func DecodeMixinExtraBase64(extra string) (string, []byte)

+ func DecodeMixinExtraHEX(memo string) (string, []byte)

+ func EncodeMixinExtraBase64(appId string, extra []byte) string

Jul 2, 2024

Changes in this version

+ var SCHEMA string

+ func CheckRetryableError(err error) bool

+ func CheckTestEnvironment(ctx context.Context) bool

+ func EnableTestEnvironment(ctx context.Context) context.Context

+ func ExpandTilde(path string) string

+ func NewMixAddress(ctx context.Context, members []string, threshold byte, storage bool) (*mixin.MixAddress, bool, error)

+ func UniqueId(a, b string) string

type Action

+ ActionState ActionState

+ OutputId string

+ Sequence uint64

+ TransactionHash string

+ type ActionState int

+ const ActionStateRestorable

type Configuration

+ Project string

+ StoreDir string

+ type DepositEntry struct

+ Destination string

+ Tag string

+ func (e DepositEntry) UniqueKey() string

type Group

+ GroupId string

+ func (grp *Group) AttachWorker(appId string, wkr Worker)

+ func (grp *Group) BuildTransactionWithReference(traceId, opponentAppId, assetId, amount, memo string, receivers []string, ...) *Transaction

+ func (grp *Group) BuildTransactionWithStorageTraceId(traceId, opponentAppId, assetId, amount, memo string, receivers []string, ...) *Transaction

+ func (grp *Group) CheckAssetBalanceAt(ctx context.Context, appId, assetId string, sequence uint64) (decimal.Decimal, error)

+ func (grp *Group) FindAppByEntry(entry string) string

+ func (grp *Group) FindWorker(appId string) Worker

+ func (grp *Group) RegisterDepositEntry(appId string, entry DepositEntry)

+ func (node *Group) Index() int

+ type Row interface

+ Scan func(dest ...any) error

+ type SQLite3Store struct

+ func OpenSQLite3Store(path string) (*SQLite3Store, error)

+ func (s *SQLite3Store) Close() error

+ func (s *SQLite3Store) FinishAction(ctx context.Context, id string, state ActionState, ts []*Transaction) error

+ func (s *SQLite3Store) FinishTransaction(ctx context.Context, traceId string) error

+ func (s *SQLite3Store) ListActions(ctx context.Context, state ActionState, limit int) ([]*Action, error)

+ func (s *SQLite3Store) ListIterations(ctx context.Context) ([]*Iteration, error)

+ func (s *SQLite3Store) ListOutputsForAsset(ctx context.Context, appId, assetId string, sequence uint64, ...) ([]*UnifiedOutput, error)

+ func (s *SQLite3Store) ListOutputsForTransaction(ctx context.Context, traceId string, sequence uint64) ([]*UnifiedOutput, error)

+ func (s *SQLite3Store) ListPreviousInitialTransactions(ctx context.Context, asset string, sequence uint64) ([]*Transaction, error)

+ func (s *SQLite3Store) ListTransactions(ctx context.Context, state, limit int) ([]*Transaction, map[string][]*Transaction, error)

+ func (s *SQLite3Store) ReadProperty(ctx context.Context, k string) (string, error)

+ func (s *SQLite3Store) ReadTransactionByHash(ctx context.Context, hash crypto.Hash) (*Transaction, error)

+ func (s *SQLite3Store) ReadTransactionByTraceId(ctx context.Context, id string) (*Transaction, error)

+ func (s *SQLite3Store) RestoreAction(ctx context.Context, out *UnifiedOutput, t *Transaction) error

+ func (s *SQLite3Store) UpdateTxWithOutputs(ctx context.Context, t *Transaction, os []*UnifiedOutput) error

+ func (s *SQLite3Store) WriteAction(ctx context.Context, out *UnifiedOutput, state ActionState) error

+ func (s *SQLite3Store) WriteIteration(ctx context.Context, ir *Iteration) error

+ func (s *SQLite3Store) WriteProperty(ctx context.Context, k, v string) error

+ type SafeDepositView struct

+ DepositHash string

+ DepositIndex int64

+ Destination string

+ Sender string

+ Tag string

+ type SafeUtxoState string

+ const OutputTypeSafeOutput

+ const SafeUtxoStateSigned

+ const SafeUtxoStateSpent

+ const SafeUtxoStateUnspent

type Transaction

+ AppId string

+ Compaction bool

+ OpponentAppId string

+ Sequence uint64

+ Storage bool

+ StorageTraceId string

+ type TransactionRecipient struct

+ Amount string

+ MixAddress *mixin.MixAddress

+ UuidMember bool

type UnifiedOutput

+ AppId string

+ AssetId string

+ Extra string

+ KernelAssetId string

+ Keys []string

+ Mask string

+ OutputId string

+ Receivers []string

+ ReceiversHash string

+ ReceiversThreshold int64

+ RequestId string

+ Senders []string

+ SendersHash string

+ SendersThreshold int64

+ Sequence uint64

+ Signers []string

+ TraceId string

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)