server

Documentation

Index

• type GrpcServer
  • func NewGrpcServer(meta meta.Provider, r *Registry) (*GrpcServer, error)
  • func (srv *GrpcServer) AgentHeartbeat(ctx context.Context, req *pb.AgentHeartbeatReq) (*pb.AgentHeartbeatRes, error)
  • func (srv *GrpcServer) GetLogger() *dlog.Logger
  • func (srv *GrpcServer) ListAgent(ctx context.Context, req *pb.ListAgentReq) (*pb.ListAgentRes, error)
  • func (srv *GrpcServer) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity
  • func (srv *GrpcServer) NodeInfo(ctx context.Context, _ *pb.NodeInfoReq) (*pb.NodeInfoRes, error)
  • func (srv *GrpcServer) Ping(ctx context.Context, ping *pb.Ping) (*pb.Pong, error)
  • func (srv *GrpcServer) RegisterAgent(ctx context.Context, req *pb.RegisterAgentReq) (*pb.RegisterAgentRes, error)
  • func (srv *GrpcServer) SetLogger(logger *dlog.Logger)
  • func (srv *GrpcServer) SubmitJob(ctx context.Context, req *pb.SubmitJobReq) (*pb.SubmitJobRes, error)
• type HttpServer
  • func NewHttpServer(meta meta.Provider, r *Registry) (*HttpServer, error)
  • func (srv *HttpServer) GetLogger() *dlog.Logger
  • func (srv *HttpServer) Handler() http.Handler
  • func (srv *HttpServer) ListAgent(ctx context.Context) (*pb.ListAgentRes, error)
  • func (srv *HttpServer) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity
  • func (srv *HttpServer) NodeInfo(ctx context.Context) (*pb.NodeInfoRes, error)
  • func (srv *HttpServer) Ping(ctx context.Context, ping *pb.Ping) (*pb.Pong, error)
  • func (srv *HttpServer) RegisterHandler(mux *ihttp.JsonHandlerMux)
  • func (srv *HttpServer) SetLogger(logger *dlog.Logger)
• type JobPoller
  • func NewJobPoller(r *Registry, pollInterval time.Duration) (*JobPoller, error)
  • func (j *JobPoller) GetLogger() *dlog.Logger
  • func (j *JobPoller) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity
  • func (j *JobPoller) RunWithContext(ctx context.Context) error
  • func (j *JobPoller) SetLogger(logger *dlog.Logger)
• type Manager
  • func NewManager(cfg config.CentralServerConfig) (*Manager, error)
  • func (mgr *Manager) GetLogger() *dlog.Logger
  • func (mgr *Manager) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity
  • func (mgr *Manager) Run() error
  • func (mgr *Manager) SetLogger(logger *dlog.Logger)
• type Registry
  • func NewRegistry(cfg config.CentralServerConfig) (*Registry, error)
  • func (r *Registry) AddJob(job *job.Manager) error
  • func (r *Registry) NodeInfo() pb.NodeInfo

Types

type GrpcServer

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

func NewGrpcServer

func NewGrpcServer(meta meta.Provider, r *Registry) (*GrpcServer, error)

func (*GrpcServer) AgentHeartbeat

func (srv *GrpcServer) AgentHeartbeat(ctx context.Context, req *pb.AgentHeartbeatReq) (*pb.AgentHeartbeatRes, error)

func (*GrpcServer) GetLogger

func (srv *GrpcServer) GetLogger() *dlog.Logger

func (*GrpcServer) ListAgent

func (srv *GrpcServer) ListAgent(ctx context.Context, req *pb.ListAgentReq) (*pb.ListAgentRes, error)

func (*GrpcServer) LoggerIdentity

func (srv *GrpcServer) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity

func (*GrpcServer) NodeInfo

func (srv *GrpcServer) NodeInfo(ctx context.Context, _ *pb.NodeInfoReq) (*pb.NodeInfoRes, error)

func (*GrpcServer) Ping

func (srv *GrpcServer) Ping(ctx context.Context, ping *pb.Ping) (*pb.Pong, error)

func (*GrpcServer) RegisterAgent

func (srv *GrpcServer) RegisterAgent(ctx context.Context, req *pb.RegisterAgentReq) (*pb.RegisterAgentRes, error)

func (*GrpcServer) SetLogger

func (srv *GrpcServer) SetLogger(logger *dlog.Logger)

func (*GrpcServer) SubmitJob

func (srv *GrpcServer) SubmitJob(ctx context.Context, req *pb.SubmitJobReq) (*pb.SubmitJobRes, error)

SubmitJob handles job spec submitted by client and return an id to it

type HttpServer

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

func NewHttpServer

func NewHttpServer(meta meta.Provider, r *Registry) (*HttpServer, error)

func (*HttpServer) GetLogger

func (srv *HttpServer) GetLogger() *dlog.Logger

func (*HttpServer) Handler

func (srv *HttpServer) Handler() http.Handler

func (*HttpServer) ListAgent

func (srv *HttpServer) ListAgent(ctx context.Context) (*pb.ListAgentRes, error)

func (*HttpServer) LoggerIdentity

func (srv *HttpServer) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity

func (*HttpServer) NodeInfo

func (srv *HttpServer) NodeInfo(ctx context.Context) (*pb.NodeInfoRes, error)

func (*HttpServer) Ping

func (srv *HttpServer) Ping(ctx context.Context, ping *pb.Ping) (*pb.Pong, error)

func (*HttpServer) RegisterHandler

func (srv *HttpServer) RegisterHandler(mux *ihttp.JsonHandlerMux)

func (*HttpServer) SetLogger

func (srv *HttpServer) SetLogger(logger *dlog.Logger)

type JobPoller

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

JobPoller get job for store and create job managers to run them

func NewJobPoller

func NewJobPoller(r *Registry, pollInterval time.Duration) (*JobPoller, error)

func (*JobPoller) GetLogger

func (j *JobPoller) GetLogger() *dlog.Logger

func (*JobPoller) LoggerIdentity

func (j *JobPoller) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity

func (*JobPoller) RunWithContext

func (j *JobPoller) RunWithContext(ctx context.Context) error

func (*JobPoller) SetLogger

func (j *JobPoller) SetLogger(logger *dlog.Logger)

type Manager

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

func NewManager

func NewManager(cfg config.CentralServerConfig) (*Manager, error)

func (*Manager) GetLogger

func (mgr *Manager) GetLogger() *dlog.Logger

func (*Manager) LoggerIdentity

func (mgr *Manager) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity

func (*Manager) Run

func (mgr *Manager) Run() error

Run creates the following long running goroutines

job poller http server grpc server

func (*Manager) SetLogger

func (mgr *Manager) SetLogger(logger *dlog.Logger)

type Registry

type Registry struct {
	Config    config.CentralServerConfig
	Meta      meta.Provider
	Scheduler scheduler.Scheduler
	// contains filtered or unexported fields
}

func NewRegistry

func NewRegistry(cfg config.CentralServerConfig) (*Registry, error)

func (*Registry) AddJob

func (r *Registry) AddJob(job *job.Manager) error

func (*Registry) NodeInfo

func (r *Registry) NodeInfo() pb.NodeInfo