v2_6

Documentation

Index

• type AMQPConfig
• type BeanstalkConfig
• type BoltDBConfig
• type Config
• type Env
• type MemoryConfig
• type NATSConfig
• type SQSConfig

Types

type AMQPConfig

type AMQPConfig struct {
	Priority      int64  `mapstructure:"priority"`
	Prefetch      int    `mapstructure:"prefetch"`
	Queue         string `mapstructure:"queue"`
	Exchange      string `mapstructure:"exchange"`
	ExchangeType  string `mapstructure:"exchange_type"`
	RoutingKey    string `mapstructure:"routing_key"`
	Exclusive     bool   `mapstructure:"exclusive"`
	MultipleAck   bool   `mapstructure:"multiple_ask"`
	RequeueOnFail bool   `mapstructure:"requeue_on_fail"`
}

type BeanstalkConfig

type BeanstalkConfig struct {
	Priority       int64         `mapstructure:"priority"`
	TubePriority   *uint32       `mapstructure:"tube_priority"`
	Tube           string        `mapstructure:"tube"`
	ReserveTimeout time.Duration `mapstructure:"reserve_timeout"`
}

type BoltDBConfig

type BoltDBConfig struct {
	Priority int64  `mapstructure:"priority"`
	File     string `mapstructure:"file"`
	Prefetch int    `mapstructure:"prefetch"`
}

type Config

type Config struct {
	// --------------
	Nats *struct {
		Addr string `mapstructure:"addr"`
	} `mapstructure:"nats"`
	// --------------
	Boltdb *struct {
		Permissions int `mapstructure:"permissions"`
	} `mapstructure:"boltdb"`
	// --------------
	AMQP *struct {
		Addr string `mapstructure:"addr"`
	} `mapstructure:"amqp"`
	// --------------
	Beanstalk *struct {
		Addr    string `mapstructure:"addr"`
		Timeout string `mapstructure:"timeout"`
	} `mapstructure:"beanstalk"`
	// --------------
	Sqs *struct {
		Key          string `mapstructure:"key"`
		Secret       string `mapstructure:"secret"`
		Region       string `mapstructure:"region"`
		SessionToken string `mapstructure:"session_token"`
		Endpoint     string `mapstructure:"endpoint"`
	} `mapstructure:"sqs"`
	// --------------
	Jobs *struct {
		NumPollers   int                           `mapstructure:"num_pollers"`
		PipelineSize int                           `mapstructure:"pipeline_size"`
		Pool         *pool.Config                  `mapstructure:"pool"`
		Pipelines    map[string]*pipeline.Pipeline `mapstructure:"pipelines"`
		Consume      []string                      `mapstructure:"consume"`
	} `mapstructure:"jobs"`
}

type Env

type Env map[string]string

type MemoryConfig

type MemoryConfig struct {
	Priority int64 `mapstructure:"priority"`
}

type NATSConfig

type NATSConfig struct {
	Priority           int64  `mapstructure:"priority"`
	Subject            string `mapstructure:"subject"`
	Stream             string `mapstructure:"stream"`
	Prefetch           int    `mapstructure:"prefetch"`
	RateLimit          uint64 `mapstructure:"rate_limit"`
	DeleteAfterAck     bool   `mapstructure:"delete_after_ack"`
	DeliverNew         bool   `mapstructure:"deliver_new"`
	DeleteStreamOnStop bool   `mapstructure:"delete_stream_on_stop"`
}

type SQSConfig

type SQSConfig struct {
	Priority          int64             `mapstructure:"priority"`
	VisibilityTimeout int32             `mapstructure:"visibility_timeout"`
	WaitTimeSeconds   int32             `mapstructure:"wait_time_seconds"`
	Prefetch          int32             `mapstructure:"prefetch"`
	Queue             *string           `mapstructure:"queue"`
	Attributes        map[string]string `mapstructure:"attributes"`
	Tags              map[string]string `mapstructure:"tags"`
}