convoy

package

v0.0.0-...-7940cbf Latest Latest Go to latest Published: Apr 3, 2023 License: MIT Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/frain-dev/migrate-to-postgres

Links

Open Source Insights

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 ¶

View Source

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

View Source

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

View Source

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

Exports dir

View Source

const (
	Concurrency = 100
)

View Source

const (
	EventDeliveryIDLength = 12
)

Variables ¶

View Source

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
auth
config
algo
datastore
mongo
net
pkg
flatten
httpheader
log
signature
verifier
util

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL