The highest tagged major version is
Documentation
¶
Index ¶
- Constants
- type Plugin
- func (p *Plugin) ActivityNames() []string
- func (p *Plugin) AddListener(listener events.Listener)
- func (p *Plugin) Init(temporal client.Temporal, server server.Server, log logger.Logger, ...) error
- func (p *Plugin) Name() string
- func (p *Plugin) RPC() interface{}
- func (p *Plugin) Reset() error
- func (p *Plugin) Serve() chan error
- func (p *Plugin) Stop() error
- func (p *Plugin) Workers() []worker.BaseProcess
- type RecordHeartbeatRequest
- type RecordHeartbeatResponse
Constants ¶
View Source
const ( // PluginName defines public service name. PluginName = "activities" // Main plugin name RootPluginName = "temporal" // RRMode sets as RR_MODE env variable to let worker know about the mode to run. RRMode = "temporal/activity" )
View Source
const RR_CODEC = "RR_CODEC" //nolint:golint,stylecheck
RR_CODEC env variable
View Source
const RR_MODE = "RR_MODE" //nolint:golint,stylecheck
RR_MODE env variable
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Plugin ¶
type Plugin struct {
// contains filtered or unexported fields
}
Plugin to manage activity execution.
func (*Plugin) ActivityNames ¶
ActivityNames returns list of all available activities.
func (*Plugin) AddListener ¶
AddListener adds event listeners to the service.
func (*Plugin) Init ¶
func (p *Plugin) Init(temporal client.Temporal, server server.Server, log logger.Logger, cfg config.Configurer) error
Init configures activity service.
func (*Plugin) Workers ¶
func (p *Plugin) Workers() []worker.BaseProcess
Workers returns pool workers.
type RecordHeartbeatRequest ¶
type RecordHeartbeatRequest struct {
TaskToken []byte `json:"taskToken"`
Details []byte `json:"details"`
}
RecordHeartbeatRequest sent by activity to record current state.
type RecordHeartbeatResponse ¶
type RecordHeartbeatResponse struct {
Canceled bool `json:"canceled"`
}
RecordHeartbeatResponse sent back to the worker to indicate that activity was cancelled.
Source Files
Click to show internal directories.
Click to hide internal directories.