config

Aug 27, 2017

Changes in this version

+ func Refresh(newCnf *Config)

+ func Reset()

type Config

+ func Get() *Config

Dec 3, 2019

Changes in this version

type Config

+ MonitorServerQueue string

+ MonitorWorkerQueue string

Oct 28, 2019

Changes in this version

type Config

+ MonitorQueue string

Oct 24, 2019

Changes in this version

type Config

+ CycleQueue string

Oct 15, 2019

Changes in this version

+ const DefaultResultsExpireIn

+ func ReadFromFile(cnfPath string) ([]byte, error)

+ type AMQPConfig struct

+ AutoDelete bool

+ BindingKey string

+ Exchange string

+ ExchangeType string

+ PrefetchCount int

+ QueueBindingArgs QueueBindingArgs

+ QueueDeclareArgs QueueDeclareArgs

+ type Config struct

+ AMQP *AMQPConfig

+ Broker string

+ DefaultQueue string

+ DynamoDB *DynamoDBConfig

+ GCPPubSub *GCPPubSubConfig

+ MongoDB *MongoDBConfig

+ NoUnixSignals bool

+ Redis *RedisConfig

+ ResultBackend string

+ ResultsExpireIn int

+ SQS *SQSConfig

+ TLSConfig *tls.Config

+ func NewFromEnvironment(keepReloading bool) (*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

+ ConnectTimeout int

+ DelayedTasksKey string

+ DelayedTasksPollPeriod int

+ IdleTimeout int

+ MaxActive int

+ MaxIdle int

+ NormalTasksPollPeriod int

+ ReadTimeout int

+ Wait bool

+ WriteTimeout int

+ type SQSConfig struct

+ Client *sqs.SQS

+ VisibilityTimeout *int

+ WaitTimeSeconds int