utils

package

v0.0.0-test Latest Latest Go to latest Published: Oct 9, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/confluentinc/kcp

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func BindEnvToFlags(cmd *cobra.Command) error
func ConvertKafkaVersion(kafkaVersion *string) string
func GetClientBrokerEncryptionInTransit(cluster kafkatypes.Cluster) kafkatypes.ClientBroker
func GetClusterByArn(state *types.State, clusterArn string) (*types.DiscoveredCluster, error)
func GetKafkaVersion(clusterInfo types.AWSClientInformation) string
func ParseTerraformState(targetEnvFolder string, requiredFields []string) (*types.TerraformState, error)
func StructToMap(s any) (map[string]any, error)
type AWSZone
- func ValidateAWSZones(awsZonesStr string) ([]AWSZone, error)
type TerraformOutputGetter

Constants ¶

View Source

const DefaultClientBrokerEncryptionInTransit = kafkatypes.ClientBrokerTls

DefaultClientBrokerEncryptionInTransit is the fallback encryption type when cluster encryption info is not available

Variables ¶

This section is empty.

Functions ¶

func BindEnvToFlags ¶

func BindEnvToFlags(cmd *cobra.Command) error

sets flag values from corresponding environment variables if flags weren't explicitly provided

func ConvertKafkaVersion ¶ added in v0.2.2

func ConvertKafkaVersion(kafkaVersion *string) string

func GetClientBrokerEncryptionInTransit ¶ added in v0.4.0

func GetClientBrokerEncryptionInTransit(cluster kafkatypes.Cluster) kafkatypes.ClientBroker

GetClientBrokerEncryptionInTransit determines the client broker encryption in transit value for a cluster with proper fallback logic when encryption info is not available

func GetClusterByArn ¶ added in v0.4.0

func GetClusterByArn(state *types.State, clusterArn string) (*types.DiscoveredCluster, error)

func GetKafkaVersion ¶ added in v0.4.0

func GetKafkaVersion(clusterInfo types.AWSClientInformation) string

getKafkaVersion determines the Kafka version based on cluster type

func ParseTerraformState ¶

func ParseTerraformState(targetEnvFolder string, requiredFields []string) (*types.TerraformState, error)

func StructToMap ¶ added in v0.4.0

func StructToMap(s any) (map[string]any, error)

Types ¶

type AWSZone ¶

type AWSZone struct {
	CIDR string
	Zone string
}

AWSZone represents an AWS availability zone with its CIDR block

func ValidateAWSZones ¶

func ValidateAWSZones(awsZonesStr string) ([]AWSZone, error)

ValidateAWSZones validates and parses the AWSZones string into a slice of AWSZone structs Expected format: "us-east-1a:10.0.0.0/24,us-east-1b:10.0.1.0/24"

type TerraformOutputGetter ¶

type TerraformOutputGetter func(types.TerraformOutput) any

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL