bridge_pending_activity

Documentation

Index

• Constants
• type BridgePendingActivity
  • func NewBridgePendingActivity(logger applogger.Logger, rdbConn rdb.Conn, config *appprojection.Config) *BridgePendingActivity
  • func (projection *BridgePendingActivity) Config() *Config
  • func (_ *BridgePendingActivity) GetEventsToListen() []string
  • func (projection *BridgePendingActivity) HandleEvents(height int64, events []event_entity.Event) error
  • func (projection *BridgePendingActivity) OnInit() error
• type Config

Constants

const (
	MIGRATION_TABLE_NAME = "bridge_pending_activity_schema_migrations"
	MIGRATION_DIRECOTRY  = "projection/bridge_activity/bridge_pending_activity/migrations"
)

Types

type BridgePendingActivity

type BridgePendingActivity struct {
	*rdbprojectionbase.Base
	// contains filtered or unexported fields
}

func NewBridgePendingActivity

func NewBridgePendingActivity(
	logger applogger.Logger,
	rdbConn rdb.Conn,
	config *appprojection.Config,
) *BridgePendingActivity

func (*BridgePendingActivity) Config

func (projection *BridgePendingActivity) Config() *Config

func (*BridgePendingActivity) GetEventsToListen

func (_ *BridgePendingActivity) GetEventsToListen() []string

func (*BridgePendingActivity) HandleEvents

func (projection *BridgePendingActivity) HandleEvents(height int64, events []event_entity.Event) error

func (*BridgePendingActivity) OnInit

func (projection *BridgePendingActivity) OnInit() error

type Config

type Config struct {
	ThisChainId           string `mapstructure:"this_chain_id"`
	ThisChainName         string `mapstructure:"this_chain_name"`
	CounterpartyChainName string `mapstructure:"counterparty_chain_name"`
	ChannelId             string `mapstructure:"channel_id"`
	StartingHeight        int64  `mapstructure:"starting_height"`
}