utils

Documentation

Index

• type DS
  • func DistributedService(r manager.Runnable) DS
• type DSD
  • func DelayedShutdown(svc DelayedService) DSD
• type DelayedService

Types

type DS

type DS interface {
	Start(context.Context) error
}

DS ...

func DistributedService

func DistributedService(r manager.Runnable) DS

DistributedService is a wrapper that configures a Runnable to run on every instance of a controller, despite being the leader or not.

type DSD

type DSD interface {
	Start(context.Context) error
}

DSD ...

func DelayedShutdown

func DelayedShutdown(svc DelayedService) DSD

DelayedShutdown adds a delay in the shutdown event, so the runnable has some time to listen to events from other runnables triggered during their shutdown

type DelayedService

type DelayedService interface {
	Start(context.Context) error
	CanShutdown() bool
}

DelayedService ...