protocol

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 11, 2022 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

View Source 
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/"
)
View Source 
const (
	Follower = 1
	Leader   = 2
)
View Source 
const (
	ExecuteSnapshotInit int32 = iota
	ExecuteSnapshotDoing
	ExecuteSnapshotSuccess
	ExecuteSnapshotFail
)

Variables

This section is empty.

Functions

This section is empty.

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.