statusservice

type DB interface {
	LoadStatus(ctx context.Context, id string) (*persistence.Status, error)
}

type Data struct {
	Port      int
	DB        DB
	WSHandler WSConnHandler
}

type HandlerData struct {
	GueClient   *gue.Client
	WorkerCount int
	DB          StatusDB
	WSHandler   WSConnHandler
}

type StatusDB interface {
	LoadStatus(ctx context.Context, id string) (*persistence.Status, error)
}

type WSConnHandler interface {
	HandleConnection(WsConn) error
	GetConnections(id string) ([]WsConn, bool)
}

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

type WsConn interface {
	ReadMessage() (messageType int, p []byte, err error)
	Close() error
	WriteJSON(v interface{}) error
}