Versions in this module Expand all Collapse all v1 v1.0.1 May 7, 2023 Changes in this version + var ErrUnknownBank = errors.New("bank doesn't exist") + type Account struct + Account *bank.Account + Transactions []*bank.Transaction + TransactionsUpTo time.Time + type Job interface + Credentials func(login, pwd []byte, a <-chan string) (q <-chan string) + Done func() <-chan struct{} + Position func() int + Results func() ([]*Account, error) + Started func() <-chan struct{} + type Queue interface + Set func(ctx context.Context, bank string) (Job, bool) + func NewSimpleQueue(jobTimeout time.Duration, transactionsDoneUpTo time.Duration, cap int32) Queue + type SimpleQueue struct + JobTimeout time.Duration + Queue []*SimpleQueueJob + TransactionsUpTo time.Duration + func (s *SimpleQueue) Position(j *SimpleQueueJob) int32 + func (s *SimpleQueue) Process() + func (s *SimpleQueue) Set(ctx context.Context, bank string) (Job, bool) + type SimpleQueueJob struct + func (s *SimpleQueueJob) Credentials(login, pwd []byte, a <-chan string) (q <-chan string) + func (s *SimpleQueueJob) Done() <-chan struct{} + func (s *SimpleQueueJob) Position() int + func (s *SimpleQueueJob) Results() ([]*Account, error) + func (s *SimpleQueueJob) Started() <-chan struct{} v1.0.0 May 7, 2023
Go to main page