service

package
v0.0.0-...-6b3b694 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 12, 2023 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL