actions

Documentation

Index

• type ActionHandler
• type Config
• type Service
  • func NewService(log logrus.FieldLogger, cfg Config, k8sVersion string, ...) Service

Types

type ActionHandler

type ActionHandler interface {
	Handle(ctx context.Context, action *castai.ClusterAction) error
}

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 Service

type Service interface {
	Run(ctx context.Context)
}

func NewService

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