osk

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 OSKSource struct {
	// contains filtered or unexported fields
}

OSKSource implements the Source interface for Open Source Kafka clusters

func NewOSKSource() *OSKSource

NewOSKSource creates a new OSK source

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

GetClusters returns the list of clusters from credentials

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

LoadCredentials loads OSK credentials from a file

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

Scan performs scanning of all OSK clusters

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

Type returns the source type