resources

Documentation

Index

• Constants
• Variables
• type BootstrapServerSpec
• type KafkaConnection
• type KafkaConnectionSpec
• type KafkaConnectionStatus
• type KafkaCredentialsSpec
• type RegistryCredentialsSpec
• type ServiceRegistryConnection
• type ServiceRegistryConnectionSpec
• type ServiceRegistryConnectionStatus

Constants

const (
	AKCGroup   = "rhoas.redhat.com"
	AKCVersion = "v1alpha1"
)

const (
	SRCGroup   = "rhoas.redhat.com"
	SRCVersion = "v1alpha1"
)

Variables

var AKCRMeta = metav1.TypeMeta{
	Kind:       "KafkaConnection",
	APIVersion: AKCGroup + "/" + AKCVersion,
}

var AKCResource = schema.GroupVersionResource{
	Group:    AKCGroup,
	Version:  AKCVersion,
	Resource: "kafkaconnections",
}

var AllResources = []schema.GroupVersionResource{
	AKCResource,
	SRCResource,
}

All services defined as resources

var RegistryResourceMeta = metav1.TypeMeta{
	Kind:       "ServiceRegistryConnection",
	APIVersion: SRCGroup + "/" + SRCVersion,
}

var SRCResource = schema.GroupVersionResource{
	Group:    SRCGroup,
	Version:  SRCVersion,
	Resource: "serviceregistryconnections",
}

Types

type BootstrapServerSpec

type BootstrapServerSpec struct {
	// Host full host to  Kafka Service including port
	Host string `json:"host,omitempty"`
}

BootstrapServerSpec contains server host information that can be used to connecto the Kafka

type KafkaConnection

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

	Spec   KafkaConnectionSpec   `json:"spec,omitempty"`
	Status KafkaConnectionStatus `json:"status,omitempty"`
}

KafkaConnection schema

type KafkaConnectionSpec

type KafkaConnectionSpec struct {
	AccessTokenSecretName string               `json:"accessTokenSecretName,omitempty"`
	KafkaID               string               `json:"kafkaId,omitempty"`
	Credentials           KafkaCredentialsSpec `json:"credentials"`
}

KafkaConnectionSpec contains credentials and connection parameters to Kafka

type KafkaConnectionStatus

type KafkaConnectionStatus struct {
	CreatedBy       string              `json:"createdBy,omitempty"`
	Message         string              `json:"message,omitempty"`
	Updated         string              `json:"updated,omitempty"`
	BootstrapServer BootstrapServerSpec `json:"bootstrapServer"`
	// Reference to secret name that needs to be fetched
	SecretName string `json:"serviceAccountSecretName,omitempty"`
}

KafkaConnectionStatus defines the observed state of KafkaConnection

type KafkaCredentialsSpec

type KafkaCredentialsSpec struct {
	// Reference to secret name that needs to be fetched
	SecretName string `json:"serviceAccountSecretName,omitempty"`
}

CredentialsSpec specification containing various formats of credentials

type RegistryCredentialsSpec

type RegistryCredentialsSpec struct {
	// Reference to secret name that needs to be fetched
	SecretName string `json:"serviceAccountSecretName,omitempty"`
}

CredentialsSpec specification containing various formats of credentials

type ServiceRegistryConnection

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

	Spec   ServiceRegistryConnectionSpec   `json:"spec,omitempty"`
	Status ServiceRegistryConnectionStatus `json:"status,omitempty"`
}

ServiceRegistryConnection schema

type ServiceRegistryConnectionSpec

type ServiceRegistryConnectionSpec struct {
	AccessTokenSecretName string                  `json:"accessTokenSecretName,omitempty"`
	ServiceRegistryId     string                  `json:"serviceRegistryId,omitempty"`
	Credentials           RegistryCredentialsSpec `json:"credentials"`
}

ServiceRegistryConnectionSpec contains credentials and connection parameters to Kafka

type ServiceRegistryConnectionStatus

type ServiceRegistryConnectionStatus struct {
	CreatedBy   string `json:"createdBy,omitempty"`
	Message     string `json:"message,omitempty"`
	Updated     string `json:"updated,omitempty"`
	RegistryUrl string `json:"registryUrl"`
	// Reference to secret name that needs to be fetched
	ServiceAccountSecretName string `json:"ServiceAccountSecretName,omitempty"`
}

ServiceRegistryConnectionStatus defines the observed state of ServiceRegistryConnection