convenience

Documentation

Index

• type Container
  • func NewContainer(db sqlx.DB) *Container
  • func (c *Container) GetConvenienceService() *services.ConvenienceService
  • func (c *Container) GetGraphQLSynchronizer() *synchronizer.Synchronizer
  • func (c *Container) GetNoticeRepository() *repository.NoticeRepository
  • func (c *Container) GetOutputDecoder() *decoder.OutputDecoder
  • func (c *Container) GetRepository() *repository.VoucherRepository
  • func (c *Container) GetSyncRepository() *repository.SynchronizerRepository
  • func (c *Container) GetVoucherFetcher() *synchronizer.VoucherFetcher
• type VoucherExecListener
  • func NewExecListener(provider string, applicationAddress common.Address, ...) VoucherExecListener
  • func (x *VoucherExecListener) GetEventData(vLog types.Log, client *ethclient.Client, contractABI abi.ABI) (uint64, uint64, []interface{}, error)
  • func (x *VoucherExecListener) HandleLog(vLog types.Log, client *ethclient.Client, contractABI abi.ABI) error
  • func (x VoucherExecListener) OnEvent(eventValues []interface{}, timestamp, blockNumber uint64) error
  • func (x VoucherExecListener) Start(ctx context.Context, ready chan<- struct{}) error
  • func (x VoucherExecListener) String() string
  • func (x *VoucherExecListener) WatchExecutions(ctx context.Context, client *ethclient.Client) error

Types

type Container

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

func NewContainer

func NewContainer(db sqlx.DB) *Container

func (*Container) GetConvenienceService

func (c *Container) GetConvenienceService() *services.ConvenienceService

func (*Container) GetGraphQLSynchronizer

func (c *Container) GetGraphQLSynchronizer() *synchronizer.Synchronizer

func (*Container) GetNoticeRepository

func (c *Container) GetNoticeRepository() *repository.NoticeRepository

func (*Container) GetOutputDecoder

func (c *Container) GetOutputDecoder() *decoder.OutputDecoder

func (*Container) GetRepository

func (c *Container) GetRepository() *repository.VoucherRepository

func (*Container) GetSyncRepository

func (c *Container) GetSyncRepository() *repository.SynchronizerRepository

func (*Container) GetVoucherFetcher

func (c *Container) GetVoucherFetcher() *synchronizer.VoucherFetcher

type VoucherExecListener

type VoucherExecListener struct {
	Provider           string
	ApplicationAddress common.Address
	AbiString          string
	EventName          string
	ConvenienceService *services.ConvenienceService
	FromBlock          *big.Int
}

func NewExecListener

func NewExecListener(
	provider string,
	applicationAddress common.Address,
	convenienceService *services.ConvenienceService,
	fromBlock *big.Int,
) VoucherExecListener

func (*VoucherExecListener) GetEventData

func (x *VoucherExecListener) GetEventData(
	vLog types.Log,
	client *ethclient.Client,
	contractABI abi.ABI,
) (uint64, uint64, []interface{}, error)

func (*VoucherExecListener) HandleLog

func (x *VoucherExecListener) HandleLog(
	vLog types.Log,
	client *ethclient.Client,
	contractABI abi.ABI,
) error

func (VoucherExecListener) OnEvent

func (x VoucherExecListener) OnEvent(
	eventValues []interface{},
	timestamp,
	blockNumber uint64,
) error

on event callback

func (VoucherExecListener) Start

func (x VoucherExecListener) Start(ctx context.Context, ready chan<- struct{}) error

func (VoucherExecListener) String

func (x VoucherExecListener) String() string

String implements supervisor.Worker.

func (*VoucherExecListener) WatchExecutions

func (x *VoucherExecListener) WatchExecutions(ctx context.Context, client *ethclient.Client) error