app

Documentation

Index

• Constants
• Variables
• func ReadConfig(filename string) (*Agent.Config, error)
• type LibType
• type ScheduleJob
  • func NewScheduleJob(libPath string, configPath string, libType LibType, daemon bool, ...) *ScheduleJob
  • func (s *ScheduleJob) Run()

Constants

const (
	PROBE_TYPE_READINESS = "readiness"
	PROBE_TYPE_LIVENESS  = "liveness"
)

Variables

var (
	EnablePreloaderCmd = &cobra.Command{
		Use:   "enable",
		Short: "Enable preloader",
		Long:  "",
		Run: func(cmd *cobra.Command, args []string) {
			enablePreloader()
		},
	}
)

var (
	LoadFutureCmd = &cobra.Command{
		Use:   "loadfuture",
		Short: "Load future node/container metrics",
		Long:  "",
		Run: func(cmd *cobra.Command, args []string) {
			startLoadFuture()
		},
	}
)

var (
	ProbeCmd = &cobra.Command{
		Use:   "probe",
		Short: "probe federatorai agent",
		Long:  "",
		Run: func(cmd *cobra.Command, args []string) {
			startProbing()
		},
	}
)

var RootCmd = &cobra.Command{
	Use:   "transmitter",
	Short: "federatorai agent",
	Long:  "",
}

var (
	RunCmd = &cobra.Command{
		Use:   "run",
		Short: "start alameda recommender",
		Long:  "",
		Run: func(cmd *cobra.Command, args []string) {
			startAgent()
		},
	}
)

Functions

func ReadConfig

func ReadConfig(filename string) (*Agent.Config, error)

Types

type LibType

type LibType int

const (
	LibTypeInput  LibType = 0
	LibTypeOutput LibType = 1
)

type ScheduleJob

type ScheduleJob struct {
	LibPath          string
	ConfigPath       string
	LibType          LibType
	HealthCheckRetry int
	// contains filtered or unexported fields
}

func NewScheduleJob

func NewScheduleJob(libPath string, configPath string, libType LibType, daemon bool, healthCheckRetry int) *ScheduleJob

func (*ScheduleJob) Run

func (s *ScheduleJob) Run()