bridge_pending_activity

Documentation

Index

• Constants
• Variables
• type BridgePendingActivity
  • func New(config Config, logger applogger.Logger, rdbConn rdb.Conn, ...) *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 ChannelId
• type Config
  • func ConfigFromInterface(data interface{}) (Config, error)
• type CounterPartyChainConfig

Constants

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

Variables

var (
	NewBridgePendingActivitiesView = bridge_pending_activity_view.NewBridgePendingActivitiesView
	UpdateLastHandledEventHeight   = (*BridgePendingActivity).UpdateLastHandledEventHeight
)

Types

type BridgePendingActivity

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

func New

func New(
	config Config,
	logger applogger.Logger,
	rdbConn rdb.Conn,
	migrationHelper migrationhelper.MigrationHelper,
) *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 ChannelId

type ChannelId = string

type Config

type Config struct {
	ThisChainName      string                    `mapstructure:"this_chain_name"`
	CounterPartyChains []CounterPartyChainConfig `mapstructure:"counterparty_chains"`
}

func ConfigFromInterface

func ConfigFromInterface(data interface{}) (Config, error)

type CounterPartyChainConfig

type CounterPartyChainConfig struct {
	ChainName      string `mapstructure:"name"`
	ChannelId      string `mapstructure:"channel_id"`
	StartingHeight int64  `mapstructure:"starting_height"`
}