Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

agscheduler

package module

Go to main page

Versions in this module

v0

v0.7.8

May 29, 2024

v0.7.7

May 28, 2024

Changes in this version

type Broker

+ WorkersPerQueue int

v0.7.6

May 28, 2024

v0.7.0

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

v0.6.1

Apr 14, 2024

v0.6.0

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