temporal

type ArchivalConfig struct {
	HistoryState    string
	VisibilityState string
}

type AuthConfig struct {
	Authorizer  string
	ClaimMapper string
}

type BuildOptions struct {
	// BindOnIP is the address services bind to. Defaults to "0.0.0.0".
	BindOnIP string
	// BroadcastAddress is the membership broadcast address (typically the pod IP).
	BroadcastAddress string
	// DynamicConfigPath overrides the default dynamic config file path.
	DynamicConfigPath string
	// DefaultStorePassword / VisibilityStorePassword are the resolved passwords.
	DefaultStorePassword    string
	VisibilityStorePassword string
	// DefaultStorePasswordCommand / VisibilityStorePasswordCommand are used for
	// Temporal 1.31+ IAM auth instead of a static password.
	DefaultStorePasswordCommand    string
	VisibilityStorePasswordCommand string
	// PublicClientHostPort overrides the publicClient host:port.
	PublicClientHostPort string
}

type ConfigData struct {
	Version                  string
	LogLevel                 string
	NumHistoryShards         int32
	DefaultStoreName         string
	VisibilityStoreName      string
	DefaultStore             DatastoreConfig
	VisibilityStore          DatastoreConfig
	BindOnIP                 string
	BroadcastAddress         string
	MTLS                     MTLSConfig
	Metrics                  MetricsConfig
	Authorization            *AuthConfig
	Services                 map[string]ServicePort
	UseInternalFrontend      bool
	EnableGlobalNamespace    bool
	CurrentClusterName       string
	MasterClusterName        string
	FailoverVersionIncrement int
	InitialFailoverVersion   int
	DynamicConfigPath        string
	Archival                 *ArchivalConfig
	PublicClient             string
}

type DatastoreConfig struct {
	// Kind is "sql", "cassandra", or "elasticsearch".
	Kind string

	// SQL fields.
	PluginName      string
	DatabaseName    string
	ConnectAddr     string
	User            string
	Password        string
	PasswordCommand string
	MaxConns        int32
	MaxIdleConns    int32
	MaxConnLifetime string

	// Cassandra fields.
	Hosts      string
	Keyspace   string
	Port       int32
	Datacenter string

	// Elasticsearch fields.
	ESVersion       string
	URLScheme       string
	URLHost         string
	VisibilityIndex string

	TLS *DatastoreTLS
}

type DatastoreTLS struct {
	Enabled                bool
	CAFile                 string
	CertFile               string
	KeyFile                string
	EnableHostVerification bool
	ServerName             string
}

type IntervalParams struct {
	Every  time.Duration
	Offset *time.Duration
}

type MTLSConfig struct {
	Enabled             bool
	RefreshInterval     string
	RequireClientAuth   bool
	InternodeServerCert string
	InternodeServerKey  string
	InternodeClientCA   string
	InternodeServerName string
	FrontendServerCert  string
	FrontendServerKey   string
	FrontendServerName  string
	SystemWorkerCert    string
	SystemWorkerKey     string
	SystemWorkerCA      string
	SystemWorkerName    string
}

type MetricsConfig struct {
	Enabled       bool
	ListenAddress string
}

type NamespaceClient interface {
	Describe(ctx context.Context, name string) (*NamespaceInfo, error)
	Register(ctx context.Context, params NamespaceParams) error
	Update(ctx context.Context, params NamespaceParams) error
	// Failover changes only the namespace's active cluster. It must be a
	// standalone call: Temporal rejects an active-cluster change combined with
	// any other update parameters.
	Failover(ctx context.Context, name, activeCluster string) error
	Delete(ctx context.Context, name string) error
	Close() error
}

type NamespaceClientFactory func(ctx context.Context, address string, tlsConfig *tls.Config) (NamespaceClient, error)

type NamespaceInfo struct {
	ID              string
	Description     string
	OwnerEmail      string
	RetentionPeriod time.Duration
	IsGlobal        bool
	ActiveCluster   string
	Clusters        []string
}

type NamespaceParams struct {
	Name            string
	Description     string
	OwnerEmail      string
	RetentionPeriod time.Duration
	IsGlobal        bool
	Clusters        []string
	ActiveCluster   string
}

type RangeParams struct {
	Start int32
	End   int32
	Step  int32
}

type RemoteClusterClient interface {
	ListRemoteClusters(ctx context.Context) ([]RemoteClusterInfo, error)
	UpsertRemoteCluster(ctx context.Context, frontendAddress string, enableConnection bool) error
	RemoveRemoteCluster(ctx context.Context, name string) error
	Close() error
}

type RemoteClusterClientFactory func(ctx context.Context, address string, tlsConfig *tls.Config) (RemoteClusterClient, error)

type RemoteClusterInfo struct {
	Name                   string
	Address                string
	InitialFailoverVersion int64
	ConnectionEnabled      bool
	HistoryShardCount      int32
}

type RetryParams struct {
	InitialInterval        *time.Duration
	BackoffCoefficient     float64
	MaximumInterval        *time.Duration
	MaximumAttempts        int32
	NonRetryableErrorTypes []string
}

type ScheduleClient interface {
	Describe(ctx context.Context, namespace, scheduleID string) (*ScheduleInfo, error)
	Create(ctx context.Context, params ScheduleParams) error
	Update(ctx context.Context, params ScheduleParams) error
	Pause(ctx context.Context, namespace, scheduleID, notes string) error
	Unpause(ctx context.Context, namespace, scheduleID, notes string) error
	Delete(ctx context.Context, namespace, scheduleID string) error
	Close() error
}

type ScheduleClientFactory func(ctx context.Context, address string, tlsConfig *tls.Config) (ScheduleClient, error)

type ScheduleInfo struct {
	Paused           bool
	Notes            string
	NextActionTimes  []time.Time
	RunningWorkflows int
}

type ScheduleParams struct {
	ScheduleID string
	Namespace  string
	Spec       ScheduleSpecParams
	Action     StartWorkflowParams
	Policies   SchedulePolicyParams
	State      ScheduleStateParams
}

type SchedulePolicyParams struct {
	OverlapPolicy          string
	CatchupWindow          *time.Duration
	PauseOnFailure         bool
	KeepOriginalWorkflowID bool
}

type ScheduleSpecParams struct {
	CronStrings      []string
	Intervals        []IntervalParams
	Calendars        []StructuredCalendarParams
	ExcludeCalendars []StructuredCalendarParams
	StartTime        *time.Time
	EndTime          *time.Time
	Jitter           *time.Duration
	TimezoneName     string
}

type ScheduleStateParams struct {
	Paused           bool
	Notes            string
	LimitedActions   bool
	RemainingActions int64
}

type SearchAttributeClient interface {
	// List returns the custom search attributes for a namespace, keyed by name
	// with the CR-style type string as the value.
	List(ctx context.Context, namespace string) (map[string]string, error)
	Add(ctx context.Context, namespace, name, attrType string) error
	Remove(ctx context.Context, namespace, name string) error
	Close() error
}

type SearchAttributeClientFactory func(ctx context.Context, address string, tlsConfig *tls.Config) (SearchAttributeClient, error)

type ServicePort struct {
	GRPCPort       int32
	MembershipPort int32
	HTTPPort       int32
}

type StartWorkflowParams struct {
	WorkflowType     string
	TaskQueue        string
	WorkflowID       string
	Args             [][]byte
	ExecutionTimeout *time.Duration
	RunTimeout       *time.Duration
	TaskTimeout      *time.Duration
	IDReusePolicy    string
	Retry            *RetryParams
	Memo             map[string][]byte
	SearchAttributes map[string][]byte
}

type StructuredCalendarParams struct {
	Second     []RangeParams
	Minute     []RangeParams
	Hour       []RangeParams
	DayOfMonth []RangeParams
	Month      []RangeParams
	Year       []RangeParams
	DayOfWeek  []RangeParams
	Comment    string
}

type VersionInfo struct {
	// Version is the minor version, e.g. "1.31".
	Version string
	// PatchVersions are the exact supported patch releases, e.g. "1.31.1".
	PatchVersions []string
	// MinSchemaSQL is the minimum SQL schema version required.
	MinSchemaSQL string
	// MinSchemaCassandra is the minimum Cassandra schema version required.
	MinSchemaCassandra string
	// MinSchemaES is the minimum Elasticsearch schema/index template version.
	MinSchemaES string
	// AllowedFromVersions are the minor versions a cluster may upgrade from.
	AllowedFromVersions []string
	// UISeries is the compatible temporal-ui minor series, e.g. "2.34".
	UISeries string
	// DefaultUIVersion is the known-good exact temporal-ui version to pair with.
	DefaultUIVersion string
	// DevServerCLIVersion is the temporalio/temporal CLI image tag whose bundled
	// server is in this line, used to run a dev server for this server version.
	DevServerCLIVersion string
	// CassandraVisibilitySupported reports whether Cassandra may be used as a
	// visibility store on this version.
	CassandraVisibilitySupported bool
	// RemovedDynamicConfig lists dynamic config keys removed in this version.
	RemovedDynamicConfig []string
	// AddedDynamicConfig lists dynamic config keys added in this version.
	AddedDynamicConfig []string
}