websocket

Documentation

Index

• type Conn
• type Gen
• type Keeper
  • func NewKeeper(gen Gen) *Keeper
  • func (k *Keeper) Close()
  • func (k *Keeper) Done() chan struct{}
  • func (k *Keeper) ECh() chan error
  • func (k *Keeper) Loop(ctx context.Context)

Types

type Conn

type Conn interface {
	Run(ctx context.Context) error
	Close() error
	Error() error
	Done() <-chan struct{}
	Subscribe(ctx context.Context, channels ...exchange.Channel) error
	UnSubscribe(ctx context.Context, channels ...exchange.Channel) error
}

Conn Unique exchange websocket client

type Gen

type Gen interface {
	NewConn(ctx context.Context) (Conn, error)
	//Channel return channels which need to be subscribe.
	Channels(ctx context.Context, oldChannel []exchange.Channel) (newChannels []exchange.Channel, notify chan struct{}, err error)
}

Gen is a interface for unify rpc connection and update subscription channel

type Keeper

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

Keeper is a struct which used to make websocket connection auto reconnect and auto update subscribe channels

func NewKeeper

func NewKeeper(gen Gen) *Keeper

func (*Keeper) Close

func (k *Keeper) Close()

Close loop manualy

func (*Keeper) Done

func (k *Keeper) Done() chan struct{}

func (*Keeper) ECh

func (k *Keeper) ECh() chan error

ECh push error when error happen

func (*Keeper) Loop

func (k *Keeper) Loop(ctx context.Context)