Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GroupManager ¶
type GroupManager struct {
// contains filtered or unexported fields
}
func (*GroupManager) AddInformers ¶
func (g *GroupManager) AddInformers(ctx context.Context, informers map[string]k8sCache.SharedIndexInformer)
func (*GroupManager) Wait ¶
func (g *GroupManager) Wait()
func (*GroupManager) WaitWithTimeout ¶
func (g *GroupManager) WaitWithTimeout(timeout time.Duration) error
type Interface ¶
type Interface interface { // Add will start a go routine for the given "function" and adds it to the list of go routines // and will also remove the "function" from the list when it completes Add(ctx context.Context, function func(context.Context)) AddInformers(ctx context.Context, informers map[string]k8sCache.SharedIndexInformer) // Wait blocks the execution of the process until all the go routines in the manager are completed. Wait() // WaitWithTimeout blocks the execution of the process until timeout or till all all the go routines in the manager are completed WaitWithTimeout(timeout time.Duration) error }
Interface keeps track of the go routines in the system and can be used to gracefully shutdown the the system by waiting for completion of go routines added to it.
Click to show internal directories.
Click to hide internal directories.