Versions in this module Expand all Collapse all v0 v0.2.6 Dec 13, 2017 v0.2.2 Nov 24, 2017 Changes in this version + const APITimeOut + const DefaultConfigFile + const DefaultDBName + const DefaultHttpPort + const DefaultKeySpeace + const DefaultPidFile + const DefaultRPCPort + const DefaultRegion + const DefaultSQLHost + const DefaultSQLPort + const DefaultSQLUser + const DefaultSerfPort + const DefaultSnapshotPath + const LOADALL + const LOADNOTHING + const LOADOWN + const QueryJobCount + const QueryRunJob + var RESERVEDTAGS = [...]string + type Agent struct + func New(args []string, version string) *Agent + func (a *Agent) AddJob(in *pb.Job) (out *pb.Job, err error) + func (a *Agent) DeleteJob(in *pb.Job) (out *pb.Job, err error) + func (a *Agent) GetJob(name, region string) (*pb.Job, error) + func (a *Agent) GetStatus(name, region string) (out *pb.JobStatus, err error) + func (a *Agent) ListExecutions(in *pb.Execution, search *pb.Search) (out []*pb.Execution, count int32, err error) + func (a *Agent) ListJob(in *pb.Job, search *pb.Search) (jobs []*pb.Job, count int32, err error) + func (a *Agent) ListNode(node *pb.Node, search *pb.Search) (nodes []*pb.Node, count int32, err error) + func (a *Agent) ListRegions() (regions []string, err error) + func (a *Agent) ModifyJob(in *pb.Job) (out *pb.Job, err error) + func (a *Agent) PerformOps(obj interface{}, ops pb.Ops, search *pb.Search) ([]interface{}, int32, error) + func (a *Agent) Reload(args []string) + func (a *Agent) RemovePid() error + func (a *Agent) Run() error + func (a *Agent) RunJob(name, region string) (*pb.Execution, error) + func (a *Agent) Search(in interface{}, search *pb.Search) (out []interface{}, count int32, err error) + func (a *Agent) SendBackExecution(ex *pb.Execution) (err error) + func (a *Agent) Stop(graceful bool) int + func (a *Agent) WritePid() error + type Config struct + APIBindIP string + APIBindPort int + APITokens map[string]string + CAFile string + CertFile string + DSN string + JobStore string + JobStoreKeyspace string + JobStoreServers []string + KeyFile string + LoadJobPolicy loadJobPolicy + LogFile string + LogLevel string + Nodename string + PidFile string + RPCAdcertiseIP string + RPCAdcertisePort int + RPCBindIP string + RPCBindPort int + RPCTls bool + Region string + SerfAdvertiseIP string + SerfAdvertisePort int + SerfBindIP string + SerfBindPort int + SerfJoin []string + SerfSnapshotPath string + Server bool + Tags map[string]string + func ReadConfig(version string) (*Config, error) + func (c *Config) EncryptKey() ([]byte, error)