networkpolicy

Documentation

Index

• Variables
• type Controller
  • func NewController(cfg *rest.Config, cs kubernetes.Interface, namespace string) (*Controller, error)
  • func (c *Controller) Run() error
• type LatestReleaser
  • func (r *LatestReleaser) ExternalRelease(releases []v1alpha1.Release) (*v1alpha1.Release, error)

Variables

var (
	// NetworkPolicyResource describes the CRD networkuration for the
	// NetworkPolicy CRD.
	NetworkPolicyResource = kubekit.CustomResource{
		Name:    "networkpolicy",
		Plural:  "networkpolicies",
		Group:   v1alpha1.GroupName,
		Version: v1alpha1.Version,
		Scope:   v1beta1.NamespaceScoped,

		Aliases:    []string{},
		Object:     &v1alpha1.NetworkPolicy{},
		Validation: v1alpha1.NetworkPolicyValidationSchema,
	}

	// VersioningPolicyResource describes the CRD configuration for the
	// VersioningPolicy CRD.
	VersioningPolicyResource = kubekit.CustomResource{
		Name:    "versioningpolicy",
		Plural:  "versioningpolicies",
		Group:   v1alpha1.GroupName,
		Version: v1alpha1.Version,
		Scope:   v1beta1.NamespaceScoped,
		Aliases: []string{"vp"},
		Object:  &v1alpha1.VersioningPolicy{},
		Validation: &v1beta1.CustomResourceValidation{
			OpenAPIV3Schema: &v1beta1.JSONSchemaProps{
				Properties: map[string]v1beta1.JSONSchemaProps{
					"spec": v1alpha1.VersioningPolicyValidationSchema,
				},
			},
		},
	}
)

Types

type Controller

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

Controller represents the MicroserviceController. This controller takes care of creating, updating and deleting lower level Kubernetese components that are associated with a specific Microservice.

func NewController

func NewController(cfg *rest.Config, cs kubernetes.Interface, namespace string) (*Controller, error)

NewController returns a new NetworkPolicy Controller.

func (*Controller) Run

func (c *Controller) Run() error

Run runs the Controller in the background and sets up watchers to take action when the desired state is altered.

type LatestReleaser

type LatestReleaser struct{}

LatestReleaser is able to select a release based on the releasetime date.

func (*LatestReleaser) ExternalRelease

func (r *LatestReleaser) ExternalRelease(releases []v1alpha1.Release) (*v1alpha1.Release, error)

ExternalRelease goes over all releases and releases the latest release based on the releaseTime timestamp.