custodian

Documentation

Index

• Constants
• Variables
• type SQLite3Store
  • func OpenSQLite3Store(path string) (*SQLite3Store, error)
  • func (s *SQLite3Store) Close() error
  • func (s *SQLite3Store) ReadProperty(ctx context.Context, k string) (string, error)
  • func (s *SQLite3Store) WriteProperty(ctx context.Context, k, v string) error
• type Worker
  • func NewWorker(s *SQLite3Store) *Worker
  • func (worker *Worker) Boot(ctx context.Context)
  • func (worker *Worker) ProcessCollectibleOutput(context.Context, *mtg.CollectibleOutput) bool
  • func (worker *Worker) ProcessOutput(ctx context.Context, out *mtg.Output) bool

Constants

const (
	XINAssetId = "c94ac88f-4671-3976-b60a-09064f1811e8"

	// domain do the first key, next should be from the first key
	CustodianActionRefreshKey = 1
	CustodianActionDistribute = 2

	// every signer node will send this to the mtg
	// everyday at a specific time
	// then at some point, a random output will cause
	// all signer nodes to finalize the works
	CustodianActionVoteWorks = 3
	// then the signer mtg send this action to keeper mtg
	// the custodian will process this then
	CustodianActionFinalizeWorks = 4
)

Variables

var SCHEMA string

Types

type SQLite3Store

type SQLite3Store struct {
	// contains filtered or unexported fields
}

func OpenSQLite3Store

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

func (*SQLite3Store) Close

func (s *SQLite3Store) Close() error

func (*SQLite3Store) ReadProperty

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

func (*SQLite3Store) WriteProperty

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

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(s *SQLite3Store) *Worker

func (*Worker) Boot

func (worker *Worker) Boot(ctx context.Context)

func (*Worker) ProcessCollectibleOutput

func (worker *Worker) ProcessCollectibleOutput(context.Context, *mtg.CollectibleOutput) bool

func (*Worker) ProcessOutput

func (worker *Worker) ProcessOutput(ctx context.Context, out *mtg.Output) bool