Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AuthenticationSummarizer ¶
type AuthenticationSummarizer interface {
SummariseAuthentication(cluster kafkatypes.Cluster) string
}
AuthenticationSummarizer defines the interface for summarizing cluster authentication
type DefaultAuthenticationSummarizer ¶
type DefaultAuthenticationSummarizer struct{}
DefaultAuthenticationSummarizer provides the default implementation
func (*DefaultAuthenticationSummarizer) SummariseAuthentication ¶
func (d *DefaultAuthenticationSummarizer) SummariseAuthentication(cluster kafkatypes.Cluster) string
type RegionScanner ¶
type RegionScanner struct {
// contains filtered or unexported fields
}
func NewRegionScanner ¶
func NewRegionScanner(mskClient RegionScannerMSKClient, opts ScanRegionOpts) *RegionScanner
func NewRegionScannerWithAuthSummarizer ¶
func NewRegionScannerWithAuthSummarizer(region string, mskClient RegionScannerMSKClient, authSummarizer AuthenticationSummarizer) *RegionScanner
NewRegionScannerWithAuthSummarizer creates a RegionScanner with a custom AuthenticationSummarizer (useful for testing)
func (*RegionScanner) Run ¶
func (rs *RegionScanner) Run() error
type RegionScannerMSKClient ¶
type RegionScannerMSKClient interface {
ListClustersV2(ctx context.Context, params *kafka.ListClustersV2Input, optFns ...func(*kafka.Options)) (*kafka.ListClustersV2Output, error)
ListVpcConnections(ctx context.Context, params *kafka.ListVpcConnectionsInput, optFns ...func(*kafka.Options)) (*kafka.ListVpcConnectionsOutput, error)
ListConfigurations(ctx context.Context, params *kafka.ListConfigurationsInput, optFns ...func(*kafka.Options)) (*kafka.ListConfigurationsOutput, error)
DescribeConfigurationRevision(ctx context.Context, params *kafka.DescribeConfigurationRevisionInput, optFns ...func(*kafka.Options)) (*kafka.DescribeConfigurationRevisionOutput, error)
ListKafkaVersions(ctx context.Context, params *kafka.ListKafkaVersionsInput, optFns ...func(*kafka.Options)) (*kafka.ListKafkaVersionsOutput, error)
ListReplicators(ctx context.Context, params *kafka.ListReplicatorsInput, optFns ...func(*kafka.Options)) (*kafka.ListReplicatorsOutput, error)
DescribeReplicator(ctx context.Context, params *kafka.DescribeReplicatorInput, optFns ...func(*kafka.Options)) (*kafka.DescribeReplicatorOutput, error)
}
RegionScannerMSKClient defines the MSK client methods used by RegionScanner
type ScanRegionOpts ¶
type ScanRegionOpts struct {
Region string
}
Source Files
Click to show internal directories.
Click to hide internal directories.