worker

type Configuration struct {
	Socket     *socket.Socket       `json:"socket"`
	Execution  string               `json:"execution"`
	StartTime  time.Time            `json:"start_time"`
	EndTime    time.Time            `json:"end_time"`
	Database   *config.Database     `json:"database"`
	Parameters []*storage.Parameter `json:"parameters"`
}

type Instance struct {
	Service *serviceStorage.Instance `json:"-"`

	Running bool `json:"running"`
	// contains filtered or unexported fields
}

type Pool interface {
	Configure(context.Context, *Configuration) error
	Run(context.Context) error
	Process(context.Context, *message.Request) (*message.Response, error)
	Stop(context.Context) error
}