managedkafka

package
v1.129.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 26, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AccessConfig_FromProto 

func AccessConfig_FromProto(mapCtx *direct.MapContext, in *pb.AccessConfig) *krm.AccessConfig

func AccessConfig_ToProto 

func AccessConfig_ToProto(mapCtx *direct.MapContext, in *krm.AccessConfig) *pb.AccessConfig

func CapacityConfig_FromProto 

func CapacityConfig_FromProto(mapCtx *direct.MapContext, in *pb.CapacityConfig) *krm.CapacityConfig

func CapacityConfig_ToProto 

func CapacityConfig_ToProto(mapCtx *direct.MapContext, in *krm.CapacityConfig) *pb.CapacityConfig

func GcpConfig_FromProto 

func GcpConfig_FromProto(mapCtx *direct.MapContext, in *pb.GcpConfig) *krm.GcpConfig

func GcpConfig_ToProto 

func GcpConfig_ToProto(mapCtx *direct.MapContext, in *krm.GcpConfig) *pb.GcpConfig

func ManagedKafkaClusterObservedState_FromProto 

func ManagedKafkaClusterObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Cluster) *krm.ManagedKafkaClusterObservedState

func ManagedKafkaClusterObservedState_ToProto 

func ManagedKafkaClusterObservedState_ToProto(mapCtx *direct.MapContext, in *krm.ManagedKafkaClusterObservedState) *pb.Cluster

func ManagedKafkaClusterSpec_FromProto 

func ManagedKafkaClusterSpec_FromProto(mapCtx *direct.MapContext, in *pb.Cluster) *krm.ManagedKafkaClusterSpec

func ManagedKafkaClusterSpec_ToProto 

func ManagedKafkaClusterSpec_ToProto(mapCtx *direct.MapContext, in *krm.ManagedKafkaClusterSpec) *pb.Cluster

func ManagedKafkaTopicSpec_FromProto added in v1.129.2 

func ManagedKafkaTopicSpec_FromProto(mapCtx *direct.MapContext, in *pb.Topic) *krmv1alpha1.ManagedKafkaTopicSpec

func ManagedKafkaTopicSpec_ToProto added in v1.129.2 

func ManagedKafkaTopicSpec_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.ManagedKafkaTopicSpec) *pb.Topic

func NetworkConfig_FromProto 

func NetworkConfig_FromProto(mapCtx *direct.MapContext, in *pb.NetworkConfig) *krm.NetworkConfig

func NetworkConfig_ToProto 

func NetworkConfig_ToProto(mapCtx *direct.MapContext, in *krm.NetworkConfig) *pb.NetworkConfig

func NewClusterModel 

func NewClusterModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func NewTopicModel added in v1.129.2 

func NewTopicModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func RebalanceConfig_FromProto 

func RebalanceConfig_FromProto(mapCtx *direct.MapContext, in *pb.RebalanceConfig) *krm.RebalanceConfig

func RebalanceConfig_ToProto 

func RebalanceConfig_ToProto(mapCtx *direct.MapContext, in *krm.RebalanceConfig) *pb.RebalanceConfig

Types

type ClusterAdapter 

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

func (*ClusterAdapter) Create 

func (a *ClusterAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error

Create creates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

func (*ClusterAdapter) Delete 

func (a *ClusterAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)

Delete the resource from GCP service when the corresponding Config Connector resource is deleted.

func (*ClusterAdapter) Export 

func (a *ClusterAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)

Export maps the GCP object to a Config Connector resource `spec`.

func (*ClusterAdapter) Find 

func (a *ClusterAdapter) Find(ctx context.Context) (bool, error)

Find retrieves the GCP resource. Return true means the object is found. This triggers Adapter `Update` call. Return false means the object is not found. This triggers Adapter `Create` call. Return a non-nil error requeues the requests.

func (*ClusterAdapter) Update 

func (a *ClusterAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error

Update updates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

type TopicAdapter added in v1.129.2 

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

func (*TopicAdapter) Create added in v1.129.2 

func (a *TopicAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error

Create creates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

func (*TopicAdapter) Delete added in v1.129.2 

func (a *TopicAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)

Delete the resource from GCP service when the corresponding Config Connector resource is deleted.

func (*TopicAdapter) Export added in v1.129.2 

func (a *TopicAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)

Export maps the GCP object to a Config Connector resource `spec`.

func (*TopicAdapter) Find added in v1.129.2 

func (a *TopicAdapter) Find(ctx context.Context) (bool, error)

Find retrieves the GCP resource. Return true means the object is found. This triggers Adapter `Update` call. Return false means the object is not found. This triggers Adapter `Create` call. Return a non-nil error requeues the requests.

func (*TopicAdapter) Update added in v1.129.2 

func (a *TopicAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error

Update updates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.