autoprov

Documentation

Index

• func Run()
• type AppChecker
  • func (s *AppChecker) Check(ctx context.Context)
• type AutoProvAggr
  • func NewAutoProvAggr(intervalSec, offsetSec float64, caches *CacheData) *AutoProvAggr
  • func (s *AutoProvAggr) DeleteApp(ctx context.Context, appKey *edgeproto.AppKey)
  • func (s *AutoProvAggr) Run()
  • func (s *AutoProvAggr) Start()
  • func (s *AutoProvAggr) Stop()
  • func (s *AutoProvAggr) UpdateApp(ctx context.Context, appKey *edgeproto.AppKey)
  • func (s *AutoProvAggr) UpdatePolicy(ctx context.Context, key *edgeproto.PolicyKey)
  • func (s *AutoProvAggr) UpdateSettings(ctx context.Context, intervalSec, offsetSec float64)
• type CacheData
• type HasItType
• type MinMaxChecker
  • func (s *MinMaxChecker) CheckApp(ctx context.Context, k interface{})
  • func (s *MinMaxChecker) DeletedApp(ctx context.Context, old *edgeproto.App)
  • func (s *MinMaxChecker) DeletedAppInst(ctx context.Context, inst *edgeproto.AppInst)
  • func (s *MinMaxChecker) DeletedPolicy(ctx context.Context, old *edgeproto.AutoProvPolicy)
  • func (s *MinMaxChecker) UpdatedApp(ctx context.Context, old *edgeproto.App, new *edgeproto.App)
  • func (s *MinMaxChecker) UpdatedAppInst(ctx context.Context, old *edgeproto.AppInst, new *edgeproto.AppInst)
  • func (s *MinMaxChecker) UpdatedAppInstRefs(ctx context.Context, old *edgeproto.AppInstRefs, new *edgeproto.AppInstRefs)
  • func (s *MinMaxChecker) UpdatedCloudlet(ctx context.Context, old *edgeproto.Cloudlet, new *edgeproto.Cloudlet)
  • func (s *MinMaxChecker) UpdatedCloudletInfo(ctx context.Context, old *edgeproto.CloudletInfo, new *edgeproto.CloudletInfo)
  • func (s *MinMaxChecker) UpdatedPolicy(ctx context.Context, old *edgeproto.AutoProvPolicy, ...)
• type RetryTracker

Functions

func Run

func Run()

Types

type AppChecker

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

AppChecker maintains the min and max number of AppInsts for the specified App, based on the policies on the App.

func (*AppChecker) Check

func (s *AppChecker) Check(ctx context.Context)

type AutoProvAggr

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

AutoProvAggr aggregates auto-provisioning stats pulled from influxdb, and deploys or undeploys AppInsts if they meet the policy criteria.

func NewAutoProvAggr

func NewAutoProvAggr(intervalSec, offsetSec float64, caches *CacheData) *AutoProvAggr

func (*AutoProvAggr) DeleteApp

func (s *AutoProvAggr) DeleteApp(ctx context.Context, appKey *edgeproto.AppKey)

func (*AutoProvAggr) Run

func (s *AutoProvAggr) Run()

func (*AutoProvAggr) Start

func (s *AutoProvAggr) Start()

func (*AutoProvAggr) Stop

func (s *AutoProvAggr) Stop()

func (*AutoProvAggr) UpdateApp

func (s *AutoProvAggr) UpdateApp(ctx context.Context, appKey *edgeproto.AppKey)

func (*AutoProvAggr) UpdatePolicy

func (s *AutoProvAggr) UpdatePolicy(ctx context.Context, key *edgeproto.PolicyKey)

func (*AutoProvAggr) UpdateSettings

func (s *AutoProvAggr) UpdateSettings(ctx context.Context, intervalSec, offsetSec float64)

type CacheData

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

type HasItType

type HasItType int

const (
	NotHasIt HasItType = 0
	HasIt    HasItType = 1
)

type MinMaxChecker

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

MinMaxChecker maintains the minimum and maximum number of AppInsts if specified in the policy.

func (*MinMaxChecker) CheckApp

func (s *MinMaxChecker) CheckApp(ctx context.Context, k interface{})

func (*MinMaxChecker) DeletedApp

func (s *MinMaxChecker) DeletedApp(ctx context.Context, old *edgeproto.App)

func (*MinMaxChecker) DeletedAppInst

func (s *MinMaxChecker) DeletedAppInst(ctx context.Context, inst *edgeproto.AppInst)

func (*MinMaxChecker) DeletedPolicy

func (s *MinMaxChecker) DeletedPolicy(ctx context.Context, old *edgeproto.AutoProvPolicy)

func (*MinMaxChecker) UpdatedApp

func (s *MinMaxChecker) UpdatedApp(ctx context.Context, old *edgeproto.App, new *edgeproto.App)

func (*MinMaxChecker) UpdatedAppInst

func (s *MinMaxChecker) UpdatedAppInst(ctx context.Context, old *edgeproto.AppInst, new *edgeproto.AppInst)

func (*MinMaxChecker) UpdatedAppInstRefs

func (s *MinMaxChecker) UpdatedAppInstRefs(ctx context.Context, old *edgeproto.AppInstRefs, new *edgeproto.AppInstRefs)

func (*MinMaxChecker) UpdatedCloudlet

func (s *MinMaxChecker) UpdatedCloudlet(ctx context.Context, old *edgeproto.Cloudlet, new *edgeproto.Cloudlet)

func (*MinMaxChecker) UpdatedCloudletInfo

func (s *MinMaxChecker) UpdatedCloudletInfo(ctx context.Context, old *edgeproto.CloudletInfo, new *edgeproto.CloudletInfo)

func (*MinMaxChecker) UpdatedPolicy

func (s *MinMaxChecker) UpdatedPolicy(ctx context.Context, old *edgeproto.AutoProvPolicy, new *edgeproto.AutoProvPolicy)

type RetryTracker

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