server

package
v1.16.2 Latest Latest
Warning

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

Go to latest
Published: Oct 30, 2025 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Options

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

	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
	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(opts Options) (*Server, error)

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