server

Documentation

Index

• func IsValidCronJobHandle(handle string) bool
• func IsValidJobHandle(handle string) bool
• func LocalIP() (net.IP, error)
• func ReadMessage(r io.Reader) (runtime.PT, []byte, error)
• type AP
  • func ParseTextMessage(msg string) (AP, string)
• type Client
• type Config
• type Server
  • func NewServer(cfg Config) *Server
  • func (s *Server) Clients() int
  • func (s *Server) DeleteCronJob(cj *CronJob) error
  • func (s *Server) EvtLoop()
  • func (s *Server) ExpressionToEpoch(scdTime string) (int64, bool)
  • func (s *Server) Jobs() int
  • func (s *Server) RunningJobsByFunction() map[string]int
  • func (s *Server) RunningJobsByWorker() map[string]int
  • func (s *Server) Start()
  • func (s *Server) Stats() map[string]int
  • func (s *Server) WatchJobTimeout()
  • func (s *Server) WatcherLoop()
  • func (s *Server) Workers() int
• type Session
  • func (s *Session) Send(data []byte) bool
• type Tuple
• type Worker
  • func (w *Worker) MarshalJSON() ([]byte, error)

Functions

func IsValidCronJobHandle

func IsValidCronJobHandle(handle string) bool

func IsValidJobHandle

func IsValidJobHandle(handle string) bool

func LocalIP

func LocalIP() (net.IP, error)

func ReadMessage

func ReadMessage(r io.Reader) (runtime.PT, []byte, error)

Types

type AP

type AP string

const (
	AP_Workers         AP = "workers"
	AP_Status          AP = "status"
	AP_Cancel          AP = "cancel-job"
	AP_Show            AP = "show"
	AP_Create          AP = "create"
	AP_Drop            AP = "drop"
	AP_MaxQueue        AP = "maxqueue"
	AP_GetPid          AP = "getpid"
	AP_Shutdown        AP = "shutdown"
	AP_Verbose         AP = "verbose"
	AP_Version         AP = "version"
	AP_PRIORITY_STATUS AP = "prioritystatus"
)

func ParseTextMessage

func ParseTextMessage(msg string) (AP, string)

type Client

type Client struct {
	Session
}

type Config

type Config struct {
	ListenAddr string
	Storage    string
	WebAddress string
}

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(cfg Config) *Server

func (*Server) Clients

func (s *Server) Clients() int

func (*Server) DeleteCronJob

func (s *Server) DeleteCronJob(cj *CronJob) error

func (*Server) EvtLoop

func (s *Server) EvtLoop()

func (*Server) ExpressionToEpoch

func (s *Server) ExpressionToEpoch(scdTime string) (int64, bool)

func (*Server) Jobs

func (s *Server) Jobs() int

func (*Server) RunningJobsByFunction

func (s *Server) RunningJobsByFunction() map[string]int

func (*Server) RunningJobsByWorker

func (s *Server) RunningJobsByWorker() map[string]int

func (*Server) Start

func (s *Server) Start()

func (*Server) Stats

func (s *Server) Stats() map[string]int

func (*Server) WatchJobTimeout

func (s *Server) WatchJobTimeout()

func (*Server) WatcherLoop

func (s *Server) WatcherLoop()

func (*Server) Workers

func (s *Server) Workers() int

type Session

type Session struct {
	SessionId int64

	ConnectAt time.Time
	// contains filtered or unexported fields
}

func (*Session) Send

func (s *Session) Send(data []byte) bool

type Tuple

type Tuple struct {
	// contains filtered or unexported fields
}

type Worker

type Worker struct {
	net.Conn
	Session
	// contains filtered or unexported fields
}

func (*Worker) MarshalJSON

func (w *Worker) MarshalJSON() ([]byte, error)