v1

Documentation

Index

• Constants
• type Capacity
• type EndpointSpec
• type ManagedKafka
• type ManagedKafkaSpec
• type ManagedKafkaStatus
• type OAuthSpec
• type ServiceAccount
• type TlsSpec
• type VersionsSpec

Constants

const ManagedKafkaBf2DeploymentLabelKey = "bf2.org/deployment"

const ManagedKafkaBf2DeploymentLabelValueReserved = "reserved"

const ManagedKafkaBf2PauseReconciliationAnnotationKey = "managedkafka.bf2.org/pause-reconciliation"

const ManagedKafkaBf2SuspendedLabelKey = "bf2.org/suspended"

Types

type Capacity

type Capacity struct {
	IngressPerSec               string `json:"ingressPerSec"`
	EgressPerSec                string `json:"egressPerSec"`
	TotalMaxConnections         int    `json:"totalMaxConnections"`
	MaxDataRetentionSize        string `json:"maxDataRetentionSize"`
	MaxPartitions               int    `json:"maxPartitions"`
	MaxDataRetentionPeriod      string `json:"maxDataRetentionPeriod"`
	MaxConnectionAttemptsPerSec int    `json:"maxConnectionAttemptsPerSec"`
}

type EndpointSpec

type EndpointSpec struct {
	BootstrapServerHost string   `json:"bootstrapServerHost"`
	Tls                 *TlsSpec `json:"tls,omitempty"`
}

type ManagedKafka

type ManagedKafka struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Id     string             `json:"id,omitempty"`
	Spec   ManagedKafkaSpec   `json:"spec,omitempty"`
	Status ManagedKafkaStatus `json:"status,omitempty"`
}

type ManagedKafkaSpec

type ManagedKafkaSpec struct {
	Capacity        Capacity         `json:"capacity"`
	OAuth           OAuthSpec        `json:"oauth"`
	Endpoint        EndpointSpec     `json:"endpoint"`
	Versions        VersionsSpec     `json:"versions"`
	Deleted         bool             `json:"deleted"`
	Owners          []string         `json:"owners"`
	ServiceAccounts []ServiceAccount `json:"service_accounts"`
}

type ManagedKafkaStatus

type ManagedKafkaStatus struct {
	Conditions []metav1.Condition `json:"conditions"`
	Capacity   Capacity           `json:"capacity"`
	Versions   VersionsSpec       `json:"versions"`
}

type OAuthSpec

type OAuthSpec struct {
	ClientId               string  `json:"clientId"`
	ClientSecret           string  `json:"clientSecret"`
	TokenEndpointURI       string  `json:"tokenEndpointURI"`
	JwksEndpointURI        string  `json:"jwksEndpointURI"`
	ValidIssuerEndpointURI string  `json:"validIssuerEndpointURI"`
	UserNameClaim          string  `json:"userNameClaim"`
	TlsTrustedCertificate  *string `json:"tlsTrustedCertificate,omitempty"`
	CustomClaimCheck       string  `json:"customClaimCheck"`
	FallBackUserNameClaim  string  `json:"fallbackUserNameClaim"`
	MaximumSessionLifetime int64   `json:"maximumSessionLifetime"`
}

Spec

type ServiceAccount

type ServiceAccount struct {
	Name      string `json:"name"`
	Principal string `json:"principal"`
	Password  string `json:"password"`
}

type TlsSpec

type TlsSpec struct {
	Cert string `json:"cert"`
	Key  string `json:"key"`
}

type VersionsSpec

type VersionsSpec struct {
	Kafka    string `json:"kafka"`
	Strimzi  string `json:"strimzi"`
	KafkaIBP string `json:"kafkaIbp"`
}