Documentation
¶
Index ¶
Constants ¶
View Source
const ( TaskQueueName = "webhookx:queue" TaskQueueDataName = "webhookx:queue_data" TaskQueueVisibilityTimeout = time.Second * 65 TaskQueuePreScheduleTimeWindow = time.Minute * 3 )
Task Queue
View Source
const ( QueueRedisQueueName = "webhookx:proxy_queue" QueueRedisGroupName = "group_default" QueueRedisConsumerName = "consumer_default" QueueRedisVisibilityTimeout = time.Second * 60 )
Redis Queue
Variables ¶
View Source
var ( EventCacheKey = register(CacheKey{"events", "v1"}) EndpointCacheKey = register(CacheKey{"endpoints", "v1"}) SourceCacheKey = register(CacheKey{"sources", "v1"}) WorkspaceCacheKey = register(CacheKey{"workspaces", "v1"}) AttemptCacheKey = register(CacheKey{"attempts", "v1"}) PluginCacheKey = register(CacheKey{"plugins", "v1"}) AttemptDetailCacheKey = register(CacheKey{"attempt_details", "v1"}) WorkspaceEndpointsKey = register(CacheKey{"workspaces_endpoints", "v1"}) )
View Source
var ( HeaderEventId = "X-Webhookx-Event-Id" DefaultResponseHeaders = []Header{ {Name: "Server", Value: "WebhookX/" + webhookx.VERSION}, } DefaultDelivererRequestHeaders = []Header{ {Name: "User-Agent", Value: "WebhookX/" + webhookx.VERSION}, {Name: "Content-Type", Value: "application/json; charset=utf-8"}, } )
Functions ¶
This section is empty.
Types ¶
type CacheKey ¶
CacheKey cache key definition. format "webhookx:<name>:<version>:<id>"
func CacheKeyFrom ¶ added in v1.0.0
Click to show internal directories.
Click to hide internal directories.