actions

Documentation

Index

• type ActionHandler
• type Config
• type Service
  • func NewService(log logrus.FieldLogger, cfg Config, clientset *kubernetes.Clientset, ...) Service

Types

type ActionHandler

type ActionHandler interface {
	Handle(ctx context.Context, data interface{}) 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
}

type Service

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

func NewService

func NewService(
	log logrus.FieldLogger,
	cfg Config,
	clientset *kubernetes.Clientset,
	castaiClient castai.Client,
) Service