Help us shape the future of Go! Take the 2026 Go Developer Survey

server

package
v1.18.6 Latest Latest
Warning

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

Go to latest
Published: Oct 9, 2026 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Controller added in v1.18.0

type Controller = controller.Controller

Controller is a long-lived k8s controller that must only be created once per process because controller-runtime registers controller names globally in the metrics registry.

func NewController added in v1.18.0

func NewController(opts ControllerOptions) (*Controller, error)

type ControllerOptions added in v1.18.0

type ControllerOptions = controller.Options

Controller is a long-lived k8s controller that must only be created once per process because controller-runtime registers controller names globally in the metrics registry.

type Options

type Options struct {
	Healthz                   healthz.Healthz
	Security                  security.Handler
	ListenAddress             string
	OverrideBroadcastHostPort *string
	Port                      int
	Mode                      modes.DaprMode
	KubeConfig                *string
	Controller                *controller.Controller

	Workers uint32

	EtcdEmbed                      bool
	EtcdDataDir                    string
	EtcdName                       string
	EtcdInitialCluster             []string
	EtcdClientPort                 uint64
	EtcdClientListenAddress        string
	EtcdSpaceQuota                 int64
	EtcdCompactionMode             string
	EtcdCompactionRetention        string
	EtcdSnapshotCount              uint64
	EtcdMaxSnapshots               uint
	EtcdMaxWALs                    uint
	EtcdBackendBatchLimit          int
	EtcdBackendBatchInterval       string
	EtcdMaxTxnOps                  uint
	EtcdDefragThresholdMB          uint
	EtcdInitialElectionTickAdvance bool
	EtcdMetrics                    string

	EtcdClientEndpoints []string
	EtcdClientUsername  string
	EtcdClientPassword  string
}

type Server

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

Server is the gRPC server for the Scheduler service.

func New

func New(ctx context.Context, opts Options) (*Server, error)

func (*Server) DeleteByMetadata added in v1.17.0

DeleteByMetadata deletes all jobs matching the provided metadata.

func (*Server) DeleteByNamePrefix added in v1.17.0

DeleteByNamePrefix deletes all jobs matching the provided name prefix.

func (*Server) GetJob

func (*Server) ListJobs added in v1.15.0

func (*Server) Run

func (s *Server) Run(ctx context.Context) error

func (*Server) WatchHosts added in v1.15.0

WatchHosts sends the current set of hosts in the scheduler cluster, and updates the sidecars upon changes.

func (*Server) WatchJobs

func (s *Server) WatchJobs(stream schedulerv1pb.Scheduler_WatchJobsServer) error

WatchJobs sends jobs to Dapr sidecars upon component changes.

Jump to

Keyboard shortcuts

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