async

Documentation

Index

• type AsyncSMSService
  • func NewAsyncSMSService(ctx context.Context, smsSvc sms.Service, ...) *AsyncSMSService
  • func (a *AsyncSMSService) Send(ctx context.Context, toNb string, body string, args ...string) error
• type AsyncSMSServiceOptions

Types

type AsyncSMSService

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

NOTE: Use Singleton to fire only one go routine that reprogram async send.

func NewAsyncSMSService

func NewAsyncSMSService(
	ctx context.Context,
	smsSvc sms.Service,
	asyncRepo repository.AsyncSMSRepository,
	opts *AsyncSMSServiceOptions,
) *AsyncSMSService

func (*AsyncSMSService) Send

func (a *AsyncSMSService) Send(
	ctx context.Context,
	toNb string,
	body string,
	args ...string,
) error

type AsyncSMSServiceOptions

type AsyncSMSServiceOptions struct {
	PollInterval time.Duration
	RetryTimes   int
	// For twilio, it could be 20504 Twilio Internal Error
	RetryErrorCodes []int
}