v1

package

v0.0.11 Latest Latest Go to latest Published: Feb 22, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/qpoint-io/kubernetes-qtap-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func EnsureAssetsInNamespace(config *Config) error
func MutateCaInjection(pod *corev1.Pod, config *Config) error
func MutateEgress(pod *corev1.Pod, config *Config) error
func MutateInjection(pod *corev1.Pod, config *Config) error
type Config
- func (c *Config) GetAnnotation(key string) string
- func (c *Config) Init(pod *corev1.Pod) error
type EgressType
type Registration
- func FetchRegistration(token string) (*Registration, error)
type RegistrationResponse
type Webhook
- func (w *Webhook) Handle(ctx context.Context, req admission.Request) admission.Response

Constants ¶

View Source

const DEFAULT_ENDPOINT = "https://api.qpoint.io"

View Source

const INIT_IMAGE = "us-docker.pkg.dev/qpoint-edge/public/kubernetes-qtap-init"

View Source

const INJECT_ANNOTATIONS_CONFIGMAP = "qtap-operator-inject-pod-annotations-configmap"

View Source

const NAMESPACE_EGRESS_LABEL = "qpoint.io/egress"

View Source

const POD_EGRESS_LABEL = "qpoint.io/egress"

View Source

const QPOINT_ROOT_CA = "qpoint-qtap-ca.crt" // this is the Qpoint CA

View Source

const QTAP_BUNDLE = "qtap-ca-bundle.crt" // final bundle includes all CAs (including Qpoint's CA)

View Source

const QTAP_IMAGE = "us-docker.pkg.dev/qpoint-edge/public/qtap"

View Source

const SERVICE_ANNOTATIONS_CONFIGMAP = "qtap-operator-service-pod-annotations-configmap"

Variables ¶

This section is empty.

Functions ¶

func EnsureAssetsInNamespace ¶

func EnsureAssetsInNamespace(config *Config) error

func MutateCaInjection ¶

func MutateCaInjection(pod *corev1.Pod, config *Config) error

func MutateEgress ¶

func MutateEgress(pod *corev1.Pod, config *Config) error

func MutateInjection ¶ added in v0.0.5

func MutateInjection(pod *corev1.Pod, config *Config) error

Types ¶

type Config ¶

type Config struct {
	EgressType        EgressType
	InjectCa          bool
	Namespace         string
	OperatorNamespace string
	Client            client.Client
	Ctx               context.Context
	// contains filtered or unexported fields
}

func (*Config) GetAnnotation ¶ added in v0.0.5

func (c *Config) GetAnnotation(key string) string

func (*Config) Init ¶

func (c *Config) Init(pod *corev1.Pod) error

type EgressType ¶ added in v0.0.5

type EgressType string

const (
	EgressType_UNDEFINED EgressType = "undefined"
	EgressType_DISABLE   EgressType = "disable"
	EgressType_SERVICE   EgressType = "service"
	EgressType_INJECT    EgressType = "inject"
)

type Registration ¶ added in v0.0.5

type Registration struct {
	Ca string `json:"ca"`
}

func FetchRegistration ¶ added in v0.0.5

func FetchRegistration(token string) (*Registration, error)

type RegistrationResponse ¶ added in v0.0.5

type RegistrationResponse struct {
	Registration Registration `json:"registration"`
}

type Webhook ¶

type Webhook struct {
	Namespace   string
	ApiClient   client.Client
	Decoder     *admission.Decoder
	Development bool
}

func (*Webhook) Handle ¶

func (w *Webhook) Handle(ctx context.Context, req admission.Request) admission.Response

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL