bridge_activity_matcher

Documentation

Index

• Constants
• type BridgeActivityMatcher
  • func New(logger applogger.Logger, rdbConn rdb.Conn, config *appprojection.Config) *BridgeActivityMatcher
  • func (cronJob *BridgeActivityMatcher) Config() *Config
  • func (cronJob *BridgeActivityMatcher) Exec() error
  • func (cronJob *BridgeActivityMatcher) HandleIncoming(rows []view.BridgePendingActivityReadRow, ...) error
  • func (cronJob *BridgeActivityMatcher) HandleOutgoing(rows []view.BridgePendingActivityReadRow, ...) error
  • func (cronJob *BridgeActivityMatcher) Id() string
  • func (cronJob *BridgeActivityMatcher) Interval() time.Duration
  • func (cronJob *BridgeActivityMatcher) OnInit() error
• type Config

Constants

const (
	MIGRATION_TABLE_NAME = "bridge_activity_matcher_schema_migrations"
	MIGRATION_DIRECOTRY  = "projection/bridge_activity/bridge_activity_matcher/migrations"
)

Types

type BridgeActivityMatcher

type BridgeActivityMatcher struct {
	projection_usecase.Base
	// contains filtered or unexported fields
}

func New

func New(logger applogger.Logger, rdbConn rdb.Conn, config *appprojection.Config) *BridgeActivityMatcher

func (*BridgeActivityMatcher) Config

func (cronJob *BridgeActivityMatcher) Config() *Config

func (*BridgeActivityMatcher) Exec

func (cronJob *BridgeActivityMatcher) Exec() error

func (*BridgeActivityMatcher) HandleIncoming

func (cronJob *BridgeActivityMatcher) HandleIncoming(
	rows []view.BridgePendingActivityReadRow,
	bridgePendingActivities *view.BridgePendingActivities,
) error

func (*BridgeActivityMatcher) HandleOutgoing

func (cronJob *BridgeActivityMatcher) HandleOutgoing(
	rows []view.BridgePendingActivityReadRow,
	bridgePendingActivities *view.BridgePendingActivities,
) error

func (*BridgeActivityMatcher) Id

func (cronJob *BridgeActivityMatcher) Id() string

func (*BridgeActivityMatcher) Interval

func (cronJob *BridgeActivityMatcher) Interval() time.Duration

func (*BridgeActivityMatcher) OnInit

func (cronJob *BridgeActivityMatcher) OnInit() error

type Config

type Config struct {
	Interval               time.Duration `mapstructure:"interval"`
	CryptoOrgChainDatabase struct {
		SSL      bool   `mapstructure:"ssl"`
		Host     string `mapstructure:"host"`
		Port     int32  `mapstructure:"port"`
		Username string `mapstructure:"username"`
		Password string `mapstructure:"password"`
		Name     string `mapstructure:"name"`
		Schema   string `mapstructure:"schema"`
	} `mapstructure:"crypto_org_chain_database"`
}