mtg

Dec 2, 2025

Changes in this version

type SQLite3Store

+ func (s *SQLite3Store) ReadOutputById(ctx context.Context, id string) (*UnifiedOutput, error)

type SafeUtxoState

+ const SafeUtxoStateUnreceived

Aug 21, 2025

Changes in this version

type Group

+ func (grp *Group) ReadFinishedTxHashByTraceId(ctx context.Context, id string) string

Jul 11, 2025

Changes in this version

type Action

+ func (a *Action) Restored() bool

type Group

+ func (grp *Group) TestUpdateOutputsState(ctx context.Context, os []*UnifiedOutput, state string) error

type SQLite3Store

+ func (s *SQLite3Store) TestUpdateOutputsState(ctx context.Context, os []*UnifiedOutput, state string) error

Jun 4, 2025

Changes in this version

+ func MigrateSchema(ctx context.Context, s *SQLite3Store) error

type UnifiedOutput

+ DepositHash sql.NullString

+ DepositIndex sql.NullInt64

May 20, 2025

Changes in this version

+ const MixinFeeUserId

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

type Action

+ func (act *Action) BuildWithdrawTransaction(ctx context.Context, traceId, assetId, amount, memo, destination, tag string) *Transaction

type Group

+ func (grp *Group) ListConfirmedWithdrawalTransactionsAfter(ctx context.Context, offset time.Time, limit int) []*Transaction

+ func (grp *Group) ListOutputsByTransactionHash(ctx context.Context, hash string, sequence uint64) []*UnifiedOutput

+ func (grp *Group) ListUnconfirmedWithdrawalTransactions(ctx context.Context, limit int) []*Transaction

type SQLite3Store

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

+ func (s *SQLite3Store) GetConsumedIds(ctx context.Context, tx *Transaction) error

+ func (s *SQLite3Store) ListConfirmedWithdrawalTransactionsAfter(ctx context.Context, offset time.Time, limit int) ([]*Transaction, error)

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

+ func (s *SQLite3Store) ListUnconfirmedWithdrawalTransactions(ctx context.Context, limit int) ([]*Transaction, error)

+ func (s *SQLite3Store) Migrate(ctx context.Context) error

+ type SafeTransactionReceiver struct

+ Destination string

+ MemberHash string

+ Members []string

+ Tag string

+ Threshold uint8

+ WithdrawalHash string

+ type SafeTransactionRequest struct

+ Amount decimal.Decimal

+ Asset mixinnet.Hash

+ AssetID mixinnet.Hash

+ CreatedAt time.Time

+ Extra string

+ KernelAssetID mixinnet.Hash

+ RawTransaction string

+ Receivers []*SafeTransactionReceiver

+ RequestID string

+ RevokedBy string

+ Senders []string

+ SendersHash string

+ SendersThreshold uint8

+ Signers []string

+ SnapshotAt *time.Time

+ SnapshotHash string

+ State SafeUtxoState

+ TransactionHash string

+ UpdatedAt time.Time

+ UserID string

+ Views []mixinnet.Key

type Transaction

+ ActionId string

+ Destination sql.NullString

+ Tag sql.NullString

+ WithdrawalHash sql.NullString

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

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

+ func (t *Transaction) IsNormal() bool

+ func (t *Transaction) IsStorage() bool

+ func (t *Transaction) IsWithdrawal() bool

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

type TransactionRecipient

+ Destination string

+ Tag string

Mar 11, 2025

Changes in this version

+ const IterationActionAdd

+ const IterationActionRemove

+ const OutputsBatchSize

+ const StorageAssetId

+ const TransactionStateInitial

+ const TransactionStateSigned

+ const TransactionStateSnapshot

+ var SCHEMA string

+ func CheckRetryableError(err error) bool

+ func CheckTestEnvironment(ctx context.Context) bool

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

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

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

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

+ func ExpandTilde(path string) string

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

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

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

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

+ func UniqueId(a, b string) string

+ type Action struct

+ ActionState ActionState

+ 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 ActionState int

+ const ActionStateDone

+ const ActionStateInitial

+ const ActionStateRestorable

+ type Configuration struct

+ App struct{ ... }

+ Genesis struct{ ... }

+ GroupSize int

+ LoopWaitDuration int64

+ Project string

+ StoreDir string

+ type DepositEntry struct

+ Destination string

+ Tag string

+ func (e DepositEntry) UniqueKey() string

+ type Group struct

+ GroupId string

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

+ func (grp *Group) AddNode(ctx context.Context, id string, threshold int, epoch uint64) error

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

+ func (grp *Group) EnableDebug()

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

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

+ func (grp *Group) GenesisId() string

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

+ func (grp *Group) GetThreshold() int

+ func (grp *Group) Index() int

+ func (grp *Group) ListActiveNodes(ctx context.Context) ([]string, int, uint64, error)

+ func (grp *Group) ListOutputsForAsset(ctx context.Context, appId, assetId string, consumedUntil, sequence uint64, ...) []*UnifiedOutput

+ func (grp *Group) ListOutputsForTransaction(ctx context.Context, traceId string, sequence uint64) []*UnifiedOutput

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

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

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

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

+ func (grp *Group) Synced(ctx context.Context) bool

+ type Iteration struct

+ Action int

+ CreatedAt uint64

+ NodeId string

+ Threshold 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, consumedUntil, 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) ReadCache(ctx context.Context, k string) (string, error)

+ func (s *SQLite3Store) ReadOutputByHashAndIndex(ctx context.Context, hash string, index uint) (*UnifiedOutput, 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, act *Action, 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) WriteCache(ctx context.Context, k, v string) 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 SafeUtxoStateAssigned

+ const SafeUtxoStateSigned

+ const SafeUtxoStateSpent

+ const SafeUtxoStateUnspent

+ type Transaction struct

+ Amount string

+ AppId string

+ AssetId string

+ Hash crypto.Hash

+ Memo string

+ OpponentAppId string

+ Raw []byte

+ Receivers []string

+ Sequence uint64

+ State int

+ Threshold int

+ TraceId string

+ UpdatedAt time.Time

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

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

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

+ func (tx *Transaction) RequestID() string

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

+ type TransactionRecipient struct

+ Amount string

+ MixAddress *mixin.MixAddress

+ UuidMember bool

+ type UnifiedOutput struct

+ Amount decimal.Decimal

+ AppId string

+ AssetId string

+ Extra string

+ KernelAssetId string

+ OutputId string

+ OutputIndex int

+ ReceiversHash string

+ ReceiversThreshold int64

+ Senders []string

+ SendersHash string

+ SendersThreshold int64

+ Sequence uint64

+ SequencerCreatedAt time.Time

+ SignedBy string

+ Signers []string

+ State SafeUtxoState

+ TraceId string

+ TransactionHash string

+ TransactionRequestId string

+ Type string

+ type Worker interface

+ ProcessOutput func(context.Context, *Action) ([]*Transaction, string)