The highest tagged major version is
Documentation
¶
Index ¶
- Constants
- type Plugin
- func (p *Plugin) ActivityNames() []string
- func (p *Plugin) BaseProcesses() []rrWorker.BaseProcess
- 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() []*process.State
- type RecordHeartbeatRequest
- type RecordHeartbeatResponse
Constants ¶
View Source
const (
// PluginName defines public service name.
PluginName = "activities"
)
View Source
const RR_CODEC = "RR_CODEC" //nolint:revive,stylecheck
RR_CODEC env variable
View Source
const RR_MODE = "RR_MODE" //nolint:revive,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) BaseProcesses ¶ added in v1.0.4
func (p *Plugin) BaseProcesses() []rrWorker.BaseProcess
BaseProcesses returns pool workers.
func (*Plugin) Init ¶
func (p *Plugin) Init(temporal client.Temporal, server server.Server, log logger.Logger, cfg config.Configurer) error
Init configures activity service.
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 canceled.
Source Files
Click to show internal directories.
Click to hide internal directories.