resources

Documentation

Index

• type CacheRepo
• type ClientManager
• type MessageBroker
• type Resources
  • func New(ctx context.Context, cfg config.ServerCfg) (*Resources, error)

Types

type CacheRepo

type CacheRepo interface {
	AddMessage(ctx context.Context, data []byte) error
	GetLastTen(ctx context.Context) ([]response.Msg, error)
}

type ClientManager

type ClientManager interface {
	Store(con *websocket.Conn)
	Release(con *websocket.Conn)
	Broadcaster(ctx context.Context) chan<- response.Msg
	WriteMsg(con *websocket.Conn, msg response.Msg) error
}

type MessageBroker

type MessageBroker interface {
	Write(ctx context.Context, data []byte)
}

type Resources

type Resources struct {
	Cfg           config.ServerCfg
	Log           zerolog.Logger
	ClientManager ClientManager
	RedisRepo     CacheRepo
	KafkaWriter   MessageBroker
}

func New

func New(ctx context.Context, cfg config.ServerCfg) (*Resources, error)