msk

package

v0.2.5 Latest Latest Go to latest Published: Aug 27, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewMSKService(client *kafka.Client) *MSKService

func (ms *MSKService) DescribeCluster(ctx context.Context, clusterArn *string) (*kafkatypes.Cluster, error)

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

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

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

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

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

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

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

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

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

func (ms *MSKService) ParseBrokerAddresses(brokers kafka.GetBootstrapBrokersOutput, authType types.AuthType) ([]string, error)