launcher

Documentation

Index

• Variables
• func GetCompressOrderData(order *model.Order) ([]byte, error)
• type Executor
  • func NewExecutor(ctx context.Context, dao dao.DAO, chainCli chain.ChainClient, ...) *Executor
  • func (s *Executor) Run() error
• type Launcher
  • func NewLaunch(ctx context.Context, dao dao.DAO, chainCli chain.ChainClient, ...) *Launcher
  • func (l *Launcher) ImportPrivateKey(pk string) (string, error)
  • func (l *Launcher) Start() error
• type Monitor
  • func NewMonitor(ctx context.Context, dao dao.DAO, chainCli chain.ChainClient, ...) *Monitor
  • func (s *Monitor) Run() error
• type Syncer
  • func NewSyncer(ctx context.Context, dao dao.DAO, chainCli chain.ChainClient, ...) *Syncer
  • func (s *Syncer) Run() error

Variables

var ChannelHWM = 64

Functions

func GetCompressOrderData

func GetCompressOrderData(order *model.Order) ([]byte, error)

Types

type Executor

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

func NewExecutor

func NewExecutor(ctx context.Context, dao dao.DAO, chainCli chain.ChainClient, gm *gasmonitor.GasMonitor, match *match.Server) *Executor

func (*Executor) Run

func (s *Executor) Run() error

type Launcher

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

func NewLaunch

func NewLaunch(ctx context.Context, dao dao.DAO, chainCli chain.ChainClient, match *match.Server, gm *gasmonitor.GasMonitor) *Launcher

func (*Launcher) ImportPrivateKey

func (l *Launcher) ImportPrivateKey(pk string) (string, error)

func (*Launcher) Start

func (l *Launcher) Start() error

type Monitor

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

func NewMonitor

func NewMonitor(ctx context.Context, dao dao.DAO, chainCli chain.ChainClient, match *match.Server) *Monitor

func (*Monitor) Run

func (s *Monitor) Run() error

type Syncer

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

func NewSyncer

func NewSyncer(ctx context.Context, dao dao.DAO, chainCli chain.ChainClient, match *match.Server) *Syncer

func (*Syncer) Run

func (s *Syncer) Run() error