schedules

Documentation

Index

• type ScheduleName
• type ScheduleRequestHandler
• type ScheduleWorkerManager
  • func New() *ScheduleWorkerManager
  • func (s *ScheduleWorkerManager) HandleRequest(request *schedulespb.ServerMessage) (*schedulespb.ClientMessage, error)
  • func (s *ScheduleWorkerManager) Schedule(stream schedulespb.Schedules_ScheduleServer) error
  • func (s *ScheduleWorkerManager) WorkerCount() int
• type WorkerConnection

Types

type ScheduleName

type ScheduleName = string

type ScheduleRequestHandler

type ScheduleRequestHandler interface {
	schedulespb.SchedulesServer
	HandleRequest(request *schedulespb.ServerMessage) (*schedulespb.ClientMessage, error)
	WorkerCount() int
}

type ScheduleWorkerManager

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

func New

func New() *ScheduleWorkerManager

func (*ScheduleWorkerManager) HandleRequest

func (s *ScheduleWorkerManager) HandleRequest(request *schedulespb.ServerMessage) (*schedulespb.ClientMessage, error)

func (*ScheduleWorkerManager) Schedule

func (s *ScheduleWorkerManager) Schedule(stream schedulespb.Schedules_ScheduleServer) error

func (*ScheduleWorkerManager) WorkerCount

func (s *ScheduleWorkerManager) WorkerCount() int

type WorkerConnection

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