app

Documentation

Index

• func SetupEnvConfig() *envConfig
• type Context
  • func NewContext(tunnel tunnel.Tunnel, queue storage.Vwap, cfg *envConfig) *Context
  • func (s *Context) Run(ctx context.Context) (err error)

Functions

func SetupEnvConfig

func SetupEnvConfig() *envConfig

Types

type Context

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

Context is application's content

func NewContext

func NewContext(tunnel tunnel.Tunnel, queue storage.Vwap, cfg *envConfig) *Context

NewContext instantiates new rte context object.

func (*Context) Run

func (s *Context) Run(ctx context.Context) (err error)

Run the App context, subscribe to the ws, and initiate the storage and calculation for the trading pairs. It is resilient tolerant. It will gracefully shut down and can receive an interrupt signal and safely to close the connexion.