convenience

Documentation

Index

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

Types

type Container

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

func NewContainer

func NewContainer(db sqlx.DB, autoCount bool) *Container

func (*Container) GetConvenienceService

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

func (*Container) GetGraphQLSynchronizer

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

func (*Container) GetInputRepository

func (c *Container) GetInputRepository() *repository.InputRepository

func (*Container) GetNoticeRepository

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

func (*Container) GetOutputDecoder

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

func (*Container) GetOutputRepository

func (c *Container) GetOutputRepository() *repository.OutputRepository

func (*Container) GetRawInputRepository

func (c *Container) GetRawInputRepository() *repository.RawInputRefRepository

func (*Container) GetRawOutputRefRepository

func (c *Container) GetRawOutputRefRepository() *repository.RawOutputRefRepository

func (*Container) GetReportRepository

func (c *Container) GetReportRepository() *repository.ReportRepository

func (*Container) GetSyncRepository

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

func (*Container) GetVoucherFetcher

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

func (*Container) GetVoucherRepository

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

type OutputExecListener

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

func NewExecListener

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

func (*OutputExecListener) GetEventData

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

func (*OutputExecListener) HandleLog

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

func (OutputExecListener) OnEvent

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

on event callback

func (*OutputExecListener) ReadPastExecutions

func (x *OutputExecListener) ReadPastExecutions(ctx context.Context, client *ethclient.Client, contractABI abi.ABI, query ethereum.FilterQuery) error

func (OutputExecListener) Start

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

func (OutputExecListener) String

func (x OutputExecListener) String() string

String implements supervisor.Worker.

func (*OutputExecListener) WatchExecutions

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