coordinator

Documentation

Index

• type Handler
  • func NewHandler(t mockConstructorTestingTNewHandler) *Handler
  • func (_m *Handler) TransactionCreated(_a0 context.Context, _a1 string, _a2 *types.TransactionIdentifier) error
• type Helper
  • func NewHelper(t mockConstructorTestingTNewHelper) *Helper
  • func (_m *Helper) AllAccounts(_a0 context.Context, _a1 database.Transaction) ([]*types.AccountIdentifier, error)
  • func (_m *Helper) Balance(_a0 context.Context, _a1 database.Transaction, _a2 *types.AccountIdentifier, ...) (*types.Amount, error)
  • func (_m *Helper) Broadcast(_a0 context.Context, _a1 database.Transaction, _a2 string, ...) error
  • func (_m *Helper) BroadcastAll(_a0 context.Context) error
  • func (_m *Helper) Coins(_a0 context.Context, _a1 database.Transaction, _a2 *types.AccountIdentifier, ...) ([]*types.Coin, error)
  • func (_m *Helper) Combine(_a0 context.Context, _a1 *types.NetworkIdentifier, _a2 string, ...) (string, error)
  • func (_m *Helper) DatabaseTransaction(_a0 context.Context) database.Transaction
  • func (_m *Helper) Derive(_a0 context.Context, _a1 *types.NetworkIdentifier, _a2 *types.PublicKey, ...) (*types.AccountIdentifier, map[string]interface{}, error)
  • func (_m *Helper) GetBlob(ctx context.Context, dbTx database.Transaction, key string) (bool, []byte, error)
  • func (_m *Helper) GetKey(_a0 context.Context, _a1 database.Transaction, _a2 *types.AccountIdentifier) (*keys.KeyPair, error)
  • func (_m *Helper) Hash(_a0 context.Context, _a1 *types.NetworkIdentifier, _a2 string) (*types.TransactionIdentifier, error)
  • func (_m *Helper) HeadBlockExists(_a0 context.Context) bool
  • func (_m *Helper) LockedAccounts(_a0 context.Context, _a1 database.Transaction) ([]*types.AccountIdentifier, error)
  • func (_m *Helper) Metadata(_a0 context.Context, _a1 *types.NetworkIdentifier, _a2 map[string]interface{}, ...) (map[string]interface{}, []*types.Amount, error)
  • func (_m *Helper) Parse(_a0 context.Context, _a1 *types.NetworkIdentifier, _a2 bool, _a3 string) ([]*types.Operation, []*types.AccountIdentifier, map[string]interface{}, error)
  • func (_m *Helper) Payloads(_a0 context.Context, _a1 *types.NetworkIdentifier, _a2 []*types.Operation, ...) (string, []*types.SigningPayload, error)
  • func (_m *Helper) Preprocess(_a0 context.Context, _a1 *types.NetworkIdentifier, _a2 []*types.Operation, ...) (map[string]interface{}, []*types.AccountIdentifier, error)
  • func (_m *Helper) SetBlob(ctx context.Context, dbTx database.Transaction, key string, value []byte) error
  • func (_m *Helper) Sign(_a0 context.Context, _a1 []*types.SigningPayload) ([]*types.Signature, error)
  • func (_m *Helper) StoreKey(_a0 context.Context, _a1 database.Transaction, _a2 *types.AccountIdentifier, ...) error
• type JobStorage
  • func NewJobStorage(t mockConstructorTestingTNewJobStorage) *JobStorage
  • func (_m *JobStorage) Broadcasting(_a0 context.Context, _a1 database.Transaction) ([]*job.Job, error)
  • func (_m *JobStorage) Get(_a0 context.Context, _a1 database.Transaction, _a2 string) (*job.Job, error)
  • func (_m *JobStorage) Processing(_a0 context.Context, _a1 database.Transaction, _a2 string) ([]*job.Job, error)
  • func (_m *JobStorage) Ready(_a0 context.Context, _a1 database.Transaction) ([]*job.Job, error)
  • func (_m *JobStorage) Update(_a0 context.Context, _a1 database.Transaction, _a2 *job.Job) (string, error)

Types

type Handler

type Handler struct {
	mock.Mock
}

Handler is an autogenerated mock type for the Handler type

func NewHandler

func NewHandler(t mockConstructorTestingTNewHandler) *Handler

NewHandler creates a new instance of Handler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Handler) TransactionCreated

func (_m *Handler) TransactionCreated(_a0 context.Context, _a1 string, _a2 *types.TransactionIdentifier) error

TransactionCreated provides a mock function with given fields: _a0, _a1, _a2

type Helper

type Helper struct {
	mock.Mock
}

Helper is an autogenerated mock type for the Helper type

func NewHelper

func NewHelper(t mockConstructorTestingTNewHelper) *Helper

NewHelper creates a new instance of Helper. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Helper) AllAccounts

func (_m *Helper) AllAccounts(_a0 context.Context, _a1 database.Transaction) ([]*types.AccountIdentifier, error)

AllAccounts provides a mock function with given fields: _a0, _a1

func (*Helper) Balance

func (_m *Helper) Balance(_a0 context.Context, _a1 database.Transaction, _a2 *types.AccountIdentifier, _a3 *types.Currency) (*types.Amount, error)

Balance provides a mock function with given fields: _a0, _a1, _a2, _a3

func (*Helper) Broadcast

func (_m *Helper) Broadcast(_a0 context.Context, _a1 database.Transaction, _a2 string, _a3 *types.NetworkIdentifier, _a4 []*types.Operation, _a5 *types.TransactionIdentifier, _a6 string, _a7 int64, _a8 map[string]interface{}) error

Broadcast provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4, _a5, _a6, _a7, _a8

func (*Helper) BroadcastAll

func (_m *Helper) BroadcastAll(_a0 context.Context) error

BroadcastAll provides a mock function with given fields: _a0

func (*Helper) Coins

func (_m *Helper) Coins(_a0 context.Context, _a1 database.Transaction, _a2 *types.AccountIdentifier, _a3 *types.Currency) ([]*types.Coin, error)

Coins provides a mock function with given fields: _a0, _a1, _a2, _a3

func (*Helper) Combine

func (_m *Helper) Combine(_a0 context.Context, _a1 *types.NetworkIdentifier, _a2 string, _a3 []*types.Signature) (string, error)

Combine provides a mock function with given fields: _a0, _a1, _a2, _a3

func (*Helper) DatabaseTransaction

func (_m *Helper) DatabaseTransaction(_a0 context.Context) database.Transaction

DatabaseTransaction provides a mock function with given fields: _a0

func (*Helper) Derive

func (_m *Helper) Derive(_a0 context.Context, _a1 *types.NetworkIdentifier, _a2 *types.PublicKey, _a3 map[string]interface{}) (*types.AccountIdentifier, map[string]interface{}, error)

Derive provides a mock function with given fields: _a0, _a1, _a2, _a3

func (*Helper) GetBlob

func (_m *Helper) GetBlob(ctx context.Context, dbTx database.Transaction, key string) (bool, []byte, error)

GetBlob provides a mock function with given fields: ctx, dbTx, key

func (*Helper) GetKey

func (_m *Helper) GetKey(_a0 context.Context, _a1 database.Transaction, _a2 *types.AccountIdentifier) (*keys.KeyPair, error)

GetKey provides a mock function with given fields: _a0, _a1, _a2

func (*Helper) Hash

func (_m *Helper) Hash(_a0 context.Context, _a1 *types.NetworkIdentifier, _a2 string) (*types.TransactionIdentifier, error)

Hash provides a mock function with given fields: _a0, _a1, _a2

func (*Helper) HeadBlockExists

func (_m *Helper) HeadBlockExists(_a0 context.Context) bool

HeadBlockExists provides a mock function with given fields: _a0

func (*Helper) LockedAccounts

func (_m *Helper) LockedAccounts(_a0 context.Context, _a1 database.Transaction) ([]*types.AccountIdentifier, error)

LockedAccounts provides a mock function with given fields: _a0, _a1

func (*Helper) Metadata

func (_m *Helper) Metadata(_a0 context.Context, _a1 *types.NetworkIdentifier, _a2 map[string]interface{}, _a3 []*types.PublicKey) (map[string]interface{}, []*types.Amount, error)

Metadata provides a mock function with given fields: _a0, _a1, _a2, _a3

func (*Helper) Parse

func (_m *Helper) Parse(_a0 context.Context, _a1 *types.NetworkIdentifier, _a2 bool, _a3 string) ([]*types.Operation, []*types.AccountIdentifier, map[string]interface{}, error)

Parse provides a mock function with given fields: _a0, _a1, _a2, _a3

func (*Helper) Payloads

func (_m *Helper) Payloads(_a0 context.Context, _a1 *types.NetworkIdentifier, _a2 []*types.Operation, _a3 map[string]interface{}, _a4 []*types.PublicKey) (string, []*types.SigningPayload, error)

Payloads provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4

func (*Helper) Preprocess

func (_m *Helper) Preprocess(_a0 context.Context, _a1 *types.NetworkIdentifier, _a2 []*types.Operation, _a3 map[string]interface{}) (map[string]interface{}, []*types.AccountIdentifier, error)

Preprocess provides a mock function with given fields: _a0, _a1, _a2, _a3

func (*Helper) SetBlob

func (_m *Helper) SetBlob(ctx context.Context, dbTx database.Transaction, key string, value []byte) error

SetBlob provides a mock function with given fields: ctx, dbTx, key, value

func (*Helper) Sign

func (_m *Helper) Sign(_a0 context.Context, _a1 []*types.SigningPayload) ([]*types.Signature, error)

Sign provides a mock function with given fields: _a0, _a1

func (*Helper) StoreKey

func (_m *Helper) StoreKey(_a0 context.Context, _a1 database.Transaction, _a2 *types.AccountIdentifier, _a3 *keys.KeyPair) error

StoreKey provides a mock function with given fields: _a0, _a1, _a2, _a3

type JobStorage

type JobStorage struct {
	mock.Mock
}

JobStorage is an autogenerated mock type for the JobStorage type

func NewJobStorage

func NewJobStorage(t mockConstructorTestingTNewJobStorage) *JobStorage

NewJobStorage creates a new instance of JobStorage. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*JobStorage) Broadcasting

func (_m *JobStorage) Broadcasting(_a0 context.Context, _a1 database.Transaction) ([]*job.Job, error)

Broadcasting provides a mock function with given fields: _a0, _a1

func (*JobStorage) Get

func (_m *JobStorage) Get(_a0 context.Context, _a1 database.Transaction, _a2 string) (*job.Job, error)

Get provides a mock function with given fields: _a0, _a1, _a2

func (*JobStorage) Processing

func (_m *JobStorage) Processing(_a0 context.Context, _a1 database.Transaction, _a2 string) ([]*job.Job, error)

Processing provides a mock function with given fields: _a0, _a1, _a2

func (*JobStorage) Ready

func (_m *JobStorage) Ready(_a0 context.Context, _a1 database.Transaction) ([]*job.Job, error)

Ready provides a mock function with given fields: _a0, _a1

func (*JobStorage) Update

func (_m *JobStorage) Update(_a0 context.Context, _a1 database.Transaction, _a2 *job.Job) (string, error)

Update provides a mock function with given fields: _a0, _a1, _a2