worker

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 ¶ added in v0.1.8

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

func (*Handler) GetModuleProperty ¶ added in v0.1.8

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 ¶ added in v0.1.8

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

func (*Handler) ModuleSubmitEvent ¶

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

func (*Handler) ModuleSubmitJob ¶ added in v0.1.5

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

func (*Handler) SetModuleProperties ¶ added in v0.1.8

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

func (*Handler) SetModuleProperty ¶ added in v0.1.8

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);

func (*Worker) Run ¶

func (w *Worker) Run() error