mirror of
https://github.com/hanzoai/tasks.git
synced 2026-11-03 03:56:04 +00:00
zeekay
5a601d081b
Full module path rebrand from Temporal to Hanzo Tasks: - go.mod module: github.com/hanzoai/tasks - All internal Go imports updated (1906 files) - cmd/server renamed to cmd/tasksd - Binary name: tasksd (was temporal-server) - Docker images: hanzoai/tasks (was temporalio/server) - README rewritten with Hanzo Tasks branding - LLM.md created with integration notes - Makefile, goreleaser, CI workflows updated - go.temporal.io/sdk and go.temporal.io/api imports preserved (separate repos) Fork of Temporal.io (MIT license).
47 lines
1.3 KiB
Go
47 lines
1.3 KiB
Go
package temporal
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/hanzoai/tasks/common/primitives"
|
|
)
|
|
|
|
const (
|
|
mismatchLogMessage = "Supplied configuration key/value mismatches persisted cluster metadata. Continuing with the persisted value as this value cannot be changed once initialized."
|
|
serviceStartTimeout = time.Duration(15) * time.Second
|
|
serviceStopTimeout = time.Duration(5) * time.Minute
|
|
)
|
|
|
|
type (
|
|
Server interface {
|
|
Start() error
|
|
Stop() error
|
|
}
|
|
)
|
|
|
|
var (
|
|
// Services is the set of all valid temporal services as strings (needs to be strings to
|
|
// keep ServerOptions interface stable)
|
|
Services = []string{
|
|
string(primitives.FrontendService),
|
|
string(primitives.InternalFrontendService),
|
|
string(primitives.HistoryService),
|
|
string(primitives.MatchingService),
|
|
string(primitives.WorkerService),
|
|
}
|
|
|
|
// DefaultServices is the set of services to start by default if services are not given on
|
|
// the command line.
|
|
DefaultServices = []string{
|
|
string(primitives.FrontendService),
|
|
string(primitives.HistoryService),
|
|
string(primitives.MatchingService),
|
|
string(primitives.WorkerService),
|
|
}
|
|
)
|
|
|
|
// NewServer returns a new instance of server that serves one or many services.
|
|
func NewServer(opts ...ServerOption) (Server, error) {
|
|
return NewServerFx(TopLevelModule, opts...)
|
|
}
|