clientpool

Documentation

Index

• type ClientPool
  • func New(l log.Logger, c runtimeclient.Client) *ClientPool
  • func (cp *ClientPool) Close()
  • func (cp *ClientPool) GetWorkflowServiceClient(hostPort string) (workflowservice.WorkflowServiceClient, bool)
  • func (cp *ClientPool) UpsertClient(ctx context.Context, opts NewClientOptions) (workflowservice.WorkflowServiceClient, error)
• type NewClientOptions

Types

type ClientPool

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

func New

func New(l log.Logger, c runtimeclient.Client) *ClientPool

func (*ClientPool) Close

func (cp *ClientPool) Close()

func (*ClientPool) GetWorkflowServiceClient

func (cp *ClientPool) GetWorkflowServiceClient(hostPort string) (workflowservice.WorkflowServiceClient, bool)

TODO(carlydf): Replace with sdk client (scoped by ns). One controller could need to manage workers for multiple temporal namespaces and/or clusters (self-hosted)

func (*ClientPool) UpsertClient

func (cp *ClientPool) UpsertClient(ctx context.Context, opts NewClientOptions) (workflowservice.WorkflowServiceClient, error)

type NewClientOptions

type NewClientOptions struct {
	TemporalNamespace string
	K8sNamespace      string
	Spec              v1alpha1.TemporalConnectionSpec
}