forest

package module

Go to main page

Versions in this module

v0

v0.1.6

Dec 20, 2019

v0.1.5

Oct 24, 2019

v0.1.4

Aug 1, 2019

Changes in this version

type JobConf

+ Version int

+ type NodeStateChangeListener interface

type SchedulePlan

+ Version int

v0.1.3

Jul 31, 2019

Changes in this version

+ type ManualExecuteJobParam struct

+ Group string

+ Id string

+ Name string

v0.1.2

Jul 31, 2019

Changes in this version

+ const JobExecuteSnapshotDoingStatus

+ const JobExecuteSnapshotErrorStatus

+ const JobExecuteSnapshotSuccessStatus

+ const JobExecuteSnapshotUnkonwStatus

+ const JobExecuteStatusCollectionPath

+ func ParkJobExecuteSnapshot(snapshot *JobExecuteSnapshot) (value []byte, err error)

+ func ParseInLocation(value string) (dateTime time.Time, err error)

+ func TimeSubDays(t1, t2 time.Time) int

+ type JobClientDeleteEvent struct

+ Client *Client

+ Group *Group

+ type JobCollection struct

+ func NewJobCollection(node *JobNode) (c *JobCollection)

+ type JobExecuteSnapshot struct

+ CreateTime string

+ Cron string

+ FinishTime string

+ Group string

+ Id string

+ Ip string

+ JobId string

+ Mobile string

+ Name string

+ Params string

+ Remark string

+ Result string

+ StartTime string

+ Status int

+ Target string

+ Times int

+ func UParkJobExecuteSnapshot(value []byte) (snapshot *JobExecuteSnapshot, err error)

+ type JobSnapshotFailOver struct

+ func NewJobSnapshotFailOver(node *JobNode) (f *JobSnapshotFailOver)

+ type PageResult struct

+ List interface{}

+ TotalCount int

+ TotalPage int

+ type QueryExecuteSnapshotParam struct

+ Group string

+ Id string

+ Ip string

+ JobId string

+ Name string

+ PageNo int

+ PageSize int

+ Status int

v0.1.1

Jul 28, 2019

Changes in this version

+ func ToDateString(date time.Time) string

type JobSnapshot

+ CreateTime string

v0.1.0

Jul 25, 2019

Changes in this version

+ const ClientPath

+ const GroupConfPath

+ const JobClientSnapshotPath

+ const JobConfPath

+ const JobCreateChangeEvent

+ const JobDeleteChangeEvent

+ const JobNodeElectPath

+ const JobNodePath

+ const JobRunningStatus

+ const JobSnapshotGroupPath

+ const JobSnapshotPath

+ const JobStopStatus

+ const JobUpdateChangeEvent

+ const KeyCreateChangeEvent

+ const KeyDeleteChangeEvent

+ const KeyUpdateChangeEvent

+ const NodeFollowerState

+ const NodeLeaderState

+ const TTL

+ func GenerateSerialNo() string

+ func GetLocalIpAddress() (ip string)

+ func ParkGroupConf(groupConf *GroupConf) (value []byte, err error)

+ func ParkJobConf(jobConf *JobConf) (value []byte, err error)

+ func ParkJobSnapshot(snapshot *JobSnapshot) (value []byte, err error)

+ type Client struct

+ type Etcd struct

+ func NewEtcd(endpoints []string, timeout time.Duration) (etcd *Etcd, err error)

+ func (etcd *Etcd) Delete(key string) (err error)

+ func (etcd *Etcd) DeleteWithPrefixKey(prefixKey string) (err error)

+ func (etcd *Etcd) Get(key string) (value []byte, err error)

+ func (etcd *Etcd) GetWithPrefixKey(prefixKey string) (keys [][]byte, values [][]byte, err error)

+ func (etcd *Etcd) GetWithPrefixKeyLimit(prefixKey string, limit int64) (keys [][]byte, values [][]byte, err error)

+ func (etcd *Etcd) Put(key, value string) (err error)

+ func (etcd *Etcd) PutNotExist(key, value string) (success bool, oldValue []byte, err error)

+ func (etcd *Etcd) TxKeepaliveWithTTL(key, value string, ttl int64) (txResponse *TxResponse, err error)

+ func (etcd *Etcd) TxWithTTL(key, value string, ttl int64) (txResponse *TxResponse, err error)

+ func (etcd *Etcd) Update(key, value, oldValue string) (success bool, err error)

+ func (etcd *Etcd) Watch(key string) (keyChangeEventResponse *WatchKeyChangeResponse)

+ func (etcd *Etcd) WatchWithPrefixKey(prefixKey string) (keyChangeEventResponse *WatchKeyChangeResponse)

+ type Group struct

+ func NewGroup(name, path string, node *JobNode) (group *Group)

+ type GroupConf struct

+ Name string

+ Remark string

+ func UParkGroupConf(value []byte) (groupConf *GroupConf, err error)

+ type JobAPi struct

+ func NewJobAPi(node *JobNode) (api *JobAPi)

+ func (api *JobAPi) AddJob(context echo.Context) (err error)

+ type JobChangeEvent struct

+ Conf *JobConf

+ Type int

+ type JobClient struct

+ Group string

+ Name string

+ Path string

+ type JobConf struct

+ Cron string

+ Group string

+ Id string

+ Mobile string

+ Name string

+ Params string

+ Remark string

+ Status int

+ Target string

+ func UParkJobConf(value []byte) (jobConf *JobConf, err error)

+ type JobExecutor struct

+ func NewJobExecutor(node *JobNode) (exec *JobExecutor)

+ type JobGroupManager struct

+ func NewJobGroupManager(node *JobNode) (mgr *JobGroupManager)

+ type JobManager struct

+ func NewJobManager(node *JobNode) (manager *JobManager)

+ func (manager *JobManager) AddJob(jobConf *JobConf) (err error)

+ type JobNode struct

+ func NewJobNode(id string, etcd *Etcd, httpAddress string) (node *JobNode, err error)

+ func (node *JobNode) Bootstrap()

+ func (node *JobNode) Close()

+ type JobScheduler struct

+ func NewJobScheduler(node *JobNode) (sch *JobScheduler)

+ type JobSnapshot struct

+ Cron string

+ Group string

+ Id string

+ Ip string

+ JobId string

+ Mobile string

+ Name string

+ Params string

+ Remark string

+ StartTime time.Time

+ Status int

+ Target string

+ func UParkJobSnapshot(value []byte) (snapshot *JobSnapshot, err error)

+ type KeyChangeEvent struct

+ Key string

+ Type int

+ Value []byte

+ type Node struct

+ Name string

+ State int

+ type QueryClientParam struct

+ Group string

+ type QuerySnapshotParam struct

+ Group string

+ Id string

+ Ip string

+ type Result struct

+ Code int

+ Data interface{}

+ Message string

+ type SchedulePlan struct

+ BeforeTime time.Time

+ Cron string

+ Group string

+ Id string

+ Mobile string

+ Name string

+ NextTime time.Time

+ Params string

+ Remark string

+ Status int

+ Target string

+ type TxResponse struct

+ Key string

+ Lease clientv3.Lease

+ LeaseID clientv3.LeaseID

+ Success bool

+ Value string

+ type WatchKeyChangeResponse struct

+ CancelFunc context.CancelFunc

+ Event chan *KeyChangeEvent

+ Watcher clientv3.Watcher

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL