selector

Documentation

Index

• func NewManager(locker Locker, newQueryEngine NewQueryEngineFunc, numRetry int, ...) *manager
• func NewProvider(sp view.ServiceProvider, lockerProvider LockerProvider, numRetry int, ...) *selectorService
• type Cache
• type Locker
• type LockerProvider
• type MetricsAgent
• type NewQueryEngineFunc
• type QueryService
• type Repository
• type Transaction

Functions

func NewManager

func NewManager(
	locker Locker,
	newQueryEngine NewQueryEngineFunc,
	numRetry int,
	timeout time.Duration,
	requestCertification bool,
	precision uint64,
	metricsAgent MetricsAgent,
) *manager

func NewProvider

func NewProvider(sp view.ServiceProvider, lockerProvider LockerProvider, numRetry int, timeout time.Duration) *selectorService

Types

type Cache

type Cache interface {
	Get(key string) (interface{}, bool)
	Add(key string, value interface{})
}

type Locker

type Locker interface {
	Lock(id *token2.ID, txID string, reclaim bool) (string, error)
	UnlockIDs(id ...*token2.ID)
	UnlockByTxID(txID string)
	IsLocked(id *token2.ID) bool
}

type LockerProvider

type LockerProvider interface {
	New(network, channel, namespace string) Locker
}

type MetricsAgent

type MetricsAgent interface {
	EmitKey(val float32, event ...string)
}

type NewQueryEngineFunc

type NewQueryEngineFunc func() QueryService

type QueryService

type QueryService interface {
	UnspentTokensIterator() (*token.UnspentTokensIterator, error)
	UnspentTokensIteratorBy(id, typ string) (*token.UnspentTokensIterator, error)
	GetTokens(inputs ...*token2.ID) ([]*token2.Token, error)
}

type Repository

type Repository interface {
	Next(typ string, of token.OwnerFilter) (*token2.UnspentToken, error)
}

type Transaction

type Transaction interface {
	ID() string
	Network() string
	Channel() string
	Namespace() string
}