scheduler

Documentation

Index

• type ChainClient
• type Context
• type Database
• type Firebase
• type OperationRegistrar
• type Scheduler
  • func New(context Context) *Scheduler
  • func (r *Scheduler) SetOperationsRegistrar(registrar OperationRegistrar)
  • func (r *Scheduler) StartAsync()
  • func (r *Scheduler) Stop()

Types

type ChainClient

type ChainClient interface {
	AccAddress() string
	HasFeeGrant(granteeAddress string, granterAddress string) (bool, error)
	HasGrantedMsgGrantAllowanceAuthorization(appAddress string) (bool, error)
	BroadcastTxCommit(data *wallettypes.TransactionData) (*sdk.TxResponse, error)
}

type Context

type Context struct {
	ChainClient    ChainClient
	FirebaseClient Firebase
	Database       Database
}

Context contains all the data used in order to build and run a Scheduler instance

type Database

type Database interface {
	GetApp(appID string) (*types.Application, bool, error)

	GetNotGrantedFeeGrantRequests(limit int) ([]types.FeeGrantRequest, error)
	SetFeeGrantRequestsGranted(ids []string) error
}

type Firebase

type Firebase interface {
	SendNotificationToApp(appID string, notification types.Notification) error
}

type OperationRegistrar

type OperationRegistrar func(context Context, scheduler *gocron.Scheduler)

type Scheduler

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

func New

func New(context Context) *Scheduler

func (*Scheduler) SetOperationsRegistrar

func (r *Scheduler) SetOperationsRegistrar(registrar OperationRegistrar)

func (*Scheduler) StartAsync

func (r *Scheduler) StartAsync()

func (*Scheduler) Stop

func (r *Scheduler) Stop()