Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewSqliteBackend ¶
func NewSqliteBackend(opts *SqliteOptions) *sqliteBackend
NewSqliteBackend creates a new sqlite-based Backend object.
func NewTaskHubWorker ¶
func NewTaskHubWorker(executorFactory func(be backend.Backend) backend.Executor, configure func(opts *SqliteOptions)) backend.TaskHubWorker
NewTaskHubWorker creates a new TaskHubWorker with an initialized sqlite backend.
Use executorFactory to configure an Executor object for use with the new backend.
Use configure to configure options for the sqlite backend or specify `nil` to use the default configuration.
Types ¶
type SqliteOptions ¶
type SqliteOptions struct {
OrchestrationLockTimeout time.Duration
ActivityLockTimeout time.Duration
FilePath string
}
func NewSqliteOptions ¶
func NewSqliteOptions(filePath string) *SqliteOptions
NewSqliteOptions creates a new options object for the sqlite backend provider.
Specify "" for filePath to configure an in-memory database.
Source Files
Click to show internal directories.
Click to hide internal directories.