server

Documentation

Index

• type Options
• type Server
  • func New(opts Options) (*Server, error)
  • func (s *Server) DeleteJob(ctx context.Context, req *schedulerv1pb.DeleteJobRequest) (*schedulerv1pb.DeleteJobResponse, error)
  • func (s *Server) GetJob(ctx context.Context, req *schedulerv1pb.GetJobRequest) (*schedulerv1pb.GetJobResponse, error)
  • func (s *Server) ListJobs(ctx context.Context, req *schedulerv1pb.ListJobsRequest) (*schedulerv1pb.ListJobsResponse, error)
  • func (s *Server) Run(ctx context.Context) error
  • func (s *Server) ScheduleJob(ctx context.Context, req *schedulerv1pb.ScheduleJobRequest) (*schedulerv1pb.ScheduleJobResponse, error)
  • func (s *Server) WatchHosts(_ *schedulerv1pb.WatchHostsRequest, ...) error
  • func (s *Server) WatchJobs(stream schedulerv1pb.Scheduler_WatchJobsServer) error

Types

type Options

type Options struct {
	Healthz                   healthz.Healthz
	Security                  security.Handler
	ListenAddress             string
	OverrideBroadcastHostPort *string
	Port                      int
	Mode                      modes.DaprMode
	KubeConfig                *string
	DataDir                   string
	EtcdID                    string
	EtcdInitialPeers          []string
	EtcdClientPorts           []string
	EtcdClientHTTPPorts       []string
	EtcdSpaceQuota            int64
	EtcdCompactionMode        string
	EtcdCompactionRetention   string
	EtcdSnapshotCount         uint64
	EtcdMaxSnapshots          uint
	EtcdMaxWALs               uint
}

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) DeleteJob

func (s *Server) DeleteJob(ctx context.Context, req *schedulerv1pb.DeleteJobRequest) (*schedulerv1pb.DeleteJobResponse, error)

func (*Server) GetJob

func (s *Server) GetJob(ctx context.Context, req *schedulerv1pb.GetJobRequest) (*schedulerv1pb.GetJobResponse, error)

func (*Server) ListJobs

func (s *Server) ListJobs(ctx context.Context, req *schedulerv1pb.ListJobsRequest) (*schedulerv1pb.ListJobsResponse, error)

func (*Server) Run

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

func (*Server) ScheduleJob

func (s *Server) ScheduleJob(ctx context.Context, req *schedulerv1pb.ScheduleJobRequest) (*schedulerv1pb.ScheduleJobResponse, error)

func (*Server) WatchHosts

func (s *Server) WatchHosts(_ *schedulerv1pb.WatchHostsRequest, stream schedulerv1pb.Scheduler_WatchHostsServer) error

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.