service

Documentation

Index

• Variables
• func Module() fx.Option
• type Health
  • func NewHealth(redis *redis.Client, nats *nats.Conn) *Health
  • func (s *Health) Ping(ctx context.Context) error
• type Live
  • func NewLive(dropSet *lhcore.DropSet, hub *wshub.Hub) *Live
  • func (l *Live) Handle(c *websocket.Conn)

Variables

var (
	ErrRedisNotReachable = errors.New("redis not reachable")
	ErrNATSNotReachable  = errors.New("nats not reachable")
)

Functions

func Module

func Module() fx.Option

Types

type Health

type Health struct {
	Redis *redis.Client
	NATS  *nats.Conn
}

func NewHealth

func NewHealth(redis *redis.Client, nats *nats.Conn) *Health

func (*Health) Ping

func (s *Health) Ping(ctx context.Context) error

type Live

type Live struct {
	DropSet *lhcore.DropSet
	Hub     *wshub.Hub

	ResultFlushInterval time.Duration
}

func NewLive

func NewLive(dropSet *lhcore.DropSet, hub *wshub.Hub) *Live

func (*Live) Handle

func (l *Live) Handle(c *websocket.Conn)