messaging

type EmailMessage struct {
	Type nonblocking.MessageType
	mail.SendOptions
	// contains filtered or unexported fields
}

type EventService interface {
	DispatchEventImmediately(payload event.NonBlockingPayload) error
}

type Limits struct {
	Logger       Logger
	RateLimiter  RateLimiter
	UsageLimiter UsageLimiter
	RemoteIP     httputil.RemoteIP

	Config        *config.MessagingRateLimitsConfig
	FeatureConfig *config.MessagingFeatureConfig
	EnvConfig     *config.RateLimitsEnvironmentConfig
}

type Logger struct{ *log.Logger }

type RateLimiter interface {
	Reserve(spec ratelimit.BucketSpec) *ratelimit.Reservation
	Cancel(r *ratelimit.Reservation)
}

type SMSMessage struct {
	Type nonblocking.MessageType
	sms.SendOptions

	IsNotCounted bool
	// contains filtered or unexported fields
}

type Sender struct {
	Limits                 Limits
	TaskQueue              task.Queue
	Events                 EventService
	Whatsapp               *whatsapp.Service
	MessagingFeatureConfig *config.MessagingFeatureConfig
}

type UsageLimiter interface {
	Reserve(name usage.LimitName, config *config.UsageLimitConfig) (*usage.Reservation, error)
	Cancel(r *usage.Reservation)
}

type WhatsappMessage struct {
	Type         nonblocking.MessageType
	Options      whatsapp.SendTemplateOptions
	IsNotCounted bool
	// contains filtered or unexported fields
}

type WhatsappSender interface {
	SendTemplate(opts *whatsapp.SendTemplateOptions) error
}