Versions in this module Expand all Collapse all v0 v0.1.15 Feb 5, 2023 v0.1.14 Feb 6, 2023 Changes in this version + const AllIntentsRemovedAnnotation + const EndpointsPodNamesIndexField + const IngressServiceNamesIndexField + const MaxNamespaceLength + const MaxOtterizeNameLength + const NetworkPoliciesByIngressNameIndexField + const NetworkPolicyFinalizerName + const OtterizeAccessLabelKey + const OtterizeAccessLabelPrefix + const OtterizeClientLabelKey + const OtterizeCreatedForIngressAnnotation + const OtterizeCreatedForServiceAnnotation + const OtterizeNamespaceLabelKey + const OtterizeNetworkPolicy + const OtterizeNetworkPolicyExternalTraffic + const OtterizeNetworkPolicyNameTemplate + const OtterizeServerLabelKey + const OtterizeTargetServerIndexField + const ResourcePatternTypeLiteral + const ResourcePatternTypePrefix + var AddToScheme = SchemeBuilder.AddToScheme + var GroupVersion = schema.GroupVersion + var SchemeBuilder = &scheme.Builder + func GetFormattedOtterizeIdentity(name, ns string) string + func GetOtterizeLabelsFromPod(pod *v1.Pod) map[string]string + func HasOtterizeServerLabel(pod *v1.Pod, labelValue string) bool + func IsMissingOtterizeAccessLabels(pod *v1.Pod, otterizeAccessLabels map[string]string) bool + func UpdateOtterizeAccessLabels(pod *v1.Pod, otterizeAccessLabels map[string]string) *v1.Pod + type ClientIntents struct + Spec *IntentsSpec + Status *IntentsStatus + func (in *ClientIntents) BuildPodLabelSelector() (labels.Selector, error) + func (in *ClientIntents) DeepCopy() *ClientIntents + func (in *ClientIntents) DeepCopyInto(out *ClientIntents) + func (in *ClientIntents) DeepCopyObject() runtime.Object + func (in *ClientIntents) GetCallsList() []Intent + func (in *ClientIntents) GetIntentsLabelMapping(requestNamespace string) map[string]string + func (in *ClientIntents) GetServiceName() string + func (in *ClientIntents) HasKafkaTypeInCallList() bool + type ClientIntentsList struct + Items []ClientIntents + func (in *ClientIntentsList) DeepCopy() *ClientIntentsList + func (in *ClientIntentsList) DeepCopyInto(out *ClientIntentsList) + func (in *ClientIntentsList) DeepCopyObject() runtime.Object + func (in *ClientIntentsList) FormatAsOtterizeIntents() ([]*graphqlclient.IntentInput, error) + type HTTPMethod string + const HTTPMethodConnect + const HTTPMethodDelete + const HTTPMethodGet + const HTTPMethodOptions + const HTTPMethodPatch + const HTTPMethodPost + const HTTPMethodPut + const HTTPMethodTrace + type HTTPResource struct + Methods []HTTPMethod + Path string + func (in *HTTPResource) DeepCopy() *HTTPResource + func (in *HTTPResource) DeepCopyInto(out *HTTPResource) + type Intent struct + HTTPResources []HTTPResource + Name string + Topics []KafkaTopic + Type IntentType + func (in *Intent) ConvertToCloudFormat(resourceNamespace string, clientName string) graphqlclient.IntentInput + func (in *Intent) DeepCopy() *Intent + func (in *Intent) DeepCopyInto(out *Intent) + func (in *Intent) GetServerName() string + func (in *Intent) GetServerNamespace(intentsObjNamespace string) string + type IntentType string + const IntentTypeHTTP + const IntentTypeKafka + type IntentsSpec struct + Calls []Intent + Service Service + func (in *IntentsSpec) DeepCopy() *IntentsSpec + func (in *IntentsSpec) DeepCopyInto(out *IntentsSpec) + type IntentsStatus struct + func (in *IntentsStatus) DeepCopy() *IntentsStatus + func (in *IntentsStatus) DeepCopyInto(out *IntentsStatus) + type KafkaOperation string + const KafkaOperationAll + const KafkaOperationAlter + const KafkaOperationAlterConfigs + const KafkaOperationClusterAction + const KafkaOperationConsume + const KafkaOperationCreate + const KafkaOperationDelete + const KafkaOperationDescribe + const KafkaOperationDescribeConfigs + const KafkaOperationIdempotentWrite + const KafkaOperationProduce + type KafkaServerConfig struct + Spec KafkaServerConfigSpec + Status KafkaServerConfigStatus + func (in *KafkaServerConfig) DeepCopy() *KafkaServerConfig + func (in *KafkaServerConfig) DeepCopyInto(out *KafkaServerConfig) + func (in *KafkaServerConfig) DeepCopyObject() runtime.Object + type KafkaServerConfigList struct + Items []KafkaServerConfig + func (in *KafkaServerConfigList) DeepCopy() *KafkaServerConfigList + func (in *KafkaServerConfigList) DeepCopyInto(out *KafkaServerConfigList) + func (in *KafkaServerConfigList) DeepCopyObject() runtime.Object + type KafkaServerConfigSpec struct + Addr string + NoAutoCreateIntentsForOperator bool + Service Service + TLS TLSSource + Topics []TopicConfig + func (in *KafkaServerConfigSpec) DeepCopy() *KafkaServerConfigSpec + func (in *KafkaServerConfigSpec) DeepCopyInto(out *KafkaServerConfigSpec) + type KafkaServerConfigStatus struct + func (in *KafkaServerConfigStatus) DeepCopy() *KafkaServerConfigStatus + func (in *KafkaServerConfigStatus) DeepCopyInto(out *KafkaServerConfigStatus) + type KafkaTopic struct + Name string + Operations []KafkaOperation + func (in *KafkaTopic) DeepCopy() *KafkaTopic + func (in *KafkaTopic) DeepCopyInto(out *KafkaTopic) + type ResourcePatternType string + type Service struct + Name string + func (in *Service) DeepCopy() *Service + func (in *Service) DeepCopyInto(out *Service) + type TLSSource struct + CertFile string + KeyFile string + RootCAFile string + func (in *TLSSource) DeepCopy() *TLSSource + func (in *TLSSource) DeepCopyInto(out *TLSSource) + type TopicConfig struct + ClientIdentityRequired bool + IntentsRequired bool + Pattern ResourcePatternType + Topic string + func (in *TopicConfig) DeepCopy() *TopicConfig + func (in *TopicConfig) DeepCopyInto(out *TopicConfig)
Go to main page