depend

Documentation

Index

• Constants
• func ResourcesReady(ctx context.Context, acID, app, cluster string)
• type DependManager
  • func NewDependManager(acID string) *DependManager
  • func (dm *DependManager) AddDependency(app string, dep map[string]*types.Criteria) error
  • func (dm *DependManager) ClearChannels(app string)
  • func (dm *DependManager) GetResourceReadyStatus(ctx context.Context, app, cluster, res string) bool
  • func (dm *DependManager) NotifyAppliedStatus(app string)
  • func (dm *DependManager) NotifyReadyStatus(app string)
  • func (dm *DependManager) NotifyStatus(dl []appData)
  • func (dm *DependManager) WaitForDependency(ctx context.Context, app string) error
  • func (dm *DependManager) WaitResourceDependency(ctx context.Context, app, cluster, name string) error
• type DependManagerList

Constants

const SEPARATOR = "+"

Functions

func ResourcesReady

func ResourcesReady(ctx context.Context, acID, app, cluster string)

Inform waiting threads of App Ready

Types

type DependManager

type DependManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewDependManager

func NewDependManager(acID string) *DependManager

New Manager for acID

func (*DependManager) AddDependency

func (dm *DependManager) AddDependency(app string, dep map[string]*types.Criteria) error

Function registers an app for dependency

func (*DependManager) ClearChannels

func (dm *DependManager) ClearChannels(app string)

func (*DependManager) GetResourceReadyStatus

func (dm *DependManager) GetResourceReadyStatus(ctx context.Context, app, cluster, res string) bool

func (*DependManager) NotifyAppliedStatus

func (dm *DependManager) NotifyAppliedStatus(app string)

func (*DependManager) NotifyReadyStatus

func (dm *DependManager) NotifyReadyStatus(app string)

func (*DependManager) NotifyStatus

func (dm *DependManager) NotifyStatus(dl []appData)

func (*DependManager) WaitForDependency

func (dm *DependManager) WaitForDependency(ctx context.Context, app string) error

WaitForDependency waits for all dependecies to be met for an app

func (*DependManager) WaitResourceDependency

func (dm *DependManager) WaitResourceDependency(ctx context.Context, app, cluster, name string) error

WaitResourceDependency waits for the resource to be Success

type DependManagerList

type DependManagerList struct {
	sync.RWMutex
	// contains filtered or unexported fields
}