workerprocess

Documentation

Index

• type ClusterClientBuilder
  • func NewClusterClientBuilder(instance *v1beta1.TemporalWorkerProcess, cluster *v1beta1.TemporalCluster, ...) *ClusterClientBuilder
  • func (b *ClusterClientBuilder) Build() (client.Object, error)
  • func (b *ClusterClientBuilder) Update(object client.Object) error
• type DeploymentBuilder
  • func NewDeploymentBuilder(instance *v1beta1.TemporalWorkerProcess, cluster *v1beta1.TemporalCluster, ...) *DeploymentBuilder
  • func (b *DeploymentBuilder) Build() (client.Object, error)
  • func (b *DeploymentBuilder) EnsureDependencies(ctx context.Context, c client.Client) (time.Duration, error)
  • func (b *DeploymentBuilder) ReportServiceStatus(ctx context.Context, c client.Client) (*v1beta1.ServiceStatus, error)
  • func (b *DeploymentBuilder) Update(object client.Object) error

Types

type ClusterClientBuilder

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

func NewClusterClientBuilder

func NewClusterClientBuilder(instance *v1beta1.TemporalWorkerProcess, cluster *v1beta1.TemporalCluster, scheme *runtime.Scheme) *ClusterClientBuilder

func (*ClusterClientBuilder) Build

func (b *ClusterClientBuilder) Build() (client.Object, error)

func (*ClusterClientBuilder) Update

func (b *ClusterClientBuilder) Update(object client.Object) error

type DeploymentBuilder

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

func NewDeploymentBuilder

func NewDeploymentBuilder(instance *v1beta1.TemporalWorkerProcess, cluster *v1beta1.TemporalCluster, scheme *runtime.Scheme) *DeploymentBuilder

func (*DeploymentBuilder) Build

func (b *DeploymentBuilder) Build() (client.Object, error)

func (*DeploymentBuilder) EnsureDependencies

func (b *DeploymentBuilder) EnsureDependencies(ctx context.Context, c client.Client) (time.Duration, error)

func (*DeploymentBuilder) ReportServiceStatus

func (b *DeploymentBuilder) ReportServiceStatus(ctx context.Context, c client.Client) (*v1beta1.ServiceStatus, error)

func (*DeploymentBuilder) Update

func (b *DeploymentBuilder) Update(object client.Object) error