scheduler

Documentation

Index

• type Server
  • func New(ctx context.Context, cfg *config.Config, d dfpath.Dfpath) (*Server, error)
  • func (s *Server) Serve() error
  • func (s *Server) Stop()

Types

type Server

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

Server is the scheduler server.

func New

func New(ctx context.Context, cfg *config.Config, d dfpath.Dfpath) (*Server, error)

New creates a new scheduler server.

func (*Server) Serve

func (s *Server) Serve() error

Serve starts the scheduler server.

func (*Server) Stop

func (s *Server) Stop()

Stop stops the scheduler server.