state

Documentation

Index

• type CastaiConfig
• type CastaiController
  • func NewCastaiController(log *logging.Logger, cfg CastaiConfig, appJSONConfig []byte, ...) *CastaiController
  • func (c *CastaiController) Enabled() bool
  • func (c *CastaiController) Run(ctx context.Context) error
• type ContainerStatusStats
• type FlowsFilter
• type JobsCleanupConfig
• type JobsCleanupController
  • func NewJobsCleanupController(log *logging.Logger, clientset kubernetes.Interface, cfg JobsCleanupConfig) *JobsCleanupController
  • func (c *JobsCleanupController) Run(ctx context.Context) error
• type Namespace
• type PodPhaseStats
• type PodsStats
• type TrafficType
• type TrafficTypeStats

Types

type CastaiConfig

type CastaiConfig struct {
	RemoteConfigSyncDuration time.Duration `validate:"required" json:"remoteConfigSyncDuration"`
}

type CastaiController

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

func NewCastaiController

func NewCastaiController(log *logging.Logger, cfg CastaiConfig, appJSONConfig []byte, kubeClient *kube.Client, castaiClient *castai.Client) *CastaiController

func (*CastaiController) Enabled

func (c *CastaiController) Enabled() bool

func (*CastaiController) Run

func (c *CastaiController) Run(ctx context.Context) error

type ContainerStatusStats

type ContainerStatusStats struct {
	Value string `json:"value"`
	Text  string `json:"text"`
	Count int    `json:"count"`
}

type FlowsFilter

type FlowsFilter struct {
	Namespaces []string `json:"namespaces"`
	IDs        []string `json:"ids"`
	// If set to true filtering by IDs will try to filter by WorkloadKey or ID.
	TryWorkloadIDs bool `json:"-"`
}

type JobsCleanupConfig

type JobsCleanupConfig struct {
	CleanupInterval time.Duration `validate:"required" json:"cleanupInterval"`
	CleanupJobAge   time.Duration `validate:"required" json:"cleanupJobAge"`
	Namespace       string        `validate:"required" json:"namespace"`
}

type JobsCleanupController

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

func NewJobsCleanupController

func NewJobsCleanupController(log *logging.Logger, clientset kubernetes.Interface, cfg JobsCleanupConfig) *JobsCleanupController

func (*JobsCleanupController) Run

func (c *JobsCleanupController) Run(ctx context.Context) error

type Namespace

type Namespace struct {
	Name string `json:"name"`
}

type PodPhaseStats

type PodPhaseStats struct {
	Value string `json:"value"`
	Text  string `json:"text"`
	Count int    `json:"count"`
}

type PodsStats

type PodsStats struct {
	ContainerStatuses []ContainerStatusStats `json:"containerStatuses"`
	Phases            []PodPhaseStats        `json:"phases"`
	TrafficTypes      []TrafficTypeStats     `json:"trafficTypes"`
}

type TrafficType

type TrafficType string

const (
	TrafficTypeInternet     TrafficType = "internet"
	TrafficTypePrivate      TrafficType = "private"
	TrafficTypeControlPlane TrafficType = "control_plane"
	TrafficTypeCrossZone    TrafficType = "cross_zone"
	TrafficTypeWorkload     TrafficType = "workload"
	TrafficTypeService      TrafficType = "service"
)

type TrafficTypeStats

type TrafficTypeStats struct {
	Value string `json:"value"`
	Text  string `json:"text"`
	Count int    `json:"count"`
}