schedules

Documentation

Index

• type ActionState
• type LocalSchedulesService
  • func NewLocalSchedulesService(errorLogger errorsx.ServiceErrorLogger) *LocalSchedulesService
  • func (l *LocalSchedulesService) GetSchedules() State
  • func (l *LocalSchedulesService) HandleRequest(request *schedulespb.ServerMessage) (*schedulespb.ClientMessage, error)
  • func (l *LocalSchedulesService) Schedule(stream schedulespb.Schedules_ScheduleServer) error
  • func (l *LocalSchedulesService) SubscribeToAction(subscription func(ActionState))
  • func (l *LocalSchedulesService) SubscribeToState(fn func(State))
• type ScheduledService
• type State

Types

type ActionState

type ActionState struct {
	ScheduleName string
	Success      bool
}

type LocalSchedulesService

type LocalSchedulesService struct {
	*schedules.ScheduleWorkerManager
	// contains filtered or unexported fields
}

func NewLocalSchedulesService

func NewLocalSchedulesService(errorLogger errorsx.ServiceErrorLogger) *LocalSchedulesService

func (*LocalSchedulesService) GetSchedules

func (l *LocalSchedulesService) GetSchedules() State

func (*LocalSchedulesService) HandleRequest

func (l *LocalSchedulesService) HandleRequest(request *schedulespb.ServerMessage) (*schedulespb.ClientMessage, error)

func (*LocalSchedulesService) Schedule

func (l *LocalSchedulesService) Schedule(stream schedulespb.Schedules_ScheduleServer) error

func (*LocalSchedulesService) SubscribeToAction

func (l *LocalSchedulesService) SubscribeToAction(subscription func(ActionState))

func (*LocalSchedulesService) SubscribeToState

func (l *LocalSchedulesService) SubscribeToState(fn func(State))

type ScheduledService

type ScheduledService struct {
	ServiceName serviceName
	Schedule    *schedulespb.RegistrationRequest
}

type State

type State = map[scheduleName]*ScheduledService