services

Documentation

Index

• type CRPCService
  • func (crs *CRPCService) Nodes(filters map[string]any, reply *map[string]map[string]map[string]any) error
  • func (crs *CRPCService) Ping(args *agscheduler.Node, reply *agscheduler.Node) error
  • func (crs *CRPCService) Register(args *agscheduler.Node, reply *agscheduler.Node) error
• type ClusterService
  • func (s *ClusterService) Start() error
• type HTMLRoute
• type SchedulerHTTPService
  • func (s *SchedulerHTTPService) AddHTMLGlobPath(globPath string)
  • func (s *SchedulerHTTPService) AddHTMLRoute(urlPath, htmlFile string)
  • func (s *SchedulerHTTPService) AddRoute(routeFunc func(r *gin.Engine))
  • func (s *SchedulerHTTPService) AddStaticPath(urlPath, localPath string)
  • func (s *SchedulerHTTPService) Start() error
• type SchedulerRPCService
  • func (s *SchedulerRPCService) Start() error

Types

type CRPCService

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

func (*CRPCService) Nodes

func (crs *CRPCService) Nodes(filters map[string]any, reply *map[string]map[string]map[string]any) error

func (*CRPCService) Ping

func (crs *CRPCService) Ping(args *agscheduler.Node, reply *agscheduler.Node) error

func (*CRPCService) Register

func (crs *CRPCService) Register(args *agscheduler.Node, reply *agscheduler.Node) error

type ClusterService

type ClusterService struct {
	Cn *agscheduler.ClusterNode
}

func (*ClusterService) Start

func (s *ClusterService) Start() error

type HTMLRoute

type HTMLRoute struct {
	URLPath  string
	HTMLFile string
}

type SchedulerHTTPService

type SchedulerHTTPService struct {
	Scheduler *agscheduler.Scheduler

	// Default: `127.0.0.1:36370`
	Address      string
	StaticPaths  map[string]string     // New field for static paths
	ExtraRoutes  []func(r *gin.Engine) // New field for additional routes
	HTMLRoutes   []HTMLRoute           // New field for HTML routes
	HTMLGlobPath string                // New field for HTML glob path
}

func (*SchedulerHTTPService) AddHTMLGlobPath

func (s *SchedulerHTTPService) AddHTMLGlobPath(globPath string)

func (*SchedulerHTTPService) AddHTMLRoute

func (s *SchedulerHTTPService) AddHTMLRoute(urlPath, htmlFile string)

New method to add HTML resource routes

func (*SchedulerHTTPService) AddRoute

func (s *SchedulerHTTPService) AddRoute(routeFunc func(r *gin.Engine))

New method to add extra routes

func (*SchedulerHTTPService) AddStaticPath

func (s *SchedulerHTTPService) AddStaticPath(urlPath, localPath string)

New method to add static paths

func (*SchedulerHTTPService) Start

func (s *SchedulerHTTPService) Start() error

type SchedulerRPCService

type SchedulerRPCService struct {
	Scheduler *agscheduler.Scheduler

	// Default: `127.0.0.1:36360`
	Address string
}

func (*SchedulerRPCService) Start

func (s *SchedulerRPCService) Start() error