controller

Documentation

Index

• type Config
• type Controller
  • func NewService(log logrus.FieldLogger, cfg Config, k8sVersion string, ...) *Controller
  • func (s *Controller) Close() error
  • func (s *Controller) Run(ctx context.Context)

Types

type Config

type Config struct {
	PollWaitInterval time.Duration // How long to wait unit next long polling request.
	PollTimeout      time.Duration // hard timeout. Normally server should return empty result before this timeout.
	AckTimeout       time.Duration // How long to wait for ack request to complete.
	AckRetriesCount  int           // Ack retry count.
	AckRetryWait     time.Duration // How long to wait before next ack retry request.
	ClusterID        string
	Version          string
	Namespace        string
}

type Controller

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

func NewService

func NewService(
	log logrus.FieldLogger,
	cfg Config,
	k8sVersion string,
	clientset *kubernetes.Clientset,
	dynamicClient dynamic.Interface,
	castaiClient castai.CastAIClient,
	helmClient helm.Client,
	healthCheck *health.HealthzProvider,
) *Controller

func (*Controller) Close

func (s *Controller) Close() error

func (*Controller) Run

func (s *Controller) Run(ctx context.Context)