kafkadouble

package
v0.0.0-...-8548fdf Latest Latest
Warning

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

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

Documentation

Overview

Code generated by go awsdoublegen; DO NOT EDIT. This file was generated at 2020-01-29T21:22:05+11:00 For SDKVersion 1.28.13 Package kafkadouble contains test double implementation of kafkaiface.KafkaAPI

Package kafkadouble provides a TestDouble implementation of kafkaiface.KafkaAPI

Code generated by go awsdoublegen; DO NOT EDIT. This file was generated at 2020-01-29T21:22:05+11:00

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type KafkaDouble 

type KafkaDouble struct {
	kafkaiface.KafkaAPI
	*awsdouble.AWSTestDouble
}

KafkaDouble is TestDouble for kafkaiface.KafkaAPI

func NewDouble 

func NewDouble(t godouble.T, configurators ...func(*awsdouble.AWSTestDouble)) *KafkaDouble

Constructor for KafkaDouble Default configuration will ensure

  • API operations not explicitly stubbed will return an empty output struct pointer, and nil error. To simulate long polling, "Poll" operations will return these values after a random delay of up to 100ms.

  • WithContext methods implement a 'Fake' method that returns a cancellation error if the context is cancelled before the method is called.

  • Pages and PagesWithContext methods similarly implement a 'Fake' method that paginates over the underlying method.

    This allows tests to only stub the simple api methods and be generally unconcerned whether the SUT is using the Context or Pagination forms of the API.

func (*KafkaDouble) CreateCluster 

func (d *KafkaDouble) CreateCluster(i0 *kafka.CreateClusterInput) (r0 *kafka.CreateClusterOutput, r1 error)

func (*KafkaDouble) CreateClusterRequest 

func (d *KafkaDouble) CreateClusterRequest(i0 *kafka.CreateClusterInput) (r0 *request.Request, r1 *kafka.CreateClusterOutput)

func (*KafkaDouble) CreateClusterWithContext 

func (d *KafkaDouble) CreateClusterWithContext(i0 context.Context, i1 *kafka.CreateClusterInput, i2 ...request.Option) (r0 *kafka.CreateClusterOutput, r1 error)

func (*KafkaDouble) CreateConfiguration 

func (d *KafkaDouble) CreateConfiguration(i0 *kafka.CreateConfigurationInput) (r0 *kafka.CreateConfigurationOutput, r1 error)

func (*KafkaDouble) CreateConfigurationRequest 

func (d *KafkaDouble) CreateConfigurationRequest(i0 *kafka.CreateConfigurationInput) (r0 *request.Request, r1 *kafka.CreateConfigurationOutput)

func (*KafkaDouble) CreateConfigurationWithContext 

func (d *KafkaDouble) CreateConfigurationWithContext(i0 context.Context, i1 *kafka.CreateConfigurationInput, i2 ...request.Option) (r0 *kafka.CreateConfigurationOutput, r1 error)

func (*KafkaDouble) DeleteCluster 

func (d *KafkaDouble) DeleteCluster(i0 *kafka.DeleteClusterInput) (r0 *kafka.DeleteClusterOutput, r1 error)

func (*KafkaDouble) DeleteClusterRequest 

func (d *KafkaDouble) DeleteClusterRequest(i0 *kafka.DeleteClusterInput) (r0 *request.Request, r1 *kafka.DeleteClusterOutput)

func (*KafkaDouble) DeleteClusterWithContext 

func (d *KafkaDouble) DeleteClusterWithContext(i0 context.Context, i1 *kafka.DeleteClusterInput, i2 ...request.Option) (r0 *kafka.DeleteClusterOutput, r1 error)

func (*KafkaDouble) DescribeCluster 

func (d *KafkaDouble) DescribeCluster(i0 *kafka.DescribeClusterInput) (r0 *kafka.DescribeClusterOutput, r1 error)

func (*KafkaDouble) DescribeClusterOperation 

func (d *KafkaDouble) DescribeClusterOperation(i0 *kafka.DescribeClusterOperationInput) (r0 *kafka.DescribeClusterOperationOutput, r1 error)

func (*KafkaDouble) DescribeClusterOperationRequest 

func (d *KafkaDouble) DescribeClusterOperationRequest(i0 *kafka.DescribeClusterOperationInput) (r0 *request.Request, r1 *kafka.DescribeClusterOperationOutput)

func (*KafkaDouble) DescribeClusterOperationWithContext 

func (d *KafkaDouble) DescribeClusterOperationWithContext(i0 context.Context, i1 *kafka.DescribeClusterOperationInput, i2 ...request.Option) (r0 *kafka.DescribeClusterOperationOutput, r1 error)

func (*KafkaDouble) DescribeClusterRequest 

func (d *KafkaDouble) DescribeClusterRequest(i0 *kafka.DescribeClusterInput) (r0 *request.Request, r1 *kafka.DescribeClusterOutput)

func (*KafkaDouble) DescribeClusterWithContext 

func (d *KafkaDouble) DescribeClusterWithContext(i0 context.Context, i1 *kafka.DescribeClusterInput, i2 ...request.Option) (r0 *kafka.DescribeClusterOutput, r1 error)

func (*KafkaDouble) DescribeConfiguration 

func (d *KafkaDouble) DescribeConfiguration(i0 *kafka.DescribeConfigurationInput) (r0 *kafka.DescribeConfigurationOutput, r1 error)

func (*KafkaDouble) DescribeConfigurationRequest 

func (d *KafkaDouble) DescribeConfigurationRequest(i0 *kafka.DescribeConfigurationInput) (r0 *request.Request, r1 *kafka.DescribeConfigurationOutput)

func (*KafkaDouble) DescribeConfigurationRevision 

func (d *KafkaDouble) DescribeConfigurationRevision(i0 *kafka.DescribeConfigurationRevisionInput) (r0 *kafka.DescribeConfigurationRevisionOutput, r1 error)

func (*KafkaDouble) DescribeConfigurationRevisionRequest 

func (d *KafkaDouble) DescribeConfigurationRevisionRequest(i0 *kafka.DescribeConfigurationRevisionInput) (r0 *request.Request, r1 *kafka.DescribeConfigurationRevisionOutput)

func (*KafkaDouble) DescribeConfigurationRevisionWithContext 

func (d *KafkaDouble) DescribeConfigurationRevisionWithContext(i0 context.Context, i1 *kafka.DescribeConfigurationRevisionInput, i2 ...request.Option) (r0 *kafka.DescribeConfigurationRevisionOutput, r1 error)

func (*KafkaDouble) DescribeConfigurationWithContext 

func (d *KafkaDouble) DescribeConfigurationWithContext(i0 context.Context, i1 *kafka.DescribeConfigurationInput, i2 ...request.Option) (r0 *kafka.DescribeConfigurationOutput, r1 error)

func (*KafkaDouble) GetBootstrapBrokers 

func (d *KafkaDouble) GetBootstrapBrokers(i0 *kafka.GetBootstrapBrokersInput) (r0 *kafka.GetBootstrapBrokersOutput, r1 error)

func (*KafkaDouble) GetBootstrapBrokersRequest 

func (d *KafkaDouble) GetBootstrapBrokersRequest(i0 *kafka.GetBootstrapBrokersInput) (r0 *request.Request, r1 *kafka.GetBootstrapBrokersOutput)

func (*KafkaDouble) GetBootstrapBrokersWithContext 

func (d *KafkaDouble) GetBootstrapBrokersWithContext(i0 context.Context, i1 *kafka.GetBootstrapBrokersInput, i2 ...request.Option) (r0 *kafka.GetBootstrapBrokersOutput, r1 error)

func (*KafkaDouble) ListClusterOperations 

func (d *KafkaDouble) ListClusterOperations(i0 *kafka.ListClusterOperationsInput) (r0 *kafka.ListClusterOperationsOutput, r1 error)

func (*KafkaDouble) ListClusterOperationsPages 

func (d *KafkaDouble) ListClusterOperationsPages(i0 *kafka.ListClusterOperationsInput, i1 func(*kafka.ListClusterOperationsOutput, bool) bool) (r0 error)

func (*KafkaDouble) ListClusterOperationsPagesWithContext 

func (d *KafkaDouble) ListClusterOperationsPagesWithContext(i0 context.Context, i1 *kafka.ListClusterOperationsInput, i2 func(*kafka.ListClusterOperationsOutput, bool) bool, i3 ...request.Option) (r0 error)

func (*KafkaDouble) ListClusterOperationsRequest 

func (d *KafkaDouble) ListClusterOperationsRequest(i0 *kafka.ListClusterOperationsInput) (r0 *request.Request, r1 *kafka.ListClusterOperationsOutput)

func (*KafkaDouble) ListClusterOperationsWithContext 

func (d *KafkaDouble) ListClusterOperationsWithContext(i0 context.Context, i1 *kafka.ListClusterOperationsInput, i2 ...request.Option) (r0 *kafka.ListClusterOperationsOutput, r1 error)

func (*KafkaDouble) ListClusters 

func (d *KafkaDouble) ListClusters(i0 *kafka.ListClustersInput) (r0 *kafka.ListClustersOutput, r1 error)

func (*KafkaDouble) ListClustersPages 

func (d *KafkaDouble) ListClustersPages(i0 *kafka.ListClustersInput, i1 func(*kafka.ListClustersOutput, bool) bool) (r0 error)

func (*KafkaDouble) ListClustersPagesWithContext 

func (d *KafkaDouble) ListClustersPagesWithContext(i0 context.Context, i1 *kafka.ListClustersInput, i2 func(*kafka.ListClustersOutput, bool) bool, i3 ...request.Option) (r0 error)

func (*KafkaDouble) ListClustersRequest 

func (d *KafkaDouble) ListClustersRequest(i0 *kafka.ListClustersInput) (r0 *request.Request, r1 *kafka.ListClustersOutput)

func (*KafkaDouble) ListClustersWithContext 

func (d *KafkaDouble) ListClustersWithContext(i0 context.Context, i1 *kafka.ListClustersInput, i2 ...request.Option) (r0 *kafka.ListClustersOutput, r1 error)

func (*KafkaDouble) ListConfigurationRevisions 

func (d *KafkaDouble) ListConfigurationRevisions(i0 *kafka.ListConfigurationRevisionsInput) (r0 *kafka.ListConfigurationRevisionsOutput, r1 error)

func (*KafkaDouble) ListConfigurationRevisionsPages 

func (d *KafkaDouble) ListConfigurationRevisionsPages(i0 *kafka.ListConfigurationRevisionsInput, i1 func(*kafka.ListConfigurationRevisionsOutput, bool) bool) (r0 error)

func (*KafkaDouble) ListConfigurationRevisionsPagesWithContext 

func (d *KafkaDouble) ListConfigurationRevisionsPagesWithContext(i0 context.Context, i1 *kafka.ListConfigurationRevisionsInput, i2 func(*kafka.ListConfigurationRevisionsOutput, bool) bool, i3 ...request.Option) (r0 error)

func (*KafkaDouble) ListConfigurationRevisionsRequest 

func (d *KafkaDouble) ListConfigurationRevisionsRequest(i0 *kafka.ListConfigurationRevisionsInput) (r0 *request.Request, r1 *kafka.ListConfigurationRevisionsOutput)

func (*KafkaDouble) ListConfigurationRevisionsWithContext 

func (d *KafkaDouble) ListConfigurationRevisionsWithContext(i0 context.Context, i1 *kafka.ListConfigurationRevisionsInput, i2 ...request.Option) (r0 *kafka.ListConfigurationRevisionsOutput, r1 error)

func (*KafkaDouble) ListConfigurations 

func (d *KafkaDouble) ListConfigurations(i0 *kafka.ListConfigurationsInput) (r0 *kafka.ListConfigurationsOutput, r1 error)

func (*KafkaDouble) ListConfigurationsPages 

func (d *KafkaDouble) ListConfigurationsPages(i0 *kafka.ListConfigurationsInput, i1 func(*kafka.ListConfigurationsOutput, bool) bool) (r0 error)

func (*KafkaDouble) ListConfigurationsPagesWithContext 

func (d *KafkaDouble) ListConfigurationsPagesWithContext(i0 context.Context, i1 *kafka.ListConfigurationsInput, i2 func(*kafka.ListConfigurationsOutput, bool) bool, i3 ...request.Option) (r0 error)

func (*KafkaDouble) ListConfigurationsRequest 

func (d *KafkaDouble) ListConfigurationsRequest(i0 *kafka.ListConfigurationsInput) (r0 *request.Request, r1 *kafka.ListConfigurationsOutput)

func (*KafkaDouble) ListConfigurationsWithContext 

func (d *KafkaDouble) ListConfigurationsWithContext(i0 context.Context, i1 *kafka.ListConfigurationsInput, i2 ...request.Option) (r0 *kafka.ListConfigurationsOutput, r1 error)

func (*KafkaDouble) ListKafkaVersions 

func (d *KafkaDouble) ListKafkaVersions(i0 *kafka.ListKafkaVersionsInput) (r0 *kafka.ListKafkaVersionsOutput, r1 error)

func (*KafkaDouble) ListKafkaVersionsPages 

func (d *KafkaDouble) ListKafkaVersionsPages(i0 *kafka.ListKafkaVersionsInput, i1 func(*kafka.ListKafkaVersionsOutput, bool) bool) (r0 error)

func (*KafkaDouble) ListKafkaVersionsPagesWithContext 

func (d *KafkaDouble) ListKafkaVersionsPagesWithContext(i0 context.Context, i1 *kafka.ListKafkaVersionsInput, i2 func(*kafka.ListKafkaVersionsOutput, bool) bool, i3 ...request.Option) (r0 error)

func (*KafkaDouble) ListKafkaVersionsRequest 

func (d *KafkaDouble) ListKafkaVersionsRequest(i0 *kafka.ListKafkaVersionsInput) (r0 *request.Request, r1 *kafka.ListKafkaVersionsOutput)

func (*KafkaDouble) ListKafkaVersionsWithContext 

func (d *KafkaDouble) ListKafkaVersionsWithContext(i0 context.Context, i1 *kafka.ListKafkaVersionsInput, i2 ...request.Option) (r0 *kafka.ListKafkaVersionsOutput, r1 error)

func (*KafkaDouble) ListNodes 

func (d *KafkaDouble) ListNodes(i0 *kafka.ListNodesInput) (r0 *kafka.ListNodesOutput, r1 error)

func (*KafkaDouble) ListNodesPages 

func (d *KafkaDouble) ListNodesPages(i0 *kafka.ListNodesInput, i1 func(*kafka.ListNodesOutput, bool) bool) (r0 error)

func (*KafkaDouble) ListNodesPagesWithContext 

func (d *KafkaDouble) ListNodesPagesWithContext(i0 context.Context, i1 *kafka.ListNodesInput, i2 func(*kafka.ListNodesOutput, bool) bool, i3 ...request.Option) (r0 error)

func (*KafkaDouble) ListNodesRequest 

func (d *KafkaDouble) ListNodesRequest(i0 *kafka.ListNodesInput) (r0 *request.Request, r1 *kafka.ListNodesOutput)

func (*KafkaDouble) ListNodesWithContext 

func (d *KafkaDouble) ListNodesWithContext(i0 context.Context, i1 *kafka.ListNodesInput, i2 ...request.Option) (r0 *kafka.ListNodesOutput, r1 error)

func (*KafkaDouble) ListTagsForResource 

func (d *KafkaDouble) ListTagsForResource(i0 *kafka.ListTagsForResourceInput) (r0 *kafka.ListTagsForResourceOutput, r1 error)

func (*KafkaDouble) ListTagsForResourceRequest 

func (d *KafkaDouble) ListTagsForResourceRequest(i0 *kafka.ListTagsForResourceInput) (r0 *request.Request, r1 *kafka.ListTagsForResourceOutput)

func (*KafkaDouble) ListTagsForResourceWithContext 

func (d *KafkaDouble) ListTagsForResourceWithContext(i0 context.Context, i1 *kafka.ListTagsForResourceInput, i2 ...request.Option) (r0 *kafka.ListTagsForResourceOutput, r1 error)

func (*KafkaDouble) TagResource 

func (d *KafkaDouble) TagResource(i0 *kafka.TagResourceInput) (r0 *kafka.TagResourceOutput, r1 error)

func (*KafkaDouble) TagResourceRequest 

func (d *KafkaDouble) TagResourceRequest(i0 *kafka.TagResourceInput) (r0 *request.Request, r1 *kafka.TagResourceOutput)

func (*KafkaDouble) TagResourceWithContext 

func (d *KafkaDouble) TagResourceWithContext(i0 context.Context, i1 *kafka.TagResourceInput, i2 ...request.Option) (r0 *kafka.TagResourceOutput, r1 error)

func (*KafkaDouble) UntagResource 

func (d *KafkaDouble) UntagResource(i0 *kafka.UntagResourceInput) (r0 *kafka.UntagResourceOutput, r1 error)

func (*KafkaDouble) UntagResourceRequest 

func (d *KafkaDouble) UntagResourceRequest(i0 *kafka.UntagResourceInput) (r0 *request.Request, r1 *kafka.UntagResourceOutput)

func (*KafkaDouble) UntagResourceWithContext 

func (d *KafkaDouble) UntagResourceWithContext(i0 context.Context, i1 *kafka.UntagResourceInput, i2 ...request.Option) (r0 *kafka.UntagResourceOutput, r1 error)

func (*KafkaDouble) UpdateBrokerCount 

func (d *KafkaDouble) UpdateBrokerCount(i0 *kafka.UpdateBrokerCountInput) (r0 *kafka.UpdateBrokerCountOutput, r1 error)

func (*KafkaDouble) UpdateBrokerCountRequest 

func (d *KafkaDouble) UpdateBrokerCountRequest(i0 *kafka.UpdateBrokerCountInput) (r0 *request.Request, r1 *kafka.UpdateBrokerCountOutput)

func (*KafkaDouble) UpdateBrokerCountWithContext 

func (d *KafkaDouble) UpdateBrokerCountWithContext(i0 context.Context, i1 *kafka.UpdateBrokerCountInput, i2 ...request.Option) (r0 *kafka.UpdateBrokerCountOutput, r1 error)

func (*KafkaDouble) UpdateBrokerStorage 

func (d *KafkaDouble) UpdateBrokerStorage(i0 *kafka.UpdateBrokerStorageInput) (r0 *kafka.UpdateBrokerStorageOutput, r1 error)

func (*KafkaDouble) UpdateBrokerStorageRequest 

func (d *KafkaDouble) UpdateBrokerStorageRequest(i0 *kafka.UpdateBrokerStorageInput) (r0 *request.Request, r1 *kafka.UpdateBrokerStorageOutput)

func (*KafkaDouble) UpdateBrokerStorageWithContext 

func (d *KafkaDouble) UpdateBrokerStorageWithContext(i0 context.Context, i1 *kafka.UpdateBrokerStorageInput, i2 ...request.Option) (r0 *kafka.UpdateBrokerStorageOutput, r1 error)

func (*KafkaDouble) UpdateClusterConfiguration 

func (d *KafkaDouble) UpdateClusterConfiguration(i0 *kafka.UpdateClusterConfigurationInput) (r0 *kafka.UpdateClusterConfigurationOutput, r1 error)

func (*KafkaDouble) UpdateClusterConfigurationRequest 

func (d *KafkaDouble) UpdateClusterConfigurationRequest(i0 *kafka.UpdateClusterConfigurationInput) (r0 *request.Request, r1 *kafka.UpdateClusterConfigurationOutput)

func (*KafkaDouble) UpdateClusterConfigurationWithContext 

func (d *KafkaDouble) UpdateClusterConfigurationWithContext(i0 context.Context, i1 *kafka.UpdateClusterConfigurationInput, i2 ...request.Option) (r0 *kafka.UpdateClusterConfigurationOutput, r1 error)

func (*KafkaDouble) UpdateMonitoring 

func (d *KafkaDouble) UpdateMonitoring(i0 *kafka.UpdateMonitoringInput) (r0 *kafka.UpdateMonitoringOutput, r1 error)

func (*KafkaDouble) UpdateMonitoringRequest 

func (d *KafkaDouble) UpdateMonitoringRequest(i0 *kafka.UpdateMonitoringInput) (r0 *request.Request, r1 *kafka.UpdateMonitoringOutput)

func (*KafkaDouble) UpdateMonitoringWithContext 

func (d *KafkaDouble) UpdateMonitoringWithContext(i0 context.Context, i1 *kafka.UpdateMonitoringInput, i2 ...request.Option) (r0 *kafka.UpdateMonitoringOutput, r1 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.