agscheduler

Jun 20, 2024

Changes in this version

+ const EVENT_ALL

+ const EVENT_ALL_JOBS_DELETED

+ const EVENT_JOB_ADDED

+ const EVENT_JOB_DELETED

+ const EVENT_JOB_ERROR

+ const EVENT_JOB_EXECUTED

+ const EVENT_JOB_PAUSED

+ const EVENT_JOB_RESUMED

+ const EVENT_JOB_TIMEOUT

+ const EVENT_JOB_UPDATED

+ const EVENT_SCHEDULER_STARTED

+ const EVENT_SCHEDULER_STOPPED

+ var GetListener = (*Scheduler).getListener

+ type CallbackPkg struct

+ Callback func(ep EventPkg)

+ Event event

+ type EventPkg struct

+ Data any

+ Event event

+ JobId string

+ type Listener struct

+ Callbacks []CallbackPkg

type Scheduler

+ func (s *Scheduler) HasListener() bool

+ func (s *Scheduler) SetListener(lis *Listener) error

Jun 14, 2024

Changes in this version

+ func QueueToPbQueuePtr(q map[string]any) (*pb.Queue, error)

+ func QueuesToPbQueuesPtr(qs []map[string]any) ([]*pb.Queue, error)

type Backend

+ Name func() string

type Broker

+ func (b *Broker) Clear(queue string) error

+ func (b *Broker) CountJobs(queue string) (int, error)

+ func (b *Broker) GetQueues() []map[string]any

type Queue

+ CountJobs func() (int, error)

+ Name func() string

+ type QueuePkg struct

+ Queue Queue

+ Workers int

type Store

+ Name func() string

Jun 5, 2024

Changes in this version

+ func JobMarshal(j Job) ([]byte, error)

type Job

+ func JobUnmarshal(bJ []byte) (Job, error)

Jun 2, 2024

Changes in this version

+ const JOB_STATUS_PAUSED

+ const JOB_STATUS_RUNNING

+ const JOB_TYPE_CRON

+ const JOB_TYPE_DATETIME

+ const JOB_TYPE_INTERVAL

+ const RECORD_STATUS_COMPLETED

+ const RECORD_STATUS_ERROR

+ const RECORD_STATUS_RUNNING

+ const RECORD_STATUS_TIMEOUT

+ var GetRecorder = (*Scheduler).getRecorder

+ func RecordToPbRecordPtr(r Record) (*pb.Record, error)

+ func RecordsToPbRecordsPtr(rs []Record) ([]*pb.Record, error)

+ type Backend interface

+ Clear func() error

+ DeleteAllRecords func() error

+ DeleteRecords func(jId string) error

+ GetAllRecords func(page, pageSize int) ([]Record, int64, error)

+ GetRecords func(jId string, page, pageSize int) ([]Record, int64, error)

+ Init func() error

+ RecordMetadata func(r Record) error

+ RecordResult func(id uint64, status string, result string) error

+ type Record struct

+ EndAt time.Time

+ Id uint64

+ JobId string

+ JobName string

+ Result string

+ StartAt time.Time

+ Status string

+ func PbRecordPtrToRecord(pbRecord *pb.Record) Record

+ func PbRecordsPtrToRecords(pbRs []*pb.Record) []Record

+ type RecordSlice []Record

+ func (rs RecordSlice) Len() int

+ func (rs RecordSlice) Less(i, j int) bool

+ func (rs RecordSlice) Swap(i, j int)

+ type Recorder struct

+ Backend Backend

+ func (r *Recorder) Clear() error

+ func (r *Recorder) DeleteAllRecords() error

+ func (r *Recorder) DeleteRecords(jId string) error

+ func (r *Recorder) GetAllRecords(page, pageSize int) ([]Record, int64, error)

+ func (r *Recorder) GetRecords(jId string, page, pageSize int) ([]Record, int64, error)

+ func (r *Recorder) RecordMetadata(j Job) (id uint64, err error)

+ func (r *Recorder) RecordResult(id uint64, status string, result string) error

type Role

+ const RAFT_CANDIDATE

+ const RAFT_FOLLOWER

+ const RAFT_LEADER

type Scheduler

+ func (s *Scheduler) HasBroker() bool

+ func (s *Scheduler) HasRecorder() bool

+ func (s *Scheduler) SetRecorder(rec *Recorder) error

May 28, 2024

Changes in this version

type Broker

+ WorkersPerQueue int

May 23, 2024

Changes in this version

+ var GetBroker = (*Scheduler).getBroker

+ type Broker struct

+ MaxWorkers int

+ Queues map[string]Queue

type Job

+ func (j Job) DeepCopy() (Job, error)

+ type Queue interface

+ Clear func() error

+ Init func() error

+ PullJob func() <-chan []byte

+ PushJob func(j Job) error

type Scheduler

+ func (s *Scheduler) IsBrokerMode() bool

+ func (s *Scheduler) SetBroker(brk *Broker) error

Mar 29, 2024

Changes in this version

+ const STATUS_PAUSED

+ const STATUS_RUNNING

+ const TYPE_CRON

+ const TYPE_DATETIME

+ const TYPE_INTERVAL

+ const Version

+ var FuncMap = make(map[string]FuncPkg)

+ var GetClusterNode = (*Scheduler).getClusterNode

+ var GetStore = (*Scheduler).getStore

+ func CalcNextRunTime(j Job) (time.Time, error)

+ func FuncMapReadable() []map[string]string

+ func GetNextRunTimeMax() (time.Time, error)

+ func JobToPbJobPtr(j Job) (*pb.Job, error)

+ func JobsToPbJobsPtr(js []Job) (*pb.Jobs, error)

+ func RegisterFuncs(fps ...FuncPkg)

+ func StateDump(j Job) ([]byte, error)

+ type ClusterNode struct

+ Endpoint string

+ EndpointGRPC string

+ EndpointHTTP string

+ EndpointMain string

+ Mode string

+ Queue string

+ Raft *Raft

+ Scheduler *Scheduler

+ SchedulerCanStart bool

+ func (cn *ClusterNode) GetEndpointMain() string

+ func (cn *ClusterNode) HANodeMap() TypeNodeMap

+ func (cn *ClusterNode) IsMainNode() bool

+ func (cn *ClusterNode) MainNode() map[string]any

+ func (cn *ClusterNode) NodeMapCopy() TypeNodeMap

+ func (cn *ClusterNode) NodeMapToPbNodesPtr() *pb.Nodes

+ func (cn *ClusterNode) RPCHeartbeat(args *Node, reply *Node)

+ func (cn *ClusterNode) RPCRegister(args *Node, reply *Node)

+ func (cn *ClusterNode) RegisterNodeRemote(ctx context.Context) error

+ func (cn *ClusterNode) SetEndpointMain(endpoint string)

+ type FuncPkg struct

+ Func func(context.Context, Job)

+ Info string

+ type FuncUnregisteredError string

+ func (e FuncUnregisteredError) Error() string

+ type HeartbeatArgs struct

+ LeaderEndpoint string

+ SchedulerCanStart bool

+ Term int

+ type HeartbeatReply struct

+ Term int

+ type Job struct

+ Args map[string]any

+ CronExpr string

+ EndAt string

+ Func func(context.Context, Job)

+ FuncName string

+ Id string

+ Interval string

+ LastRunTime time.Time

+ Name string

+ NextRunTime time.Time

+ Queues []string

+ StartAt string

+ Status string

+ Timeout string

+ Timezone string

+ Type string

+ func PbJobPtrToJob(pbJob *pb.Job) Job

+ func PbJobsPtrToJobs(pbJs *pb.Jobs) []Job

+ func StateLoad(state []byte) (Job, error)

+ func (j *Job) FullName() string

+ func (j *Job) LastRunTimeWithTimezone() time.Time

+ func (j *Job) NextRunTimeWithTimezone() time.Time

+ func (j Job) String() string

+ type JobNotFoundError string

+ func (e JobNotFoundError) Error() string

+ type JobSlice []Job

+ func (js JobSlice) Len() int

+ func (js JobSlice) Less(i, j int) bool

+ func (js JobSlice) Swap(i, j int)

+ type JobTimeoutError struct

+ Err error

+ FullName string

+ Timeout string

+ func (e *JobTimeoutError) Error() string

+ type Node struct

+ Endpoint string

+ EndpointGRPC string

+ EndpointHTTP string

+ EndpointMain string

+ Mode string

+ NodeMap TypeNodeMap

+ Queue string

+ type Raft struct

+ func (rf *Raft) RPCHeartbeat(args HeartbeatArgs, reply *HeartbeatReply) error

+ func (rf *Raft) RPCRequestVote(args VoteArgs, reply *VoteReply) error

+ type Role int

+ const Candidate

+ const Follower

+ const Leader

+ type Scheduler struct

+ func (s *Scheduler) AddJob(j Job) (Job, error)

+ func (s *Scheduler) DeleteAllJobs() error

+ func (s *Scheduler) DeleteJob(id string) error

+ func (s *Scheduler) GetAllJobs() ([]Job, error)

+ func (s *Scheduler) GetJob(id string) (Job, error)

+ func (s *Scheduler) Info() map[string]any

+ func (s *Scheduler) IsClusterMode() bool

+ func (s *Scheduler) IsRunning() bool

+ func (s *Scheduler) PauseJob(id string) (Job, error)

+ func (s *Scheduler) ResumeJob(id string) (Job, error)

+ func (s *Scheduler) RunJob(j Job) error

+ func (s *Scheduler) ScheduleJob(j Job) error

+ func (s *Scheduler) SetClusterNode(ctx context.Context, cn *ClusterNode) error

+ func (s *Scheduler) SetStore(sto Store) error

+ func (s *Scheduler) Start()

+ func (s *Scheduler) Stop()

+ func (s *Scheduler) UpdateJob(j Job) (Job, error)

+ type Store interface

+ AddJob func(j Job) error

+ Clear func() error

+ DeleteAllJobs func() error

+ DeleteJob func(id string) error

+ GetAllJobs func() ([]Job, error)

+ GetJob func(id string) (Job, error)

+ GetNextRunTime func() (time.Time, error)

+ Init func() error

+ UpdateJob func(j Job) error

+ type TypeNodeMap map[string]map[string]any

+ type VoteArgs struct

+ CandidateEndpoint string

+ Term int

+ type VoteReply struct

+ Term int

+ VoteGranted bool