msk

package
v0.6.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 11, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MSKService 

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

func NewMSKService 

func NewMSKService(mskClient *client.RateLimitedMSKClient) *MSKService

func (*MSKService) DescribeClusterV2 added in v0.2.1 

func (ms *MSKService) DescribeClusterV2(ctx context.Context, clusterArn string) (*kafka.DescribeClusterV2Output, error)

func (*MSKService) DescribeTopic added in v0.5.2 

func (ms *MSKService) DescribeTopic(ctx context.Context, clusterArn string, topicName string) (*kafka.DescribeTopicOutput, error)

func (*MSKService) GetBootstrapBrokers added in v0.2.1 

func (ms *MSKService) GetBootstrapBrokers(ctx context.Context, clusterArn string) (*kafka.GetBootstrapBrokersOutput, error)

func (*MSKService) GetClusterPolicy added in v0.2.1 

func (ms *MSKService) GetClusterPolicy(ctx context.Context, clusterArn string) (*kafka.GetClusterPolicyOutput, error)

func (*MSKService) GetCompatibleKafkaVersions added in v0.2.1 

func (ms *MSKService) GetCompatibleKafkaVersions(ctx context.Context, clusterArn string) (*kafka.GetCompatibleKafkaVersionsOutput, error)

func (*MSKService) GetConfigurations added in v0.4.0 

func (ms *MSKService) GetConfigurations(ctx context.Context, maxResults int32) ([]kafka.DescribeConfigurationRevisionOutput, error)

func (*MSKService) GetTopicsWithConfigs added in v0.5.2 

func (ms *MSKService) GetTopicsWithConfigs(ctx context.Context, clusterArn string) ([]types.TopicDetails, error)

func (*MSKService) IsFetchFromFollowerEnabled 

func (ms *MSKService) IsFetchFromFollowerEnabled(ctx context.Context, cluster kafkatypes.Cluster) (bool, error)

func (*MSKService) ListClientVpcConnections added in v0.2.1 

func (ms *MSKService) ListClientVpcConnections(ctx context.Context, clusterArn string, maxResults int32) ([]kafkatypes.ClientVpcConnection, error)

func (*MSKService) ListClusterOperationsV2 added in v0.2.1 

func (ms *MSKService) ListClusterOperationsV2(ctx context.Context, clusterArn string, maxResults int32) ([]kafkatypes.ClusterOperationV2Summary, error)

func (*MSKService) ListClusters added in v0.2.7 

func (ms *MSKService) ListClusters(ctx context.Context, maxResults int32) ([]kafkatypes.Cluster, error)

func (*MSKService) ListNodes added in v0.2.1 

func (ms *MSKService) ListNodes(ctx context.Context, clusterArn string, maxResults int32) ([]kafkatypes.NodeInfo, error)

func (*MSKService) ListScramSecrets added in v0.2.1 

func (ms *MSKService) ListScramSecrets(ctx context.Context, clusterArn string, maxResults int32) ([]string, error)

func (*MSKService) ListTopics added in v0.5.2 

func (ms *MSKService) ListTopics(ctx context.Context, clusterArn string, maxResults int32) ([]kafkatypes.TopicInfo, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.