worker

Documentation

Index

• type Handler
  • func NewHandler(requests map[string](chan []byte), responses map[string](chan []byte), ...) *Handler
  • func (h *Handler) GetChannel(body string) ([]byte, error)
  • func (h *Handler) GetChannels(body string) ([]byte, error)
  • func (h *Handler) GetConfiguration(body string) ([]byte, error)
  • func (h *Handler) GetJob(body string) ([]byte, error)
  • func (h *Handler) GetJobStatus(body string) ([]byte, error)
  • func (h *Handler) GetJobs(body string) ([]byte, error)
  • func (h *Handler) GetModule(body string) ([]byte, error)
  • func (h *Handler) GetModuleActiveJob(body string) ([]byte, error)
  • func (h *Handler) GetModuleConfiguration(body string) ([]byte, error)
  • func (h *Handler) GetModuleJob(body string) ([]byte, error)
  • func (h *Handler) GetModuleJobs(body string) ([]byte, error)
  • func (h *Handler) GetModuleProperties(body string) ([]byte, error)
  • func (h *Handler) GetModuleProperty(body string) ([]byte, error)
  • func (h *Handler) GetModuleSettings(body string) ([]byte, error)
  • func (h *Handler) GetModuleStatus(body string) ([]byte, error)
  • func (h *Handler) GetModules(body string) ([]byte, error)
  • func (h *Handler) GetSettings(body string) ([]byte, error)
  • func (h *Handler) GetStatus(body string) ([]byte, error)
  • func (h *Handler) ModuleAvailableEvents(body string) ([]byte, error)
  • func (h *Handler) ModuleCancelJob(body string) ([]byte, error)
  • func (h *Handler) ModuleShutdown(module, body string) ([]byte, error)
  • func (h *Handler) ModuleSubmitEvent(body string) ([]byte, error)
  • func (h *Handler) ModuleSubmitJob(body string) ([]byte, error)
  • func (h *Handler) SetModuleProperties(body string) ([]byte, error)
  • func (h *Handler) SetModuleProperty(body string) ([]byte, error)
  • func (h *Handler) TryModuleConnect(body string) ([]byte, error)
  • func (h *Handler) TryModuleDisable(body string) ([]byte, error)
  • func (h *Handler) TryModuleDisconnect(body string) ([]byte, error)
  • func (h *Handler) TryModuleEnable(body string) ([]byte, error)
  • func (h *Handler) TryModuleLoad(body string) ([]byte, error)
  • func (h *Handler) TryModuleReload(body string) ([]byte, error)
  • func (h *Handler) TryModuleUnload(body string) ([]byte, error)
• type Worker
  • func NewWorker(endpoint string, name string, handler *Handler, logger *kitlog.Logger) (worker *Worker, err error)
  • func (w *Worker) Run() error

Types

type Handler

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

func NewHandler

func NewHandler(requests map[string](chan []byte), responses map[string](chan []byte), logger *kitlog.Logger) *Handler

func (*Handler) GetChannel

func (h *Handler) GetChannel(body string) ([]byte, error)

TODO: not implemented, just stubbed rpc GetChannel(ChannelRequest) returns (ChannelResponse);

func (*Handler) GetChannels

func (h *Handler) GetChannels(body string) ([]byte, error)

TODO: not implemented, just stubbed rpc GetChannels(Empty) returns (ChannelsResponse);

func (*Handler) GetConfiguration

func (h *Handler) GetConfiguration(body string) ([]byte, error)

TODO: not implemented, just stubbed

func (*Handler) GetJob

func (h *Handler) GetJob(body string) ([]byte, error)

TODO: not implemented, just stubbed rpc GetJob(JobRequest) returns (JobResponse);

func (*Handler) GetJobStatus

func (h *Handler) GetJobStatus(body string) ([]byte, error)

TODO: not implemented, just stubbed rpc GetJobStatus(JobRequest) returns (JobStatusResponse);

func (*Handler) GetJobs

func (h *Handler) GetJobs(body string) ([]byte, error)

TODO: not implemented, just stubbed rpc GetJobs(Empty) returns (JobsResponse);

func (*Handler) GetModule

func (h *Handler) GetModule(body string) ([]byte, error)

TODO: not implemented, just stubbed rpc GetModule(ModuleRequest) returns (ModuleResponse);

func (*Handler) GetModuleActiveJob

func (h *Handler) GetModuleActiveJob(body string) ([]byte, error)

func (*Handler) GetModuleConfiguration

func (h *Handler) GetModuleConfiguration(body string) ([]byte, error)

func (*Handler) GetModuleJob

func (h *Handler) GetModuleJob(body string) ([]byte, error)

func (*Handler) GetModuleJobs

func (h *Handler) GetModuleJobs(body string) ([]byte, error)

func (*Handler) GetModuleProperties

func (h *Handler) GetModuleProperties(body string) ([]byte, error)

func (*Handler) GetModuleProperty

func (h *Handler) GetModuleProperty(body string) ([]byte, error)

func (*Handler) GetModuleSettings

func (h *Handler) GetModuleSettings(body string) ([]byte, error)

func (*Handler) GetModuleStatus

func (h *Handler) GetModuleStatus(body string) ([]byte, error)

func (*Handler) GetModules

func (h *Handler) GetModules(body string) ([]byte, error)

TODO: not implemented, just stubbed rpc GetModules(Empty) returns (ModulesResponse);

func (*Handler) GetSettings

func (h *Handler) GetSettings(body string) ([]byte, error)

TODO: not implemented, just stubbed rpc GetSettings(SettingsRequest) returns (SettingsResponse);

func (*Handler) GetStatus

func (h *Handler) GetStatus(body string) ([]byte, error)

TODO: not implemented, just stubbed rpc GetStatus(StatusRequest) returns (StatusResponse);

func (*Handler) ModuleAvailableEvents

func (h *Handler) ModuleAvailableEvents(body string) ([]byte, error)

func (*Handler) ModuleCancelJob

func (h *Handler) ModuleCancelJob(body string) ([]byte, error)

func (*Handler) ModuleShutdown

func (h *Handler) ModuleShutdown(module, body string) ([]byte, error)

func (*Handler) ModuleSubmitEvent

func (h *Handler) ModuleSubmitEvent(body string) ([]byte, error)

func (*Handler) ModuleSubmitJob

func (h *Handler) ModuleSubmitJob(body string) ([]byte, error)

func (*Handler) SetModuleProperties

func (h *Handler) SetModuleProperties(body string) ([]byte, error)

func (*Handler) SetModuleProperty

func (h *Handler) SetModuleProperty(body string) ([]byte, error)

func (*Handler) TryModuleConnect

func (h *Handler) TryModuleConnect(body string) ([]byte, error)

TODO: not implemented, just stubbed rpc TryModuleConnect(ModuleRequest) returns (JobResponse);

func (*Handler) TryModuleDisable

func (h *Handler) TryModuleDisable(body string) ([]byte, error)

TODO: not implemented, just stubbed rpc TryModuleDisable(ModuleRequest) returns (JobResponse);

func (*Handler) TryModuleDisconnect

func (h *Handler) TryModuleDisconnect(body string) ([]byte, error)

TODO: not implemented, just stubbed rpc TryModuleDisconnect(ModuleRequest) returns (JobResponse);

func (*Handler) TryModuleEnable

func (h *Handler) TryModuleEnable(body string) ([]byte, error)

TODO: not implemented, just stubbed rpc TryModuleEnable(ModuleRequest) returns (JobResponse);

func (*Handler) TryModuleLoad

func (h *Handler) TryModuleLoad(body string) ([]byte, error)

TODO: not implemented, just stubbed rpc TryModuleLoad(ModuleRequest) returns (JobResponse);

func (*Handler) TryModuleReload

func (h *Handler) TryModuleReload(body string) ([]byte, error)

TODO: not implemented, just stubbed rpc TryModuleReload(ModuleRequest) returns (JobResponse);

func (*Handler) TryModuleUnload

func (h *Handler) TryModuleUnload(body string) ([]byte, error)

TODO: not implemented, just stubbed rpc TryModuleUnload(ModuleRequest) returns (JobResponse);

type Worker

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

The worker class defines a single worker instance:

func NewWorker

func NewWorker(endpoint string, name string, handler *Handler, logger *kitlog.Logger) (worker *Worker, err error)

func (*Worker) Run

func (w *Worker) Run() error