Versions in this module Expand all Collapse all v2 v2.0.15 Aug 4, 2024 Changes in this version + const DefaultResultsExpireIn + func ReadFromFile(cnfPath string) ([]byte, error) + type AMQPConfig struct + AutoDelete bool + BindingKey string + DelayedQueue string + Exchange string + ExchangeType string + PrefetchCount int + QueueBindingArgs QueueBindingArgs + QueueDeclareArgs QueueDeclareArgs + type Config struct + AMQP *AMQPConfig + Broker string + DefaultQueue string + DynamoDB *DynamoDBConfig + GCPPubSub *GCPPubSubConfig + Lock string + MongoDB *MongoDBConfig + MultipleBrokerSeparator string + NoUnixSignals bool + Redis *RedisConfig + ResultBackend string + ResultsExpireIn int + SQS *SQSConfig + TLSConfig *tls.Config + func NewFromEnvironment() (*Config, error) + func NewFromYaml(cnfPath string, keepReloading bool) (*Config, error) + type DynamoDBConfig struct + Client *dynamodb.DynamoDB + GroupMetasTable string + TaskStatesTable string + type GCPPubSubConfig struct + Client *pubsub.Client + MaxExtension time.Duration + type MongoDBConfig struct + Client *mongo.Client + Database string + type QueueBindingArgs map[string]interface + func (args *QueueBindingArgs) Decode(value string) error + type QueueDeclareArgs map[string]interface + type RedisConfig struct + ClientName string + ClusterEnabled bool + ConnectTimeout int + DelayedTasksKey string + DelayedTasksPollPeriod int + IdleTimeout int + MasterName string + MaxActive int + MaxIdle int + NormalTasksPollPeriod int + ReadTimeout int + Wait bool + WriteTimeout int + type SQSConfig struct + Client *sqs.SQS + VisibilityTimeout *int + WaitTimeSeconds int
Go to main page