context

Documentation

Index

• Variables
• func DownloadContext(ctxID string, appName string) (*context.Context, error)
• func Init() error
• func LatestWorkloadIDKey(resourceID string, appName string) string
• func New(userconf *userconfig.Config, files map[string][]byte, ignoreCache bool) (*context.Context, error)
• func StatusKey(resourceID string, workloadID string, appName string) string
• func StatusPrefix(appName string) string
• func ValidateInput(input interface{}, schema *userconfig.InputSchema, ...) (interface{}, string, error)
• func WorkloadSpecKey(workloadID string, appName string) string

Variables

var (
	OperatorAggregatorsDir = configreader.MustStringFromEnv(
		"CONST_OPERATOR_AGGREGATORS_DIR",
		&configreader.StringValidation{Default: "/src/aggregators"},
	)
	OperatorTransformersDir = configreader.MustStringFromEnv(
		"CONST_OPERATOR_TRANSFORMERS_DIR",
		&configreader.StringValidation{Default: "/src/transformers"},
	)
	OperatorEstimatorsDir = configreader.MustStringFromEnv(
		"CONST_OPERATOR_ESTIMATORS_DIR",
		&configreader.StringValidation{Default: "/src/estimators"},
	)
)

Functions

func DownloadContext

func DownloadContext(ctxID string, appName string) (*context.Context, error)

func Init

func Init() error

func LatestWorkloadIDKey

func LatestWorkloadIDKey(resourceID string, appName string) string

func New

func New(
	userconf *userconfig.Config,
	files map[string][]byte,
	ignoreCache bool,
) (*context.Context, error)

func StatusKey

func StatusKey(resourceID string, workloadID string, appName string) string

func StatusPrefix

func StatusPrefix(appName string) string

func ValidateInput

func ValidateInput(
	input interface{},
	schema *userconfig.InputSchema,
	validResourceTypes []resource.Type,
	validResources []context.Resource,
	allResources map[string][]userconfig.Resource,
	aggregators context.Aggregators,
	transformers context.Transformers,
) (interface{}, string, error)

func WorkloadSpecKey

func WorkloadSpecKey(workloadID string, appName string) string