domain

Documentation

Index

• func PollHost(ctx context.Context, host *api.Host, ...) error
• type HostStatefulSetPoller
  • func NewHostStatefulSetPoller(poller *StatefulSetPoller, kube interfaces.IKube, labeler readyMarkDeleter) *HostStatefulSetPoller
  • func (p *HostStatefulSetPoller) WaitHostStatefulSetReady(ctx context.Context, host *api.Host) error
• type StatefulSetPoller
  • func NewStatefulSetPoller(kube interfaces.IKube) *StatefulSetPoller
  • func (p *StatefulSetPoller) PollHostStatefulSet(ctx context.Context, host *api.Host, ...) error

Functions

func PollHost

func PollHost(
	ctx context.Context,
	host *api.Host,
	isDoneFn func(ctx context.Context, host *api.Host) bool,
) error

PollHost polls host

Types

type HostStatefulSetPoller

type HostStatefulSetPoller struct {
	*StatefulSetPoller
	interfaces.IKubeSTS
	// contains filtered or unexported fields
}

HostStatefulSetPoller enriches StatefulSet poller with host capabilities

func NewHostStatefulSetPoller

func NewHostStatefulSetPoller(poller *StatefulSetPoller, kube interfaces.IKube, labeler readyMarkDeleter) *HostStatefulSetPoller

NewHostStatefulSetPoller creates new HostStatefulSetPoller from StatefulSet poller

func (*HostStatefulSetPoller) WaitHostStatefulSetReady

func (p *HostStatefulSetPoller) WaitHostStatefulSetReady(ctx context.Context, host *api.Host) error

WaitHostStatefulSetReady polls host's StatefulSet until it is ready

type StatefulSetPoller

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

func NewStatefulSetPoller

func NewStatefulSetPoller(kube interfaces.IKube) *StatefulSetPoller

func (*StatefulSetPoller) PollHostStatefulSet

func (p *StatefulSetPoller) PollHostStatefulSet(
	ctx context.Context,
	host *api.Host,
	isDoneFn func(context.Context, *apps.StatefulSet) bool,
	backFn func(context.Context),
) error

pollHostStatefulSet polls host's StatefulSet