adshao_binance

Documentation

Index

• func WSServe(ctx context.Context, cfg *WSConfig, lg *zap.Logger) (<-chan WSMessage, error)
• type WSConfig
• type WSMessage

Functions

func WSServe

func WSServe(ctx context.Context, cfg *WSConfig, lg *zap.Logger) (<-chan WSMessage, error)

WSServe TODO: look to utils package and take implementation from it

Types

type WSConfig

type WSConfig struct {
	Endpoint  string
	KeepAlive bool
	Timeout   time.Duration
}

WSConfig webservice configuration

type WSMessage

type WSMessage struct {
	Payload             []byte
	DisconnectedWithErr error
}