Documentation ¶
Index ¶
- func AddToQueue(k string, v string, rClient *redis.Client)
- func AllowedEvents(e string) bool
- func CheckQueue(k string, v string, rClient *redis.Client)
- func Handler()
- func QueueComplited(k string, v string, rClient *redis.Client)
- func QueueProcessor(client *redis.Client)
- func Start()
- type Config
- func (c Config) CheckEvent(watcher *fsnotify.Watcher, client *redis.Client)
- func (c *Config) Client() *redis.Client
- func (c Config) GenerateCmd() []string
- func (c *Config) MarshalConfig() *Config
- func (c *Config) RegisterAgent(rClient *redis.Client)
- func (c *Config) Walking(watcher *fsnotify.Watcher)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AllowedEvents ¶
func QueueProcessor ¶
Types ¶
type Config ¶
type Config struct { RedisAddr string `env:"REDIS_ADDR" envDefault:"localhost:6379"` RedisPass string `env:"REDIS_PASS" envDefault:""` RedisDB int `env:"REDIS_DB" envDefault:"0"` AgentsSet string `env:"AGENTS_SET_NAME" envDefault:"agents"` QueueName string `env:"QUEUE_NAME" envDefault:"lecc"` AgentName string `env:"HOSTNAME"` Interval int `env:"INTERVAL" envDefault:"20"` Path string `env:"WATCH_PATH"` Command string `env:"COMMAND"` Image string `env:"IMAGE"` }
func (Config) CheckEvent ¶
func (Config) GenerateCmd ¶
func (*Config) MarshalConfig ¶
func (*Config) RegisterAgent ¶
Click to show internal directories.
Click to hide internal directories.