services

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Dec 21, 2023 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL