Documentation
¶
Index ¶
- type Options
- type Server
- 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
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 (*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 ¶ added in v1.15.0
func (s *Server) ListJobs(ctx context.Context, req *schedulerv1pb.ListJobsRequest) (*schedulerv1pb.ListJobsResponse, error)
func (*Server) ScheduleJob ¶
func (s *Server) ScheduleJob(ctx context.Context, req *schedulerv1pb.ScheduleJobRequest) (*schedulerv1pb.ScheduleJobResponse, error)
func (*Server) WatchHosts ¶ added in v1.15.0
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.
Click to show internal directories.
Click to hide internal directories.