Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
MaxActionsInProgress int
}
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)
Click to show internal directories.
Click to hide internal directories.