task

Documentation

Index

• Variables
• func ExportCollection(ctx context.Context, collection string, uri string, exportDir string, ...) error
• func GetArgsByCollection(collection string, uri string, exportDir string, expDate time.Time, ...) ([]string, string, error)
• func GetRetryDelay(n int, err error, t *asynq.Task) time.Duration
• func MonitorTwitterSources(store datastore.Store, queue queue.Queuer) func(context.Context, *asynq.Task) error
• func NewObjectStoreClient(config *datastore.Configuration) (objectstore.ObjectStore, string, error)
• func ProcessDeadLetters(job *queue.Job)
• func ProcessEmails(sc smtp.SmtpClient) func(context.Context, *asynq.Task) error
• func ProcessEventCreation(appRepo datastore.ApplicationRepository, eventRepo datastore.EventRepository, ...) func(context.Context, *asynq.Task) error
• func ProcessEventDelivery(appRepo datastore.ApplicationRepository, ...) func(context.Context, *asynq.Task) error
• func ProcessNotifications(sc smtp.SmtpClient) func(context.Context, *asynq.Task) error
• func RententionPolicies(instanceConfig config.Configuration, ...) func(context.Context, *asynq.Task) error
• func RetryEventDeliveries(statuses []datastore.EventDeliveryStatus, lookBackDuration string, ...)
• func SearchIndex(search searcher.Searcher) func(ctx context.Context, t *asynq.Task) error
• type EndpointError
  • func (e *EndpointError) Delay() time.Duration
  • func (e *EndpointError) Error() string
• type EventDeliveryConfig
• type RateLimitConfig
• type RateLimitError
  • func (e *RateLimitError) Delay() time.Duration
  • func (e *RateLimitError) Error() string
  • func (e *RateLimitError) RateLimit()
• type RetryConfig
• type SignatureValues

Variables

var ErrDeliveryAttemptFailed = errors.New("error sending event")

var ErrGroupIdFieldIsNotString = errors.New("group_id field does not exist on the document")

var ErrGroupIdFieldIsRequired = errors.New("group_id field should be a string")

var ErrInvalidEmailPayload = errors.New("invalid email payload")

var ErrInvalidNotificationPayload = errors.New("invalid notification payload")

var ErrInvalidNotificationType = errors.New("invalid notification type")

var ErrInvalidSlackPayload = errors.New("invalid slack payload")

var ErrRateLimit = errors.New("rate limit error")

Functions

func ExportCollection

func ExportCollection(ctx context.Context, collection string, uri string, exportDir string, expDate time.Time, objectStoreClient objectstore.ObjectStore, group *datastore.Group, eventRepo datastore.EventRepository, eventDeliveriesRepo datastore.EventDeliveryRepository, groupRepo datastore.GroupRepository, searcher searcher.Searcher) error

func GetArgsByCollection

func GetArgsByCollection(collection string, uri string, exportDir string, expDate time.Time, group *datastore.Group) ([]string, string, error)

func GetRetryDelay

func GetRetryDelay(n int, err error, t *asynq.Task) time.Duration

func MonitorTwitterSources

func MonitorTwitterSources(store datastore.Store, queue queue.Queuer) func(context.Context, *asynq.Task) error

func NewObjectStoreClient

func NewObjectStoreClient(config *datastore.Configuration) (objectstore.ObjectStore, string, error)

func ProcessDeadLetters

func ProcessDeadLetters(job *queue.Job)

func ProcessEmails

func ProcessEmails(sc smtp.SmtpClient) func(context.Context, *asynq.Task) error

func ProcessEventCreation

func ProcessEventCreation(appRepo datastore.ApplicationRepository, eventRepo datastore.EventRepository, groupRepo datastore.GroupRepository, eventDeliveryRepo datastore.EventDeliveryRepository, cache cache.Cache, eventQueue queue.Queuer, subRepo datastore.SubscriptionRepository, search searcher.Searcher, deviceRepo datastore.DeviceRepository) func(context.Context, *asynq.Task) error

func ProcessEventDelivery

func ProcessEventDelivery(appRepo datastore.ApplicationRepository, eventDeliveryRepo datastore.EventDeliveryRepository, groupRepo datastore.GroupRepository, rateLimiter limiter.RateLimiter, subRepo datastore.SubscriptionRepository, notificationQueue queue.Queuer) func(context.Context, *asynq.Task) error

func ProcessNotifications

func ProcessNotifications(sc smtp.SmtpClient) func(context.Context, *asynq.Task) error

func RententionPolicies

func RententionPolicies(instanceConfig config.Configuration, configRepo datastore.ConfigurationRepository, groupRepo datastore.GroupRepository, eventRepo datastore.EventRepository, eventDeliveriesRepo datastore.EventDeliveryRepository, searcher searcher.Searcher) func(context.Context, *asynq.Task) error

func RetryEventDeliveries

func RetryEventDeliveries(statuses []datastore.EventDeliveryStatus, lookBackDuration string, store datastore.Store, eventQueue queue.Queuer)

func SearchIndex

func SearchIndex(search searcher.Searcher) func(ctx context.Context, t *asynq.Task) error

Types

type EndpointError

type EndpointError struct {
	Err error
	// contains filtered or unexported fields
}

func (*EndpointError) Delay

func (e *EndpointError) Delay() time.Duration

func (*EndpointError) Error

func (e *EndpointError) Error() string

type EventDeliveryConfig

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

type RateLimitConfig

type RateLimitConfig struct {
	Count    int
	Duration uint64
}

type RateLimitError

type RateLimitError struct {
	Err error
	// contains filtered or unexported fields
}

func (*RateLimitError) Delay

func (e *RateLimitError) Delay() time.Duration

func (*RateLimitError) Error

func (e *RateLimitError) Error() string

func (*RateLimitError) RateLimit

func (e *RateLimitError) RateLimit()

type RetryConfig

type RetryConfig struct {
	Type       datastore.StrategyProvider
	Duration   uint64
	RetryCount uint64
}

type SignatureValues

type SignatureValues struct {
	HMAC      string
	Timestamp string
}