protocol

Documentation

Index

• Constants
• type ExecuteSnapshot
  • func (es *ExecuteSnapshot) Decode(content string) *ExecuteSnapshot
  • func (es *ExecuteSnapshot) Encode() string
• type JobChangeEvent
• type JobChangeEventType
• type JobConf
  • func (j *JobConf) Decode(content string) *JobConf
  • func (j *JobConf) Encode() string
• type JobState
• type SchedulePlan
• type SchedulePlanSnapshot
  • func (snapshot *SchedulePlanSnapshot) Decode(content string) *SchedulePlanSnapshot
  • func (snapshot *SchedulePlanSnapshot) Encode() string

Constants

const (
	NodeStateChangeTopic = "NodeStateChangeTopic"
	NodeElectionTTL      = 3
	NodeInstanceTTL      = 10

	NodeElectionPath = "/pink/node/election/"
	NodeInstancePath = "/pink/node/instances/"

	JobConfPath                = "/pink/job/conf/"
	GroupPath                  = "/pink/group/instances/"
	ClientInstancePath         = "/pink/client/%s/instances/"
	ScheduleSnapshotPath       = "/pink/schedule/snapshots/"
	ExecuteSnapshotBasePath    = "/pink/execute/snapshots/"
	ExecuteSnapshotPath        = "/pink/execute/snapshots/%s/%s/%s"
	ExecuteSnapshotHistoryPath = "/pink/execute/history/snapshots/"
)

const (
	Follower = 1
	Leader   = 2
)

const (
	ExecuteSnapshotInit int32 = iota
	ExecuteSnapshotDoing
	ExecuteSnapshotSuccess
	ExecuteSnapshotFail
)

Types

type ExecuteSnapshot

type ExecuteSnapshot struct {
	Id           string `json:"id"`
	JobId        string `json:"job_id"`
	Name         string `json:"name"`
	Group        string `json:"group"`
	Cron         string `json:"cron"`
	Target       string `json:"target"`
	Ip           string `json:"ip"`
	Param        string `json:"param"`
	State        int32  `json:"state"`
	BeforeTime   string `json:"before_time"`
	ScheduleTime string `json:"schedule_time"`
	StartTime    string `json:"start_time"`
	EndTime      string `json:"end_time"`
	Times        int64  `json:"times"`
	Mobile       string `json:"mobile"`
	Version      int32  `json:"version"`
	Remark       string `json:"remark"`
}

func (*ExecuteSnapshot) Decode

func (es *ExecuteSnapshot) Decode(content string) *ExecuteSnapshot

func (*ExecuteSnapshot) Encode

func (es *ExecuteSnapshot) Encode() string

type JobChangeEvent

type JobChangeEvent struct {
	Event   JobChangeEventType
	Content *JobConf
}

type JobChangeEventType

type JobChangeEventType int32

const (
	JobCreateChangeEventType JobChangeEventType = iota + 1
	JobUpdateChangeEventType
	JobDeleteChangeEventType
)

type JobConf

type JobConf struct {
	Id         string `json:"id"`
	Name       string `json:"name"`
	Group      string `json:"group"`
	Cron       string `json:"cron"`
	Target     string `json:"target"`
	Param      string `json:"param"`
	State      int32  `json:"state"`
	Mobile     string `json:"mobile"`
	Remark     string `json:"remark"`
	Version    int32  `json:"version"`
	CreateTime int64  `json:"create_time"`
	UpdateTime int64  `json:"update_time"`
}

func (*JobConf) Decode

func (j *JobConf) Decode(content string) *JobConf

func (*JobConf) Encode

func (j *JobConf) Encode() string

type JobState

type JobState int32

const (
	JobNormalState JobState = iota + 1
	JobStopState
)

type SchedulePlan

type SchedulePlan struct {
	Id         string        `json:"id"`
	Name       string        `json:"name"`
	Group      string        `json:"group"`
	Cron       string        `json:"cron"`
	Target     string        `json:"target"`
	Param      string        `json:"param"`
	BeforeTime time.Time     `json:"before_time"`
	NextTime   time.Time     `json:"next_time"`
	Schedule   cron.Schedule `json:"-"`
	Mobile     string        `json:"mobile"`
	Version    int32         `json:"version"`
	Remark     string        `json:"remark"`
	CreateTime time.Time     `json:"create_time"`
	UpdateTime time.Time     `json:"update_time"`
}

type SchedulePlanSnapshot

type SchedulePlanSnapshot struct {
	Id           string `json:"id"`
	JobId        string `json:"job_id"`
	Name         string `json:"name"`
	Group        string `json:"group"`
	Cron         string `json:"cron"`
	Target       string `json:"target"`
	Param        string `json:"param"`
	BeforeTime   string `json:"before_time"`
	ScheduleTime string `json:"schedule_time"`
	Mobile       string `json:"mobile"`
	Version      int32  `json:"version"`
	Remark       string `json:"remark"`
}

func (*SchedulePlanSnapshot) Decode

func (snapshot *SchedulePlanSnapshot) Decode(content string) *SchedulePlanSnapshot

func (*SchedulePlanSnapshot) Encode

func (snapshot *SchedulePlanSnapshot) Encode() string