convoy

Documentation

Index

• Constants
• Variables
• func GetVersion() string
• func ReadVersion() ([]byte, error)
• type CacheKey
  • func (c CacheKey) Get(suffix string) CacheKey
  • func (c CacheKey) String() string
• type GenericMap
• type HttpMethod
• type Plugin
• type QueueName
• type TaskName
  • func (t TaskName) SetPrefix(prefix string) TaskName

Constants

const (
	RATE_LIMIT          = 5000
	RATE_LIMIT_DURATION = "1m"
	HTTP_TIMEOUT        = "30s"
)

const (
	EventProcessor         TaskName = "EventProcessor"
	DeadLetterProcessor    TaskName = "DeadLetterProcessor"
	CreateEventProcessor   TaskName = "CreateEventProcessor"
	NotificationProcessor  TaskName = "NotificationProcessor"
	IndexDocument          TaskName = "index document"
	DailyAnalytics         TaskName = "daily analytics"
	MonitorTwitterSources  TaskName = "monitor twitter sources"
	RetentionPolicies      TaskName = "retention_policies"
	EmailProcessor         TaskName = "EmailProcessor"
	ExpireSecretsProcessor TaskName = "ExpireSecretsProcessor"
	EndpointsCacheKey      CacheKey = "endpoints"
	ProjectsCacheKey       CacheKey = "projects"
	TokenCacheKey          CacheKey = "tokens"
	SourceCacheKey         CacheKey = "sources"
)

const (
	DefaultOnPremDir = "/var/convoy/export"
	TmpExportDir     = "/tmp/convoy/export"
)

Exports dir

const (
	Concurrency = 100
)

const (
	EventDeliveryIDLength = 12
)

Variables

var ErrUnsupportedDatebase = fmt.Errorf("unsupported database for search detected, remove search configuration or use a supported database (mongodb)")

Functions

func GetVersion

func GetVersion() string

func ReadVersion

func ReadVersion() ([]byte, error)

Types

type CacheKey

type CacheKey string

func (CacheKey) Get

func (c CacheKey) Get(suffix string) CacheKey

func (CacheKey) String

func (c CacheKey) String() string

type GenericMap

type GenericMap map[string]interface{}

type HttpMethod

type HttpMethod string

const (
	HttpPost HttpMethod = "POST"
	HttpGet  HttpMethod = "GET"
)

type Plugin

type Plugin interface {
	Apply(http.ResponseWriter, *http.Request) error
	Name() string
	IsEnabled() bool
}

type QueueName

type QueueName string

const (
	EventQueue       QueueName = "EventQueue"
	CreateEventQueue QueueName = "CreateEventQueue"
	PriorityQueue    QueueName = "PriorityQueue"
	ScheduleQueue    QueueName = "ScheduleQueue"
	DefaultQueue     QueueName = "DefaultQueue"
)

queues

type TaskName

type TaskName string

func (TaskName) SetPrefix

func (t TaskName) SetPrefix(prefix string) TaskName