controllers

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

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

type K8sNetworkPolicyController interface {
	// Run starts the controller
	Run()
	// Stop will stop the controller
	Stop()
	// Subscribe executes the function consumer when the event event is triggered.
	// It returns an error if the event type does not exist.
	// It returns a function to call when you want to stop tracking that event.
	Subscribe(event pcn_types.EventType, consumer func(*networking_v1.NetworkPolicy, *networking_v1.NetworkPolicy)) (func(), error)
	// List gets policies according to a specific query
	List(pQuery, nsQuery *pcn_types.ObjectQuery) ([]networking_v1.NetworkPolicy, error)
}

type NamespaceController interface {
	// Run starts the namespace controller
	Run()
	// Stop will stop the namespace controller
	Stop()
	// Subscribe executes the function consumer when the event event is triggered.
	// It returns an error if the event type does not exist.
	// It returns a function to call when you want to stop tracking that event.
	Subscribe(event pcn_types.EventType, consumer func(*core_v1.Namespace, *core_v1.Namespace)) (func(), error)
	// List gets namespaces according to a specific namespace query
	List(query *pcn_types.ObjectQuery) ([]core_v1.Namespace, error)
}

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

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

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

type PcnNetworkPolicyController interface {
	// Run starts the controller
	Run()
	// Stop will stop the controller
	Stop()
	// Subscribe executes the function consumer when the event event is triggered.
	// It returns an error if the event type does not exist.
	// It returns a function to call when you want to stop tracking that event.
	Subscribe(event pcn_types.EventType, consumer func(*v1beta.PolycubeNetworkPolicy, *v1beta.PolycubeNetworkPolicy)) (func(), error)
	// List gets policies according to a policy query and a namespace query
	List(pQuery, nsQuery *pcn_types.ObjectQuery) ([]v1beta.PolycubeNetworkPolicy, error)
}

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

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

type PodController interface {
	// Run starts the pod controller
	Run()
	// Stop will stop the pod controller
	Stop()
	// Subscribe executes the function consumer when the event event is triggered.
	// It returns an error if the event type does not exist.
	// It returns a function to call when you want to stop tracking that event.
	Subscribe(event pcn_types.EventType, podspec, namespace, node *pcn_types.ObjectQuery, phase core_v1.PodPhase, consumer func(*core_v1.Pod, *core_v1.Pod)) (func(), error)
	// List gets pod according to a specific pod query and a namespace query
	List(queryPod, queryNs, queryNode *pcn_types.ObjectQuery) ([]core_v1.Pod, error)
}

type ServiceController interface {
	// Run starts the service controller
	Run()
	// Stop will stop the service controller
	Stop()
	// Subscribe executes the function consumer when the event event is triggered.
	// It returns an error if the event type does not exist.
	// It returns a function to call when you want to stop tracking that event.
	Subscribe(event pcn_types.EventType, consumer func(*core_v1.Service, *core_v1.Service)) (func(), error)
	// List gets services according to a specific service query and a namespace query
	List(queryServ, queryNs *pcn_types.ObjectQuery) ([]core_v1.Service, error)
}