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)
  • func (worker *Worker) ProcessOutput(ctx context.Context, out *mtg.Output)

Constants

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

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)

func (*Worker) ProcessOutput

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