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) Run(ctx context.Context) error
  • func (s *Server) ScheduleJob(ctx context.Context, req *schedulerv1pb.ScheduleJobRequest) (*schedulerv1pb.ScheduleJobResponse, error)
  • func (s *Server) WatchJobs(stream schedulerv1pb.Scheduler_WatchJobsServer) error

Types

type Options

type Options struct {
	Healthz                 healthz.Healthz
	Security                security.Handler
	ListenAddress           string
	Port                    int
	Mode                    modes.DaprMode
	ReplicaCount            uint32
	ReplicaID               uint32
	DataDir                 string
	EtcdID                  string
	EtcdInitialPeers        []string
	EtcdClientPorts         []string
	EtcdClientHTTPPorts     []string
	EtcdSpaceQuota          int64
	EtcdCompactionMode      string
	EtcdCompactionRetention 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) 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) 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) WatchJobs

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

WatchJobs sends jobs to Dapr sidecars upon component changes.