task

Documentation

Index

• Variables
• func ExpireSecret(a datastore.EndpointRepository) func(ctx context.Context, t *asynq.Task) error
• 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(endpointRepo datastore.EndpointRepository, eventRepo datastore.EventRepository, ...) func(context.Context, *asynq.Task) error
• func ProcessEventDelivery(endpointRepo datastore.EndpointRepository, ...) 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 CreateEvent
• type EndpointError
  • func (e *EndpointError) Delay() time.Duration
  • func (e *EndpointError) Error() string
• type EventDeliveryConfig
• type Payload
• 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 (
	ErrProjectIdFieldIsRequired  = errors.New("project_id field should be a string")
	ErrProjectIdFieldIsNotString = errors.New("project_id field does not exist on the document")
)

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

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")

Functions

func ExpireSecret

func ExpireSecret(a datastore.EndpointRepository) func(ctx context.Context, t *asynq.Task) error

func ExportCollection

func ExportCollection(ctx context.Context, collection string, uri string, exportDir string, expDate time.Time, objectStoreClient objectstore.ObjectStore, project *datastore.Project, eventRepo datastore.EventRepository, eventDeliveriesRepo datastore.EventDeliveryRepository, projectRepo datastore.ProjectRepository, searcher searcher.Searcher) error

func GetArgsByCollection

func GetArgsByCollection(collection string, uri string, exportDir string, expDate time.Time, project *datastore.Project) ([]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(endpointRepo datastore.EndpointRepository, eventRepo datastore.EventRepository, projectRepo datastore.ProjectRepository, 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(endpointRepo datastore.EndpointRepository, eventDeliveryRepo datastore.EventDeliveryRepository, projectRepo datastore.ProjectRepository, 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, projectRepo datastore.ProjectRepository, 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 CreateEvent

type CreateEvent struct {
	Event              datastore.Event
	CreateSubscription bool
}

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 Payload

type Payload struct {
	EndpointID string `json:"endpoint_id"`
	SecretID   string `json:"secret_id"`
}

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
}