worker

package
v0.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 8, 2021 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

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) (worker *Worker, err error)

func (*Worker) Run

func (w *Worker) Run() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL