Versions in this module Expand all Collapse all v0 v0.1.1 Sep 9, 2026 Changes in this version type Option + func WithContextPropagators(propagators []workflow.ContextPropagator) Option + func WithInterceptors(interceptors []interceptor.ClientInterceptor) Option v0.1.0 Sep 7, 2026 Changes in this version + func NewConnection(options ...Option) (client.Client, error) + func NewConnectionWithEnvvars(options ...Option) (client.Client, error) + func NewHealthCheck(ctx context.Context, taskQueues []string, address string, c client.Client) error + func NewZerologHandler(zlog *zerolog.Logger) log.Logger + type Compensator struct + func (c *Compensator) Add(fn func(workflow.Context) error) + func (c *Compensator) Compensate(ctx workflow.Context) + type ExternalConfig struct + Factory ExternalConfigFactory + PayloadSizeThreshold int + StorageDriverSelector converter.StorageDriverSelector + type ExternalConfigFactory func() ([]converter.StorageDriver, error) + func ExternalConfigS3Factory(ctx context.Context, cfg *S3Config) ExternalConfigFactory + type Option func(*client.Options) error + func ParseCobraOpts(opts *TemporalOpts, overrides ...Option) []Option + func WithAPICredentials(apiKey string) Option + func WithAuthDetection(apiKey, certPath, certKey string) Option + func WithConnectionOptions(connection *client.ConnectionOptions) Option + func WithCredentials(credential client.Credentials) Option + func WithDataAndFailureConverter(cvt converter.DataConverter) Option + func WithDataConverter(cvt converter.DataConverter) Option + func WithExternalStorage(st converter.ExternalStorage) Option + func WithExternalStorageFactory(e ExternalConfig) Option + func WithFailureConverter(cvt converter.DataConverter) Option + func WithHostPort(hostPort string) Option + func WithLogger(logger log.Logger) Option + func WithMTLS(certPath, certKey string) Option + func WithMetrics(metrics client.MetricsHandler) Option + func WithNamespace(namespace string) Option + func WithNoOp() Option + func WithPrometheusMetrics(listenAddress, prefix string, registry *prom.Registry, onError ...func(error)) Option + func WithTLS(enabled bool, tlsOpts ...TLSOption) Option + func WithZerolog(logger *zerolog.Logger) Option + type PrometheusHandler struct + func NewPrometheusHandler(listenAddress, prefix string, registry *prom.Registry, onError ...func(error)) (*PrometheusHandler, error) + func (h *PrometheusHandler) Close() error + type S3Config struct + AccessKeyID string + Bucket string + DriverName string + Endpoint string + MaxPayloadSize int + Region string + SecretAccessKey string + SessionToken string + UsePathStyle bool + type TLSOption func(*tls.Config) error + func WithTLSServerName(serverName string) TLSOption + type TemporalOpts struct + APIKey string + Address string + HealthListenAddress string + MTLSCertPath string + MTLSKeyPath string + MetricsListenAddress string + MetricsPrefix string + Namespace string + ServerName string + TLSEnabled bool + func NewCobraOpts(cmd *cobra.Command, opts *TemporalOpts) *TemporalOpts
Go to main page