domain

Documentation

Index

• Variables
• type Domain
  • func NewDomain(iamCli iam.IAMClient, env *env.Env, logger logging.Logger, ...) Domain
• type LogSubscriptionCtx
• type SocketService
• type UserContext

Variables

var Module = fx.Module("domain", fx.Provide(NewDomain))

Types

type Domain

type Domain interface {
	SocketService
}

func NewDomain

func NewDomain(
	iamCli iam.IAMClient,
	env *env.Env,

	logger logging.Logger,
	natsClient *nats.Client,
	jetStreamClient *nats.JetstreamClient,
) Domain

type LogSubscriptionCtx

type LogSubscriptionCtx struct {
	Context    context.Context
	CancelFunc context.CancelFunc
	Reader     io.Reader
}

type SocketService

type SocketService interface {
	HandleWebSocket(ctx context.Context, c *websocket.Conn) error
}

type UserContext

type UserContext struct {
	context.Context
	UserId    repos.ID
	UserName  string
	UserEmail string
}