factory

Documentation

Index

• type Factory
  • func New(opts ...OptionsFunc) Factory
• type OptionsFunc
  • func WithLogger(logger logger.Logger) OptionsFunc
  • func WithMaxRetries(maxRetries int) OptionsFunc
  • func WithMaxTotalTime(maxTotalTime time.Duration) OptionsFunc
  • func WithRetryInterval(retryInterval time.Duration) OptionsFunc
• type RetryFactory
  • func (f *RetryFactory) ArtifactClient(ctx context.Context, connectionString string) (artifactservice.ArtifactServiceClient, error)
  • func (f *RetryFactory) TemporalClient(ctx context.Context, hostPort string) (client.Client, error)

Types

type Factory

type Factory interface {
	TemporalClient(ctx context.Context, hostPort string) (client.Client, error)
	ArtifactClient(ctx context.Context, connectionString string) (artifactservice.ArtifactServiceClient, error)
}

func New

func New(opts ...OptionsFunc) Factory

type OptionsFunc

type OptionsFunc func(*RetryFactory)

func WithLogger

func WithLogger(logger logger.Logger) OptionsFunc

func WithMaxRetries

func WithMaxRetries(maxRetries int) OptionsFunc

func WithMaxTotalTime

func WithMaxTotalTime(maxTotalTime time.Duration) OptionsFunc

func WithRetryInterval

func WithRetryInterval(retryInterval time.Duration) OptionsFunc

type RetryFactory

type RetryFactory struct {
	// contains filtered or unexported fields
}

func (*RetryFactory) ArtifactClient

func (f *RetryFactory) ArtifactClient(ctx context.Context, connectionString string) (artifactservice.ArtifactServiceClient, error)

func (*RetryFactory) TemporalClient

func (f *RetryFactory) TemporalClient(ctx context.Context, hostPort string) (client.Client, error)