notifyrclient

type DeduplicatedMessageQueue interface {
	cloudcontract.MessageQueueInterface
	SendMessageWithDedupe(ctx context.Context, queueURL, messageBody, messageGroupID, dedupeID string) (*cloudmessagequeue.SendMessageResult, error)
}

type PublishAuditEvent struct {
	MessageID      string
	IdempotencyKey string
	QueueURL       string
	Channel        contracts.Channel
	Priority       contracts.Priority
	Purpose        string
	Status         PublishAuditStatus
	ProviderID     string
	Err            error
	Duration       time.Duration
	At             time.Time
}

type PublishAuditHook func(PublishAuditEvent)

type PublishAuditStatus string

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

type PublisherOptions struct {
	AuditHook PublishAuditHook
	Clock     func() time.Time
}

type QueueConfig struct {
	EmailHighPriorityURL string
	EmailLowPriorityURL  string
	SMSHighPriorityURL   string
	SMSLowPriorityURL    string
}