sources

type ClusterIdentifier struct {
	Name             string   // Human-readable name (MSK: cluster name, OSK: user ID)
	UniqueID         string   // Unique identifier (MSK: ARN, OSK: user ID)
	BootstrapServers []string // Bootstrap server addresses
}

type ClusterScanResult struct {
	Identifier         ClusterIdentifier
	KafkaAdminInfo     *types.KafkaAdminClientInformation
	SourceSpecificData interface{} // MSK: AWSClientInformation, OSK: OSKClusterMetadata
}

type ScanOptions struct {
	SkipTopics bool
	SkipACLs   bool
	// State is the existing kcp state. Required for MSK scanning (broker addresses
	// come from prior kcp discover output). Ignored by OSK.
	State *types.State
}

type ScanResult struct {
	SourceType types.SourceType
	Clusters   []ClusterScanResult
}

type Source interface {
	// Type returns the source type (msk or osk)
	Type() types.SourceType

	// LoadCredentials loads authentication credentials from a file
	LoadCredentials(credentialsPath string) error

	// Scan performs discovery/scanning of the source clusters
	Scan(ctx context.Context, opts ScanOptions) (*ScanResult, error)

	// GetClusters returns the list of clusters available to scan
	GetClusters() []ClusterIdentifier
}