Versions in this module Expand all Collapse all v1 v1.129.2 Feb 26, 2025 Changes in this version + func ManagedKafkaTopicSpec_FromProto(mapCtx *direct.MapContext, in *pb.Topic) *krmv1alpha1.ManagedKafkaTopicSpec + func ManagedKafkaTopicSpec_ToProto(mapCtx *direct.MapContext, in *krmv1alpha1.ManagedKafkaTopicSpec) *pb.Topic + func NewTopicModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error) + type TopicAdapter struct + func (a *TopicAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error + func (a *TopicAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error) + func (a *TopicAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error) + func (a *TopicAdapter) Find(ctx context.Context) (bool, error) + func (a *TopicAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error v1.128.0 Jan 31, 2025 Changes in this version + func AccessConfig_FromProto(mapCtx *direct.MapContext, in *pb.AccessConfig) *krm.AccessConfig + func AccessConfig_ToProto(mapCtx *direct.MapContext, in *krm.AccessConfig) *pb.AccessConfig + func CapacityConfig_FromProto(mapCtx *direct.MapContext, in *pb.CapacityConfig) *krm.CapacityConfig + func CapacityConfig_ToProto(mapCtx *direct.MapContext, in *krm.CapacityConfig) *pb.CapacityConfig + func GcpConfig_FromProto(mapCtx *direct.MapContext, in *pb.GcpConfig) *krm.GcpConfig + func GcpConfig_ToProto(mapCtx *direct.MapContext, in *krm.GcpConfig) *pb.GcpConfig + func ManagedKafkaClusterObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Cluster) *krm.ManagedKafkaClusterObservedState + func ManagedKafkaClusterObservedState_ToProto(mapCtx *direct.MapContext, in *krm.ManagedKafkaClusterObservedState) *pb.Cluster + func ManagedKafkaClusterSpec_FromProto(mapCtx *direct.MapContext, in *pb.Cluster) *krm.ManagedKafkaClusterSpec + func ManagedKafkaClusterSpec_ToProto(mapCtx *direct.MapContext, in *krm.ManagedKafkaClusterSpec) *pb.Cluster + func NetworkConfig_FromProto(mapCtx *direct.MapContext, in *pb.NetworkConfig) *krm.NetworkConfig + func NetworkConfig_ToProto(mapCtx *direct.MapContext, in *krm.NetworkConfig) *pb.NetworkConfig + func NewClusterModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error) + func RebalanceConfig_FromProto(mapCtx *direct.MapContext, in *pb.RebalanceConfig) *krm.RebalanceConfig + func RebalanceConfig_ToProto(mapCtx *direct.MapContext, in *krm.RebalanceConfig) *pb.RebalanceConfig + type ClusterAdapter struct + func (a *ClusterAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error + func (a *ClusterAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error) + func (a *ClusterAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error) + func (a *ClusterAdapter) Find(ctx context.Context) (bool, error) + func (a *ClusterAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error
Go to main page