jobs

Documentation

Index

• type JobManager
  • func New() *JobManager
  • func (s *JobManager) HandleJob(handlerConnectionStream batchpb.Job_HandleJobServer) error
  • func (s *JobManager) HandleJobRequest(request *batchpb.ServerMessage) (*batchpb.ClientMessage, error)
  • func (s *JobManager) WorkerCount() int
• type JobName
• type JobRequestHandler
• type WorkerConnection

Types

type JobManager

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

func New

func New() *JobManager

func (*JobManager) HandleJob

func (s *JobManager) HandleJob(handlerConnectionStream batchpb.Job_HandleJobServer) error

Subscribe allows the local nitric server to register new subscribers

called by Nitric applications wishing to subscribe to a topic.
the stream establishes communication between that subscriber and this server

func (*JobManager) HandleJobRequest

func (s *JobManager) HandleJobRequest(request *batchpb.ServerMessage) (*batchpb.ClientMessage, error)

func (*JobManager) WorkerCount

func (s *JobManager) WorkerCount() int

type JobName

type JobName = string

type JobRequestHandler

type JobRequestHandler interface {
	batchpb.JobServer
	HandleJobRequest(request *batchpb.ServerMessage) (*batchpb.ClientMessage, error)
	WorkerCount() int
}

type WorkerConnection

type WorkerConnection = workers.WorkerRequestBroker[*batchpb.ServerMessage, *batchpb.ClientMessage]