Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNoCallValue = errors.New("no call value allowed")
Functions ¶
func EnsureNoCallValues ¶
Types ¶
type Config ¶
type Config struct { TaskQueueName string `envconfig:"TASK_QUEUE_NAME" default:"sessions" json:"task_queue_name"` UpdateStateTimeout time.Duration `envconfig:"UPDATE_STATE_TIMEOUT" default:"30s" json:"update_state_timeout"` ProgramsFetchTimeout time.Duration `envconfig:"PROGRAMS_FETCH_TIMEOUT" default:"1m" json:"programs_fetch_timeout"` LoadPluginsTimeout time.Duration `envconfig:"LOAD_PLUGINS_TIMEOUT" default:"1m" json:"load_plugins_timeout"` // TODO: these should be variable somehow as load and call can take very long time (long running actions). LoadPluginTimeout time.Duration `envconfig:"LOAD_PLUGIN_TIMEOUT" default:"1h" json:"load_plugin_timeout"` CallPluginTimeout time.Duration `envconfig:"CALL_PLUGIN_TIMEOUT" default:"1h" json:"call_plugin_timeout"` HeartbeatInterval time.Duration `envconfig:"HEARTBEAT_INTERVAL" default:"3s" json:"heartbeat_interval"` }
type Sessions ¶
type Sessions struct { Config Config Temporal temporalclient.Client EventsStore eventsstore.Store Programs *programs.Programs Plugins *pluginsreg.Registry GetSecret func(context.Context, apiproject.ProjectID, string) (string, error) GetCreds func(context.Context, apiproject.ProjectID, string, string) ([]byte, error) StateStore statestore.Store L L.Nullable // contains filtered or unexported fields }
Click to show internal directories.
Click to hide internal directories.