handlers

type BaseHandler interface {
	// An entry point to the handler. Takes care of initializing / updating the resource.
	Handle(context.Context) error
	// Get the subset unique name for this handler
	GetSubset() string
}

type DeploymentHandler struct {
	client.Client
	// The unique name of the deployment we need to handle
	UniqueName string
	// The unique version of the deployment we need to handle
	UniqueVersion string
	// The name of the subset/consumer as it appears in the Status map
	SubsetName string
	// THe owner of the deployment we need to handle (e.g., to configure watches)
	Owner types.NamespacedName
	// The deployment we should use as base
	BaseDeployment *appsv1.Deployment
	// Is it a Consumer or Subset?
	DeploymentType riskifiedv1alpha1.SubsetOrConsumer
	// A list of labels to be removed from the overriding deployment
	LabelsToRemove []string
	// The version label to use
	VersionLabel string
	// Status handler (to be able to update status)
	StatusManager *model.StatusManager
	// The DynamicEnv matchers
	Matches []riskifiedv1alpha1.IstioMatch
	// An indicator whether the current deployment is updating (as opposed to initializing).
	Updating bool
	// The subset that contains the data of our deployment
	Subset riskifiedv1alpha1.Subset
	Log    logr.Logger
}

type DestinationRuleHandler struct {
	client.Client
	// The unique name of the target DestinationRule
	UniqueName string
	// The unique version of the target DestinationRule
	UniqueVersion string
	// The namespace of the target DestinationRule
	Namespace string
	// The name of the subset/consumer as it appears in the Status map
	SubsetName string
	// The version label
	VersionLabel string
	// The version that gets the default route
	DefaultVersion string
	// Status handler (to be able to update status)
	StatusManager *model.StatusManager
	// The host name of the service that points to the Deployment specified in
	// the subset.
	ServiceHosts []string
	// The name/namespace of the DynamicEnv that launches this DestinationRule
	Owner types.NamespacedName
	Log   logr.Logger
	// contains filtered or unexported fields
}

type IgnoredMissing struct{}

type MRHandler interface {
	BaseHandler
	// Computes the status of all the services which are affected by this handler. It doesn't change
	// anything, just returns the found statuses.
	GetStatus(ctx context.Context) ([]riskifiedv1alpha1.ResourceStatus, error)
	// Apply the provided status to the DynamicEnvironment.
	ApplyStatus(context.Context, []riskifiedv1alpha1.ResourceStatus) error
	/// GetHosts returns non-missing hosts.
	GetHosts() []string
}

type SRHandler interface {
	BaseHandler
	// Computes what the current status of the resource should be. It does not
	// update the status, just computes what the current status should be.
	GetStatus(ctx context.Context) (riskifiedv1alpha1.ResourceStatus, error)
	// Apply the provided status to the DynamicEnvironment.
	ApplyStatus(context.Context, riskifiedv1alpha1.ResourceStatus) error
}

type VirtualServiceHandler struct {
	client.Client
	Identifier    types.NamespacedName
	UniqueName    string
	UniqueVersion string
	Namespace     string
	// The name of the subset/consumer as it appears in the Status map
	SubsetName     string
	RoutePrefix    string
	ServiceHosts   []string
	DefaultVersion string
	Matches        []riskifiedv1alpha1.IstioMatch
	StatusManager  *model.StatusManager
	Log            logr.Logger
	// contains filtered or unexported fields
}