kafkastub

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Nov 30, 2021 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchAssociateScramSecretFuture 

type BatchAssociateScramSecretFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*BatchAssociateScramSecretFuture) Get 

func (r *BatchAssociateScramSecretFuture) Get(ctx workflow.Context) (*kafka.BatchAssociateScramSecretOutput, error)

type BatchDisassociateScramSecretFuture 

type BatchDisassociateScramSecretFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*BatchDisassociateScramSecretFuture) Get 

func (r *BatchDisassociateScramSecretFuture) Get(ctx workflow.Context) (*kafka.BatchDisassociateScramSecretOutput, error)

type Client 

type Client interface {
	BatchAssociateScramSecret(ctx workflow.Context, input *kafka.BatchAssociateScramSecretInput) (*kafka.BatchAssociateScramSecretOutput, error)
	BatchAssociateScramSecretAsync(ctx workflow.Context, input *kafka.BatchAssociateScramSecretInput) *BatchAssociateScramSecretFuture

	BatchDisassociateScramSecret(ctx workflow.Context, input *kafka.BatchDisassociateScramSecretInput) (*kafka.BatchDisassociateScramSecretOutput, error)
	BatchDisassociateScramSecretAsync(ctx workflow.Context, input *kafka.BatchDisassociateScramSecretInput) *BatchDisassociateScramSecretFuture

	CreateCluster(ctx workflow.Context, input *kafka.CreateClusterInput) (*kafka.CreateClusterOutput, error)
	CreateClusterAsync(ctx workflow.Context, input *kafka.CreateClusterInput) *CreateClusterFuture

	CreateConfiguration(ctx workflow.Context, input *kafka.CreateConfigurationInput) (*kafka.CreateConfigurationOutput, error)
	CreateConfigurationAsync(ctx workflow.Context, input *kafka.CreateConfigurationInput) *CreateConfigurationFuture

	DeleteCluster(ctx workflow.Context, input *kafka.DeleteClusterInput) (*kafka.DeleteClusterOutput, error)
	DeleteClusterAsync(ctx workflow.Context, input *kafka.DeleteClusterInput) *DeleteClusterFuture

	DeleteConfiguration(ctx workflow.Context, input *kafka.DeleteConfigurationInput) (*kafka.DeleteConfigurationOutput, error)
	DeleteConfigurationAsync(ctx workflow.Context, input *kafka.DeleteConfigurationInput) *DeleteConfigurationFuture

	DescribeCluster(ctx workflow.Context, input *kafka.DescribeClusterInput) (*kafka.DescribeClusterOutput, error)
	DescribeClusterAsync(ctx workflow.Context, input *kafka.DescribeClusterInput) *DescribeClusterFuture

	DescribeClusterOperation(ctx workflow.Context, input *kafka.DescribeClusterOperationInput) (*kafka.DescribeClusterOperationOutput, error)
	DescribeClusterOperationAsync(ctx workflow.Context, input *kafka.DescribeClusterOperationInput) *DescribeClusterOperationFuture

	DescribeConfiguration(ctx workflow.Context, input *kafka.DescribeConfigurationInput) (*kafka.DescribeConfigurationOutput, error)
	DescribeConfigurationAsync(ctx workflow.Context, input *kafka.DescribeConfigurationInput) *DescribeConfigurationFuture

	DescribeConfigurationRevision(ctx workflow.Context, input *kafka.DescribeConfigurationRevisionInput) (*kafka.DescribeConfigurationRevisionOutput, error)
	DescribeConfigurationRevisionAsync(ctx workflow.Context, input *kafka.DescribeConfigurationRevisionInput) *DescribeConfigurationRevisionFuture

	GetBootstrapBrokers(ctx workflow.Context, input *kafka.GetBootstrapBrokersInput) (*kafka.GetBootstrapBrokersOutput, error)
	GetBootstrapBrokersAsync(ctx workflow.Context, input *kafka.GetBootstrapBrokersInput) *GetBootstrapBrokersFuture

	GetCompatibleKafkaVersions(ctx workflow.Context, input *kafka.GetCompatibleKafkaVersionsInput) (*kafka.GetCompatibleKafkaVersionsOutput, error)
	GetCompatibleKafkaVersionsAsync(ctx workflow.Context, input *kafka.GetCompatibleKafkaVersionsInput) *GetCompatibleKafkaVersionsFuture

	ListClusterOperations(ctx workflow.Context, input *kafka.ListClusterOperationsInput) (*kafka.ListClusterOperationsOutput, error)
	ListClusterOperationsAsync(ctx workflow.Context, input *kafka.ListClusterOperationsInput) *ListClusterOperationsFuture

	ListClusters(ctx workflow.Context, input *kafka.ListClustersInput) (*kafka.ListClustersOutput, error)
	ListClustersAsync(ctx workflow.Context, input *kafka.ListClustersInput) *ListClustersFuture

	ListConfigurationRevisions(ctx workflow.Context, input *kafka.ListConfigurationRevisionsInput) (*kafka.ListConfigurationRevisionsOutput, error)
	ListConfigurationRevisionsAsync(ctx workflow.Context, input *kafka.ListConfigurationRevisionsInput) *ListConfigurationRevisionsFuture

	ListConfigurations(ctx workflow.Context, input *kafka.ListConfigurationsInput) (*kafka.ListConfigurationsOutput, error)
	ListConfigurationsAsync(ctx workflow.Context, input *kafka.ListConfigurationsInput) *ListConfigurationsFuture

	ListKafkaVersions(ctx workflow.Context, input *kafka.ListKafkaVersionsInput) (*kafka.ListKafkaVersionsOutput, error)
	ListKafkaVersionsAsync(ctx workflow.Context, input *kafka.ListKafkaVersionsInput) *ListKafkaVersionsFuture

	ListNodes(ctx workflow.Context, input *kafka.ListNodesInput) (*kafka.ListNodesOutput, error)
	ListNodesAsync(ctx workflow.Context, input *kafka.ListNodesInput) *ListNodesFuture

	ListScramSecrets(ctx workflow.Context, input *kafka.ListScramSecretsInput) (*kafka.ListScramSecretsOutput, error)
	ListScramSecretsAsync(ctx workflow.Context, input *kafka.ListScramSecretsInput) *ListScramSecretsFuture

	ListTagsForResource(ctx workflow.Context, input *kafka.ListTagsForResourceInput) (*kafka.ListTagsForResourceOutput, error)
	ListTagsForResourceAsync(ctx workflow.Context, input *kafka.ListTagsForResourceInput) *ListTagsForResourceFuture

	RebootBroker(ctx workflow.Context, input *kafka.RebootBrokerInput) (*kafka.RebootBrokerOutput, error)
	RebootBrokerAsync(ctx workflow.Context, input *kafka.RebootBrokerInput) *RebootBrokerFuture

	TagResource(ctx workflow.Context, input *kafka.TagResourceInput) (*kafka.TagResourceOutput, error)
	TagResourceAsync(ctx workflow.Context, input *kafka.TagResourceInput) *TagResourceFuture

	UntagResource(ctx workflow.Context, input *kafka.UntagResourceInput) (*kafka.UntagResourceOutput, error)
	UntagResourceAsync(ctx workflow.Context, input *kafka.UntagResourceInput) *UntagResourceFuture

	UpdateBrokerCount(ctx workflow.Context, input *kafka.UpdateBrokerCountInput) (*kafka.UpdateBrokerCountOutput, error)
	UpdateBrokerCountAsync(ctx workflow.Context, input *kafka.UpdateBrokerCountInput) *UpdateBrokerCountFuture

	UpdateBrokerStorage(ctx workflow.Context, input *kafka.UpdateBrokerStorageInput) (*kafka.UpdateBrokerStorageOutput, error)
	UpdateBrokerStorageAsync(ctx workflow.Context, input *kafka.UpdateBrokerStorageInput) *UpdateBrokerStorageFuture

	UpdateBrokerType(ctx workflow.Context, input *kafka.UpdateBrokerTypeInput) (*kafka.UpdateBrokerTypeOutput, error)
	UpdateBrokerTypeAsync(ctx workflow.Context, input *kafka.UpdateBrokerTypeInput) *UpdateBrokerTypeFuture

	UpdateClusterConfiguration(ctx workflow.Context, input *kafka.UpdateClusterConfigurationInput) (*kafka.UpdateClusterConfigurationOutput, error)
	UpdateClusterConfigurationAsync(ctx workflow.Context, input *kafka.UpdateClusterConfigurationInput) *UpdateClusterConfigurationFuture

	UpdateClusterKafkaVersion(ctx workflow.Context, input *kafka.UpdateClusterKafkaVersionInput) (*kafka.UpdateClusterKafkaVersionOutput, error)
	UpdateClusterKafkaVersionAsync(ctx workflow.Context, input *kafka.UpdateClusterKafkaVersionInput) *UpdateClusterKafkaVersionFuture

	UpdateConfiguration(ctx workflow.Context, input *kafka.UpdateConfigurationInput) (*kafka.UpdateConfigurationOutput, error)
	UpdateConfigurationAsync(ctx workflow.Context, input *kafka.UpdateConfigurationInput) *UpdateConfigurationFuture

	UpdateMonitoring(ctx workflow.Context, input *kafka.UpdateMonitoringInput) (*kafka.UpdateMonitoringOutput, error)
	UpdateMonitoringAsync(ctx workflow.Context, input *kafka.UpdateMonitoringInput) *UpdateMonitoringFuture
}

func NewClient 

func NewClient() Client

type CreateClusterFuture 

type CreateClusterFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*CreateClusterFuture) Get 

func (r *CreateClusterFuture) Get(ctx workflow.Context) (*kafka.CreateClusterOutput, error)

type CreateConfigurationFuture 

type CreateConfigurationFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*CreateConfigurationFuture) Get 

func (r *CreateConfigurationFuture) Get(ctx workflow.Context) (*kafka.CreateConfigurationOutput, error)

type DeleteClusterFuture 

type DeleteClusterFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DeleteClusterFuture) Get 

func (r *DeleteClusterFuture) Get(ctx workflow.Context) (*kafka.DeleteClusterOutput, error)

type DeleteConfigurationFuture 

type DeleteConfigurationFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DeleteConfigurationFuture) Get 

func (r *DeleteConfigurationFuture) Get(ctx workflow.Context) (*kafka.DeleteConfigurationOutput, error)

type DescribeClusterFuture 

type DescribeClusterFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DescribeClusterFuture) Get 

func (r *DescribeClusterFuture) Get(ctx workflow.Context) (*kafka.DescribeClusterOutput, error)

type DescribeClusterOperationFuture 

type DescribeClusterOperationFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DescribeClusterOperationFuture) Get 

func (r *DescribeClusterOperationFuture) Get(ctx workflow.Context) (*kafka.DescribeClusterOperationOutput, error)

type DescribeConfigurationFuture 

type DescribeConfigurationFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DescribeConfigurationFuture) Get 

func (r *DescribeConfigurationFuture) Get(ctx workflow.Context) (*kafka.DescribeConfigurationOutput, error)

type DescribeConfigurationRevisionFuture 

type DescribeConfigurationRevisionFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*DescribeConfigurationRevisionFuture) Get 

func (r *DescribeConfigurationRevisionFuture) Get(ctx workflow.Context) (*kafka.DescribeConfigurationRevisionOutput, error)

type GetBootstrapBrokersFuture 

type GetBootstrapBrokersFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*GetBootstrapBrokersFuture) Get 

func (r *GetBootstrapBrokersFuture) Get(ctx workflow.Context) (*kafka.GetBootstrapBrokersOutput, error)

type GetCompatibleKafkaVersionsFuture 

type GetCompatibleKafkaVersionsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*GetCompatibleKafkaVersionsFuture) Get 

func (r *GetCompatibleKafkaVersionsFuture) Get(ctx workflow.Context) (*kafka.GetCompatibleKafkaVersionsOutput, error)

type ListClusterOperationsFuture 

type ListClusterOperationsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListClusterOperationsFuture) Get 

func (r *ListClusterOperationsFuture) Get(ctx workflow.Context) (*kafka.ListClusterOperationsOutput, error)

type ListClustersFuture 

type ListClustersFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListClustersFuture) Get 

func (r *ListClustersFuture) Get(ctx workflow.Context) (*kafka.ListClustersOutput, error)

type ListConfigurationRevisionsFuture 

type ListConfigurationRevisionsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListConfigurationRevisionsFuture) Get 

func (r *ListConfigurationRevisionsFuture) Get(ctx workflow.Context) (*kafka.ListConfigurationRevisionsOutput, error)

type ListConfigurationsFuture 

type ListConfigurationsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListConfigurationsFuture) Get 

func (r *ListConfigurationsFuture) Get(ctx workflow.Context) (*kafka.ListConfigurationsOutput, error)

type ListKafkaVersionsFuture 

type ListKafkaVersionsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListKafkaVersionsFuture) Get 

func (r *ListKafkaVersionsFuture) Get(ctx workflow.Context) (*kafka.ListKafkaVersionsOutput, error)

type ListNodesFuture 

type ListNodesFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListNodesFuture) Get 

func (r *ListNodesFuture) Get(ctx workflow.Context) (*kafka.ListNodesOutput, error)

type ListScramSecretsFuture 

type ListScramSecretsFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListScramSecretsFuture) Get 

func (r *ListScramSecretsFuture) Get(ctx workflow.Context) (*kafka.ListScramSecretsOutput, error)

type ListTagsForResourceFuture 

type ListTagsForResourceFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*ListTagsForResourceFuture) Get 

func (r *ListTagsForResourceFuture) Get(ctx workflow.Context) (*kafka.ListTagsForResourceOutput, error)

type RebootBrokerFuture 

type RebootBrokerFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*RebootBrokerFuture) Get 

func (r *RebootBrokerFuture) Get(ctx workflow.Context) (*kafka.RebootBrokerOutput, error)

type TagResourceFuture 

type TagResourceFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*TagResourceFuture) Get 

func (r *TagResourceFuture) Get(ctx workflow.Context) (*kafka.TagResourceOutput, error)

type UntagResourceFuture 

type UntagResourceFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*UntagResourceFuture) Get 

func (r *UntagResourceFuture) Get(ctx workflow.Context) (*kafka.UntagResourceOutput, error)

type UpdateBrokerCountFuture 

type UpdateBrokerCountFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*UpdateBrokerCountFuture) Get 

func (r *UpdateBrokerCountFuture) Get(ctx workflow.Context) (*kafka.UpdateBrokerCountOutput, error)

type UpdateBrokerStorageFuture 

type UpdateBrokerStorageFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*UpdateBrokerStorageFuture) Get 

func (r *UpdateBrokerStorageFuture) Get(ctx workflow.Context) (*kafka.UpdateBrokerStorageOutput, error)

type UpdateBrokerTypeFuture 

type UpdateBrokerTypeFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*UpdateBrokerTypeFuture) Get 

func (r *UpdateBrokerTypeFuture) Get(ctx workflow.Context) (*kafka.UpdateBrokerTypeOutput, error)

type UpdateClusterConfigurationFuture 

type UpdateClusterConfigurationFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*UpdateClusterConfigurationFuture) Get 

func (r *UpdateClusterConfigurationFuture) Get(ctx workflow.Context) (*kafka.UpdateClusterConfigurationOutput, error)

type UpdateClusterKafkaVersionFuture 

type UpdateClusterKafkaVersionFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*UpdateClusterKafkaVersionFuture) Get 

func (r *UpdateClusterKafkaVersionFuture) Get(ctx workflow.Context) (*kafka.UpdateClusterKafkaVersionOutput, error)

type UpdateConfigurationFuture 

type UpdateConfigurationFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*UpdateConfigurationFuture) Get 

func (r *UpdateConfigurationFuture) Get(ctx workflow.Context) (*kafka.UpdateConfigurationOutput, error)

type UpdateMonitoringFuture 

type UpdateMonitoringFuture struct {
	// public to support Selector.addFuture
	Future workflow.Future
}

func (*UpdateMonitoringFuture) Get 

func (r *UpdateMonitoringFuture) Get(ctx workflow.Context) (*kafka.UpdateMonitoringOutput, 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.