cluster

package

v0.2.0 Latest Latest Go to latest Published: Jul 21, 2025 License: Apache-2.0 Imports: 14 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 ¶

type ClusterScanner
- func NewClusterScanner(mskClient ClusterScannerMSKClient, kafkaAdminFactory KafkaAdminFactory, ...) *ClusterScanner
- func (cs *ClusterScanner) Run() error
type ClusterScannerMSKClient
type ClusterScannerOpts
type KafkaAdminFactory

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ClusterScanner ¶

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

func NewClusterScanner ¶

func NewClusterScanner(mskClient ClusterScannerMSKClient, kafkaAdminFactory KafkaAdminFactory, opts ClusterScannerOpts) *ClusterScanner

NewClusterScanner creates a new ClusterScanner instance.

func (*ClusterScanner) Run ¶

func (cs *ClusterScanner) Run() error

type ClusterScannerMSKClient ¶

type ClusterScannerMSKClient interface {
	GetCompatibleKafkaVersions(ctx context.Context, params *kafka.GetCompatibleKafkaVersionsInput, optFns ...func(*kafka.Options)) (*kafka.GetCompatibleKafkaVersionsOutput, error)
	GetClusterPolicy(ctx context.Context, params *kafka.GetClusterPolicyInput, optFns ...func(*kafka.Options)) (*kafka.GetClusterPolicyOutput, error)
	GetBootstrapBrokers(ctx context.Context, params *kafka.GetBootstrapBrokersInput, optFns ...func(*kafka.Options)) (*kafka.GetBootstrapBrokersOutput, error)
	DescribeClusterV2(ctx context.Context, params *kafka.DescribeClusterV2Input, optFns ...func(*kafka.Options)) (*kafka.DescribeClusterV2Output, error)
	ListClientVpcConnections(ctx context.Context, params *kafka.ListClientVpcConnectionsInput, optFns ...func(*kafka.Options)) (*kafka.ListClientVpcConnectionsOutput, error)
	ListClusterOperationsV2(ctx context.Context, params *kafka.ListClusterOperationsV2Input, optFns ...func(*kafka.Options)) (*kafka.ListClusterOperationsV2Output, error)
	ListNodes(ctx context.Context, params *kafka.ListNodesInput, optFns ...func(*kafka.Options)) (*kafka.ListNodesOutput, error)
	ListScramSecrets(ctx context.Context, params *kafka.ListScramSecretsInput, optFns ...func(*kafka.Options)) (*kafka.ListScramSecretsOutput, error)
}

ClusterScannerMSKClient defines the MSK client methods used by ClusterScanner

type ClusterScannerOpts ¶

type ClusterScannerOpts struct {
	Region            string
	ClusterArn        string
	SkipKafka         bool
	AuthType          types.AuthType
	SASLScramUsername string
	SASLScramPassword string
	TLSCACert         string
	TLSClientCert     string
	TLSClientKey      string
}

type KafkaAdminFactory ¶

type KafkaAdminFactory func(brokerAddresses []string, clientBrokerEncryptionInTransit kafkatypes.ClientBroker) (client.KafkaAdmin, error)

KafkaAdminFactory is a function type that creates a KafkaAdmin client

Source Files ¶

View all Source files

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