msk

package

v0.8.2 Latest Latest Go to latest Published: Jun 10, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

MSKSource implements the Source interface for AWS MSK clusters

func NewMSKSource() *MSKSource

NewMSKSource creates a new MSK source

func (s *MSKSource) GetClusters() []sources.ClusterIdentifier

GetClusters returns the list of MSK clusters from credentials

func (s *MSKSource) LoadCredentials(credentialsPath string) error

LoadCredentials loads MSK credentials from a file

func (s *MSKSource) Scan(ctx context.Context, opts sources.ScanOptions) (*sources.ScanResult, error)

Scan performs scanning of all MSK clusters. opts.State must be non-nil — it contains broker addresses populated by kcp discover.

func (s *MSKSource) Type() types.SourceType

Type returns the source type