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(sourceRepo datastore.SourceRepository, ...) func(context.Context, *asynq.Task) error
• func NewObjectStoreClient(config *datastore.Configuration) (objectstore.ObjectStore, string, error)
• func ProcessDeadLetters(job *queue.Job)
• func ProcessEventCreated(appRepo datastore.ApplicationRepository, eventRepo datastore.EventRepository, ...) func(context.Context, *asynq.Task) error
• func ProcessEventDelivery(appRepo datastore.ApplicationRepository, ...) 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 SendNotification(notificationSender notification.Sender) func(ctx context.Context, t *asynq.Task) error
• type EndpointError
  • func (e *EndpointError) Delay() time.Duration
  • func (e *EndpointError) Error() string
• type RateLimitError
  • func (e *RateLimitError) Delay() time.Duration
  • func (e *RateLimitError) Error() string
  • func (e *RateLimitError) RateLimit()
• type SignatureValues

Variables

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

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(sourceRepo datastore.SourceRepository, subRepo datastore.SubscriptionRepository, appRepo datastore.ApplicationRepository, 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 ProcessEventCreated

func ProcessEventCreated(appRepo datastore.ApplicationRepository, eventRepo datastore.EventRepository, groupRepo datastore.GroupRepository, eventDeliveryRepo datastore.EventDeliveryRepository, cache cache.Cache, eventQueue queue.Queuer, subRepo datastore.SubscriptionRepository) 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) 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, eventDeliveryRepo datastore.EventDeliveryRepository, groupRepo datastore.GroupRepository, eventQueue queue.Queuer)

func SendNotification

func SendNotification(notificationSender notification.Sender) 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 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 SignatureValues

type SignatureValues struct {
	HMAC      string
	Timestamp string
}