deliverymq

type AlertMonitor interface {
	HandleAttempt(ctx context.Context, attempt alert.DeliveryAttempt) error
}

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

type DeliveryInfra interface {
	DeclareInfrastructure(ctx context.Context) error
}

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

type DeliveryMQOption struct {
	QueueConfig *mqs.QueueConfig
}

type DeliveryTracer interface {
	Deliver(ctx context.Context, task *models.DeliveryTask, destination *models.Destination) (context.Context, trace.Span)
}

type DestinationGetter interface {
	RetrieveDestination(ctx context.Context, tenantID, destID string) (*models.Destination, error)
}

type LogPublisher interface {
	Publish(ctx context.Context, entry models.LogEntry) error
}

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

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

type Publisher interface {
	PublishEvent(ctx context.Context, destination *models.Destination, event *models.Event) (*models.Attempt, error)
}

type RetryEventGetter interface {
	RetrieveEvent(ctx context.Context, request logstore.RetrieveEventRequest) (*models.Event, error)
}

type RetryScheduler interface {
	Schedule(ctx context.Context, task string, delay time.Duration, opts ...scheduler.ScheduleOption) error
	Cancel(ctx context.Context, taskID string) error
}

type RetrySchedulerOption func(*retrySchedulerConfig)

type RetryTask struct {
	EventID       string
	TenantID      string
	DestinationID string
	Attempt       int
	Telemetry     *models.DeliveryTelemetry
}