mocks

package
v0.0.0-...-5c79d48 Latest Latest
Warning

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

 Go to latest Published: Feb 15, 2024 License: AGPL-3.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ElastiCacheCluster 

func ElastiCacheCluster(name, region string, opts ...func(*elasticache.ReplicationGroup)) *elasticache.ReplicationGroup

ElastiCacheCluster returns a sample elasticache.ReplicationGroup.

func MemoryDBCluster 

func MemoryDBCluster(name, region string, opts ...func(*memorydb.Cluster)) *memorydb.Cluster

MemoryDBCluster returns a sample memorydb.Cluster.

func OpenSearchDomain 

func OpenSearchDomain(name, region string, opts ...func(status *opensearchservice.DomainStatus)) *opensearchservice.DomainStatus

OpenSearchDomain returns a sample opensearchservice.DomainStatus.

func RDSCluster 

func RDSCluster(name, region string, labels map[string]string, opts ...func(*rds.DBCluster)) *rds.DBCluster

RDSCluster returns a sample rds.DBCluster.

func RDSInstance 

func RDSInstance(name, region string, labels map[string]string, opts ...func(*rds.DBInstance)) *rds.DBInstance

RDSInstance returns a sample rds.DBInstance.

func RDSProxy 

func RDSProxy(name, region, vpcID string) *rds.DBProxy

RDSProxy returns a sample rds.DBProxy.

func RDSProxyCustomEndpoint 

func RDSProxyCustomEndpoint(rdsProxy *rds.DBProxy, name, region string) *rds.DBProxyEndpoint

RDSProxyCustomEndpoint returns a sample rds.DBProxyEndpoint.

func RedshiftCluster 

func RedshiftCluster(name, region string, labels map[string]string, opts ...func(*redshift.Cluster)) *redshift.Cluster

RedshiftCluster returns a sample redshift.Cluster.

func RedshiftGetClusterCredentialsOutput 

func RedshiftGetClusterCredentialsOutput(user, password string, clock clockwork.Clock) *redshift.GetClusterCredentialsOutput

RedshiftGetClusterCredentialsOutput return a sample redshift.GetClusterCredentialsOutput.

func RedshiftGetClusterCredentialsWithIAMOutput 

func RedshiftGetClusterCredentialsWithIAMOutput(user, password string, clock clockwork.Clock) *redshift.GetClusterCredentialsWithIAMOutput

RedshiftGetClusterCredentialsWithIAMOutput return a sample redshift.GetClusterCredentialsWithIAMeOutput.

func RedshiftServerlessEndpointAccess 

func RedshiftServerlessEndpointAccess(workgroup *redshiftserverless.Workgroup, name, region string) *redshiftserverless.EndpointAccess

RedshiftServerlessEndpointAccess returns a sample redshiftserverless.EndpointAccess.

func RedshiftServerlessGetCredentialsOutput 

func RedshiftServerlessGetCredentialsOutput(user, password string, clock clockwork.Clock) *redshiftserverless.GetCredentialsOutput

RedshiftServerlessGetCredentialsOutput return a sample redshiftserverless.GetCredentialsOutput.

func RedshiftServerlessWorkgroup 

func RedshiftServerlessWorkgroup(name, region string) *redshiftserverless.Workgroup

RedshiftServerlessWorkgroup returns a sample redshiftserverless.Workgroup.

func WithElastiCacheConfigurationEndpoint 

func WithElastiCacheConfigurationEndpoint(cluster *elasticache.ReplicationGroup)

WithElastiCacheConfigurationEndpoint in an option function for MakeElastiCacheCluster to set a configuration endpoint.

func WithElastiCacheReaderEndpoint 

func WithElastiCacheReaderEndpoint(cluster *elasticache.ReplicationGroup)

WithElastiCacheReaderEndpoint is an option function for MakeElastiCacheCluster to set a reader endpoint.

func WithOpenSearchCustomEndpoint 

func WithOpenSearchCustomEndpoint(endpoint string) func(*opensearchservice.DomainStatus)

func WithOpenSearchVPCEndpoint 

func WithOpenSearchVPCEndpoint(name string) func(*opensearchservice.DomainStatus)

func WithRDSClusterCustomEndpoint 

func WithRDSClusterCustomEndpoint(name string) func(*rds.DBCluster)

func WithRDSClusterReader 

func WithRDSClusterReader(cluster *rds.DBCluster)

Types

type AKSClusterEntry 

type AKSClusterEntry struct {
	azure.ClusterCredentialsConfig
	Config *rest.Config
	TTL    time.Duration
}

AKSClusterEntry is an entry in the AKSMock.Clusters list.

type AKSMock 

type AKSMock struct {
	azure.AKSClient
	Clusters []AKSClusterEntry
	Notify   chan struct{}
	Clock    clockwork.Clock
}

AKSMock implements the azure.AKSClient interface for tests.

func (*AKSMock) ClusterCredentials 

func (a *AKSMock) ClusterCredentials(ctx context.Context, cfg azure.ClusterCredentialsConfig) (*rest.Config, time.Time, error)

type EKSMock 

type EKSMock struct {
	eksiface.EKSAPI
	Clusters []*eks.Cluster
	Notify   chan struct{}
}

EKSMock is a mock EKS client.

func (*EKSMock) DescribeClusterWithContext 

func (e *EKSMock) DescribeClusterWithContext(_ aws.Context, req *eks.DescribeClusterInput, _ ...request.Option) (*eks.DescribeClusterOutput, error)

type ElastiCacheMock 

type ElastiCacheMock struct {
	elasticacheiface.ElastiCacheAPI
	// Unauth set to true will make API calls return unauthorized errors.
	Unauth bool

	ReplicationGroups []*elasticache.ReplicationGroup
	Users             []*elasticache.User
	TagsByARN         map[string][]*elasticache.Tag
}

ElastiCache mocks AWS ElastiCache API.

func (*ElastiCacheMock) AddMockUser 

func (m *ElastiCacheMock) AddMockUser(user *elasticache.User, tagsMap map[string]string)

func (*ElastiCacheMock) DescribeCacheClustersPagesWithContext 

func (m *ElastiCacheMock) DescribeCacheClustersPagesWithContext(aws.Context, *elasticache.DescribeCacheClustersInput, func(*elasticache.DescribeCacheClustersOutput, bool) bool, ...request.Option) error

func (*ElastiCacheMock) DescribeCacheSubnetGroupsPagesWithContext 

func (m *ElastiCacheMock) DescribeCacheSubnetGroupsPagesWithContext(aws.Context, *elasticache.DescribeCacheSubnetGroupsInput, func(*elasticache.DescribeCacheSubnetGroupsOutput, bool) bool, ...request.Option) error

func (*ElastiCacheMock) DescribeReplicationGroupsPagesWithContext 

func (m *ElastiCacheMock) DescribeReplicationGroupsPagesWithContext(_ aws.Context, _ *elasticache.DescribeReplicationGroupsInput, fn func(*elasticache.DescribeReplicationGroupsOutput, bool) bool, _ ...request.Option) error

func (*ElastiCacheMock) DescribeReplicationGroupsWithContext 

func (m *ElastiCacheMock) DescribeReplicationGroupsWithContext(_ aws.Context, input *elasticache.DescribeReplicationGroupsInput, opts ...request.Option) (*elasticache.DescribeReplicationGroupsOutput, error)

func (*ElastiCacheMock) DescribeUsersPagesWithContext 

func (m *ElastiCacheMock) DescribeUsersPagesWithContext(_ aws.Context, _ *elasticache.DescribeUsersInput, fn func(*elasticache.DescribeUsersOutput, bool) bool, _ ...request.Option) error

func (*ElastiCacheMock) DescribeUsersWithContext 

func (m *ElastiCacheMock) DescribeUsersWithContext(_ aws.Context, input *elasticache.DescribeUsersInput, opts ...request.Option) (*elasticache.DescribeUsersOutput, error)

func (*ElastiCacheMock) ListTagsForResourceWithContext 

func (m *ElastiCacheMock) ListTagsForResourceWithContext(_ aws.Context, input *elasticache.ListTagsForResourceInput, _ ...request.Option) (*elasticache.TagListMessage, error)

func (*ElastiCacheMock) ModifyUserWithContext 

func (m *ElastiCacheMock) ModifyUserWithContext(_ aws.Context, input *elasticache.ModifyUserInput, opts ...request.Option) (*elasticache.ModifyUserOutput, error)

type GCPSQLAdminClientMock 

type GCPSQLAdminClientMock struct {
	// DatabaseInstance is returned from GetDatabaseInstance.
	DatabaseInstance *sqladmin.DatabaseInstance
	// EphemeralCert is returned from GenerateEphemeralCert.
	EphemeralCert *tls.Certificate
}

GCPSQLAdminClientMock implements the gcp.GCPSQLAdminClient interface for tests.

func (*GCPSQLAdminClientMock) GenerateEphemeralCert 

func (g *GCPSQLAdminClientMock) GenerateEphemeralCert(ctx context.Context, db types.Database, identity tlsca.Identity) (*tls.Certificate, error)

func (*GCPSQLAdminClientMock) GetDatabaseInstance 

func (g *GCPSQLAdminClientMock) GetDatabaseInstance(ctx context.Context, db types.Database) (*sqladmin.DatabaseInstance, error)

func (*GCPSQLAdminClientMock) UpdateUser 

func (g *GCPSQLAdminClientMock) UpdateUser(ctx context.Context, db types.Database, dbUser string, user *sqladmin.User) error

type GKEClusterEntry 

type GKEClusterEntry struct {
	gcp.ClusterDetails
	Config *rest.Config
	TTL    time.Duration
}

GKEClusterEntry is an entry in the GKEMock.Clusters list.

type GKEMock 

type GKEMock struct {
	gcp.GKEClient
	Clusters []GKEClusterEntry
	Notify   chan struct{}
	Clock    clockwork.Clock
}

GKEMock implements the gcp.GKEClient interface for tests.

func (*GKEMock) GetClusterRestConfig 

func (g *GKEMock) GetClusterRestConfig(ctx context.Context, cfg gcp.ClusterDetails) (*rest.Config, time.Time, error)

type IAMErrorMock 

type IAMErrorMock struct {
	iamiface.IAMAPI
	Error error
}

IAMErrorMock is a mock IAM client that returns the provided Error to all APIs. If Error is not provided, all APIs returns trace.AccessDenied by default.

func (*IAMErrorMock) GetRolePolicyWithContext 

func (m *IAMErrorMock) GetRolePolicyWithContext(ctx aws.Context, input *iam.GetRolePolicyInput, options ...request.Option) (*iam.GetRolePolicyOutput, error)

func (*IAMErrorMock) GetUserPolicyWithContext 

func (m *IAMErrorMock) GetUserPolicyWithContext(ctx aws.Context, input *iam.GetUserPolicyInput, options ...request.Option) (*iam.GetUserPolicyOutput, error)

func (*IAMErrorMock) PutRolePolicyWithContext 

func (m *IAMErrorMock) PutRolePolicyWithContext(ctx aws.Context, input *iam.PutRolePolicyInput, options ...request.Option) (*iam.PutRolePolicyOutput, error)

func (*IAMErrorMock) PutUserPolicyWithContext 

func (m *IAMErrorMock) PutUserPolicyWithContext(ctx aws.Context, input *iam.PutUserPolicyInput, options ...request.Option) (*iam.PutUserPolicyOutput, error)

type IAMMock 

type IAMMock struct {
	iamiface.IAMAPI
	// contains filtered or unexported fields
}

IAMMock mocks AWS IAM API.

func (*IAMMock) DeleteRolePolicyWithContext 

func (m *IAMMock) DeleteRolePolicyWithContext(ctx aws.Context, input *iam.DeleteRolePolicyInput, options ...request.Option) (*iam.DeleteRolePolicyOutput, error)

func (*IAMMock) DeleteUserPolicyWithContext 

func (m *IAMMock) DeleteUserPolicyWithContext(ctx aws.Context, input *iam.DeleteUserPolicyInput, options ...request.Option) (*iam.DeleteUserPolicyOutput, error)

func (*IAMMock) GetRolePolicyWithContext 

func (m *IAMMock) GetRolePolicyWithContext(ctx aws.Context, input *iam.GetRolePolicyInput, options ...request.Option) (*iam.GetRolePolicyOutput, error)

func (*IAMMock) GetUserPolicyWithContext 

func (m *IAMMock) GetUserPolicyWithContext(ctx aws.Context, input *iam.GetUserPolicyInput, options ...request.Option) (*iam.GetUserPolicyOutput, error)

func (*IAMMock) PutRolePolicyWithContext 

func (m *IAMMock) PutRolePolicyWithContext(ctx aws.Context, input *iam.PutRolePolicyInput, options ...request.Option) (*iam.PutRolePolicyOutput, error)

func (*IAMMock) PutUserPolicyWithContext 

func (m *IAMMock) PutUserPolicyWithContext(ctx aws.Context, input *iam.PutUserPolicyInput, options ...request.Option) (*iam.PutUserPolicyOutput, error)

type MemoryDBMock 

type MemoryDBMock struct {
	memorydbiface.MemoryDBAPI

	Unauth    bool
	Clusters  []*memorydb.Cluster
	Users     []*memorydb.User
	TagsByARN map[string][]*memorydb.Tag
}

MemoryDBMock mocks AWS MemoryDB API.

func (*MemoryDBMock) AddMockUser 

func (m *MemoryDBMock) AddMockUser(user *memorydb.User, tagsMap map[string]string)

func (*MemoryDBMock) DescribeClustersWithContext 

func (m *MemoryDBMock) DescribeClustersWithContext(_ aws.Context, input *memorydb.DescribeClustersInput, _ ...request.Option) (*memorydb.DescribeClustersOutput, error)

func (*MemoryDBMock) DescribeSubnetGroupsWithContext 

func (m *MemoryDBMock) DescribeSubnetGroupsWithContext(aws.Context, *memorydb.DescribeSubnetGroupsInput, ...request.Option) (*memorydb.DescribeSubnetGroupsOutput, error)

func (*MemoryDBMock) DescribeUsersWithContext 

func (m *MemoryDBMock) DescribeUsersWithContext(aws.Context, *memorydb.DescribeUsersInput, ...request.Option) (*memorydb.DescribeUsersOutput, error)

func (*MemoryDBMock) ListTagsWithContext 

func (m *MemoryDBMock) ListTagsWithContext(_ aws.Context, input *memorydb.ListTagsInput, _ ...request.Option) (*memorydb.ListTagsOutput, error)

func (*MemoryDBMock) UpdateUserWithContext 

func (m *MemoryDBMock) UpdateUserWithContext(_ aws.Context, input *memorydb.UpdateUserInput, opts ...request.Option) (*memorydb.UpdateUserOutput, error)

type OpenSearchMock 

type OpenSearchMock struct {
	opensearchserviceiface.OpenSearchServiceAPI

	Unauth    bool
	Domains   []*opensearchservice.DomainStatus
	TagsByARN map[string][]*opensearchservice.Tag
}

func (*OpenSearchMock) DescribeDomainsWithContext 

func (o *OpenSearchMock) DescribeDomainsWithContext(_ aws.Context, input *opensearchservice.DescribeDomainsInput, _ ...request.Option) (*opensearchservice.DescribeDomainsOutput, error)

func (*OpenSearchMock) ListDomainNamesWithContext 

func (o *OpenSearchMock) ListDomainNamesWithContext(aws.Context, *opensearchservice.ListDomainNamesInput, ...request.Option) (*opensearchservice.ListDomainNamesOutput, error)

func (*OpenSearchMock) ListTagsWithContext 

func (o *OpenSearchMock) ListTagsWithContext(_ aws.Context, request *opensearchservice.ListTagsInput, _ ...request.Option) (*opensearchservice.ListTagsOutput, error)

type RDSMock 

type RDSMock struct {
	rdsiface.RDSAPI
	DBInstances      []*rds.DBInstance
	DBClusters       []*rds.DBCluster
	DBProxies        []*rds.DBProxy
	DBProxyEndpoints []*rds.DBProxyEndpoint
	DBEngineVersions []*rds.DBEngineVersion
}

RDSMock mocks AWS RDS API.

func (*RDSMock) DescribeDBClustersPagesWithContext 

func (m *RDSMock) DescribeDBClustersPagesWithContext(aws aws.Context, input *rds.DescribeDBClustersInput, fn func(*rds.DescribeDBClustersOutput, bool) bool, options ...request.Option) error

func (*RDSMock) DescribeDBClustersWithContext 

func (m *RDSMock) DescribeDBClustersWithContext(ctx aws.Context, input *rds.DescribeDBClustersInput, options ...request.Option) (*rds.DescribeDBClustersOutput, error)

func (*RDSMock) DescribeDBInstancesPagesWithContext 

func (m *RDSMock) DescribeDBInstancesPagesWithContext(ctx aws.Context, input *rds.DescribeDBInstancesInput, fn func(*rds.DescribeDBInstancesOutput, bool) bool, options ...request.Option) error

func (*RDSMock) DescribeDBInstancesWithContext 

func (m *RDSMock) DescribeDBInstancesWithContext(ctx aws.Context, input *rds.DescribeDBInstancesInput, options ...request.Option) (*rds.DescribeDBInstancesOutput, error)

func (*RDSMock) DescribeDBProxiesPagesWithContext 

func (m *RDSMock) DescribeDBProxiesPagesWithContext(ctx aws.Context, input *rds.DescribeDBProxiesInput, fn func(*rds.DescribeDBProxiesOutput, bool) bool, options ...request.Option) error

func (*RDSMock) DescribeDBProxiesWithContext 

func (m *RDSMock) DescribeDBProxiesWithContext(ctx aws.Context, input *rds.DescribeDBProxiesInput, options ...request.Option) (*rds.DescribeDBProxiesOutput, error)

func (*RDSMock) DescribeDBProxyEndpointsPagesWithContext 

func (m *RDSMock) DescribeDBProxyEndpointsPagesWithContext(ctx aws.Context, input *rds.DescribeDBProxyEndpointsInput, fn func(*rds.DescribeDBProxyEndpointsOutput, bool) bool, options ...request.Option) error

func (*RDSMock) DescribeDBProxyEndpointsWithContext 

func (m *RDSMock) DescribeDBProxyEndpointsWithContext(ctx aws.Context, input *rds.DescribeDBProxyEndpointsInput, options ...request.Option) (*rds.DescribeDBProxyEndpointsOutput, error)

func (*RDSMock) ListTagsForResourceWithContext 

func (m *RDSMock) ListTagsForResourceWithContext(ctx aws.Context, input *rds.ListTagsForResourceInput, options ...request.Option) (*rds.ListTagsForResourceOutput, error)

func (*RDSMock) ModifyDBClusterWithContext 

func (m *RDSMock) ModifyDBClusterWithContext(ctx aws.Context, input *rds.ModifyDBClusterInput, options ...request.Option) (*rds.ModifyDBClusterOutput, error)

func (*RDSMock) ModifyDBInstanceWithContext 

func (m *RDSMock) ModifyDBInstanceWithContext(ctx aws.Context, input *rds.ModifyDBInstanceInput, options ...request.Option) (*rds.ModifyDBInstanceOutput, error)

type RDSMockByDBType 

type RDSMockByDBType struct {
	rdsiface.RDSAPI
	DBInstances rdsiface.RDSAPI
	DBClusters  rdsiface.RDSAPI
	DBProxies   rdsiface.RDSAPI
}

RDSMockByDBType is a mock RDS client that mocks API calls by DB type

func (*RDSMockByDBType) DescribeDBClustersPagesWithContext 

func (m *RDSMockByDBType) DescribeDBClustersPagesWithContext(aws aws.Context, input *rds.DescribeDBClustersInput, fn func(*rds.DescribeDBClustersOutput, bool) bool, options ...request.Option) error

func (*RDSMockByDBType) DescribeDBClustersWithContext 

func (m *RDSMockByDBType) DescribeDBClustersWithContext(ctx aws.Context, input *rds.DescribeDBClustersInput, options ...request.Option) (*rds.DescribeDBClustersOutput, error)

func (*RDSMockByDBType) DescribeDBInstancesPagesWithContext 

func (m *RDSMockByDBType) DescribeDBInstancesPagesWithContext(ctx aws.Context, input *rds.DescribeDBInstancesInput, fn func(*rds.DescribeDBInstancesOutput, bool) bool, options ...request.Option) error

func (*RDSMockByDBType) DescribeDBInstancesWithContext 

func (m *RDSMockByDBType) DescribeDBInstancesWithContext(ctx aws.Context, input *rds.DescribeDBInstancesInput, options ...request.Option) (*rds.DescribeDBInstancesOutput, error)

func (*RDSMockByDBType) DescribeDBProxiesPagesWithContext 

func (m *RDSMockByDBType) DescribeDBProxiesPagesWithContext(ctx aws.Context, input *rds.DescribeDBProxiesInput, fn func(*rds.DescribeDBProxiesOutput, bool) bool, options ...request.Option) error

func (*RDSMockByDBType) DescribeDBProxiesWithContext 

func (m *RDSMockByDBType) DescribeDBProxiesWithContext(ctx aws.Context, input *rds.DescribeDBProxiesInput, options ...request.Option) (*rds.DescribeDBProxiesOutput, error)

func (*RDSMockByDBType) DescribeDBProxyEndpointsWithContext 

func (m *RDSMockByDBType) DescribeDBProxyEndpointsWithContext(ctx aws.Context, input *rds.DescribeDBProxyEndpointsInput, options ...request.Option) (*rds.DescribeDBProxyEndpointsOutput, error)

func (*RDSMockByDBType) ModifyDBClusterWithContext 

func (m *RDSMockByDBType) ModifyDBClusterWithContext(ctx aws.Context, input *rds.ModifyDBClusterInput, options ...request.Option) (*rds.ModifyDBClusterOutput, error)

func (*RDSMockByDBType) ModifyDBInstanceWithContext 

func (m *RDSMockByDBType) ModifyDBInstanceWithContext(ctx aws.Context, input *rds.ModifyDBInstanceInput, options ...request.Option) (*rds.ModifyDBInstanceOutput, error)

type RDSMockUnauth 

type RDSMockUnauth struct {
	rdsiface.RDSAPI
}

RDSMockUnauth is a mock RDS client that returns access denied to each call.

func (*RDSMockUnauth) DescribeDBClustersPagesWithContext 

func (m *RDSMockUnauth) DescribeDBClustersPagesWithContext(aws aws.Context, input *rds.DescribeDBClustersInput, fn func(*rds.DescribeDBClustersOutput, bool) bool, options ...request.Option) error

func (*RDSMockUnauth) DescribeDBClustersWithContext 

func (m *RDSMockUnauth) DescribeDBClustersWithContext(ctx aws.Context, input *rds.DescribeDBClustersInput, options ...request.Option) (*rds.DescribeDBClustersOutput, error)

func (*RDSMockUnauth) DescribeDBInstancesPagesWithContext 

func (m *RDSMockUnauth) DescribeDBInstancesPagesWithContext(ctx aws.Context, input *rds.DescribeDBInstancesInput, fn func(*rds.DescribeDBInstancesOutput, bool) bool, options ...request.Option) error

func (*RDSMockUnauth) DescribeDBInstancesWithContext 

func (m *RDSMockUnauth) DescribeDBInstancesWithContext(ctx aws.Context, input *rds.DescribeDBInstancesInput, options ...request.Option) (*rds.DescribeDBInstancesOutput, error)

func (*RDSMockUnauth) DescribeDBProxiesPagesWithContext 

func (m *RDSMockUnauth) DescribeDBProxiesPagesWithContext(ctx aws.Context, input *rds.DescribeDBProxiesInput, fn func(*rds.DescribeDBProxiesOutput, bool) bool, options ...request.Option) error

func (*RDSMockUnauth) DescribeDBProxiesWithContext 

func (m *RDSMockUnauth) DescribeDBProxiesWithContext(ctx aws.Context, input *rds.DescribeDBProxiesInput, options ...request.Option) (*rds.DescribeDBProxiesOutput, error)

func (*RDSMockUnauth) DescribeDBProxyEndpointsWithContext 

func (m *RDSMockUnauth) DescribeDBProxyEndpointsWithContext(ctx aws.Context, input *rds.DescribeDBProxyEndpointsInput, options ...request.Option) (*rds.DescribeDBProxyEndpointsOutput, error)

func (*RDSMockUnauth) ModifyDBClusterWithContext 

func (m *RDSMockUnauth) ModifyDBClusterWithContext(ctx aws.Context, input *rds.ModifyDBClusterInput, options ...request.Option) (*rds.ModifyDBClusterOutput, error)

func (*RDSMockUnauth) ModifyDBInstanceWithContext 

func (m *RDSMockUnauth) ModifyDBInstanceWithContext(ctx aws.Context, input *rds.ModifyDBInstanceInput, options ...request.Option) (*rds.ModifyDBInstanceOutput, error)

type RedshiftMock 

type RedshiftMock struct {
	redshiftiface.RedshiftAPI
	Clusters                           []*redshift.Cluster
	GetClusterCredentialsOutput        *redshift.GetClusterCredentialsOutput
	GetClusterCredentialsWithIAMOutput *redshift.GetClusterCredentialsWithIAMOutput
}

RedshiftMock mocks AWS Redshift API.

func (*RedshiftMock) DescribeClustersPagesWithContext 

func (m *RedshiftMock) DescribeClustersPagesWithContext(ctx aws.Context, input *redshift.DescribeClustersInput, fn func(*redshift.DescribeClustersOutput, bool) bool, options ...request.Option) error

func (*RedshiftMock) DescribeClustersWithContext 

func (m *RedshiftMock) DescribeClustersWithContext(ctx aws.Context, input *redshift.DescribeClustersInput, options ...request.Option) (*redshift.DescribeClustersOutput, error)

func (*RedshiftMock) GetClusterCredentialsWithContext 

func (m *RedshiftMock) GetClusterCredentialsWithContext(aws.Context, *redshift.GetClusterCredentialsInput, ...request.Option) (*redshift.GetClusterCredentialsOutput, error)

func (*RedshiftMock) GetClusterCredentialsWithIAMWithContext 

func (m *RedshiftMock) GetClusterCredentialsWithIAMWithContext(aws.Context, *redshift.GetClusterCredentialsWithIAMInput, ...request.Option) (*redshift.GetClusterCredentialsWithIAMOutput, error)

type RedshiftMockUnauth 

type RedshiftMockUnauth struct {
	redshiftiface.RedshiftAPI
}

RedshiftMockUnauth is a mock Redshift client that returns access denied to each call.

func (*RedshiftMockUnauth) DescribeClustersWithContext 

func (m *RedshiftMockUnauth) DescribeClustersWithContext(ctx aws.Context, input *redshift.DescribeClustersInput, options ...request.Option) (*redshift.DescribeClustersOutput, error)

type RedshiftServerlessMock 

type RedshiftServerlessMock struct {
	redshiftserverlessiface.RedshiftServerlessAPI

	Unauth               bool
	Workgroups           []*redshiftserverless.Workgroup
	Endpoints            []*redshiftserverless.EndpointAccess
	TagsByARN            map[string][]*redshiftserverless.Tag
	GetCredentialsOutput *redshiftserverless.GetCredentialsOutput
}

RedshiftServerlessMock mocks RedshiftServerless API.

func (RedshiftServerlessMock) GetCredentialsWithContext 

func (m RedshiftServerlessMock) GetCredentialsWithContext(aws.Context, *redshiftserverless.GetCredentialsInput, ...request.Option) (*redshiftserverless.GetCredentialsOutput, error)

func (RedshiftServerlessMock) GetEndpointAccessWithContext 

func (m RedshiftServerlessMock) GetEndpointAccessWithContext(_ aws.Context, input *redshiftserverless.GetEndpointAccessInput, _ ...request.Option) (*redshiftserverless.GetEndpointAccessOutput, error)

func (RedshiftServerlessMock) GetWorkgroupWithContext 

func (m RedshiftServerlessMock) GetWorkgroupWithContext(_ aws.Context, input *redshiftserverless.GetWorkgroupInput, _ ...request.Option) (*redshiftserverless.GetWorkgroupOutput, error)

func (RedshiftServerlessMock) ListEndpointAccessPagesWithContext 

func (m RedshiftServerlessMock) ListEndpointAccessPagesWithContext(_ aws.Context, input *redshiftserverless.ListEndpointAccessInput, fn func(*redshiftserverless.ListEndpointAccessOutput, bool) bool, _ ...request.Option) error

func (RedshiftServerlessMock) ListTagsForResourceWithContext 

func (m RedshiftServerlessMock) ListTagsForResourceWithContext(_ aws.Context, input *redshiftserverless.ListTagsForResourceInput, _ ...request.Option) (*redshiftserverless.ListTagsForResourceOutput, error)

func (RedshiftServerlessMock) ListWorkgroupsPagesWithContext 

func (m RedshiftServerlessMock) ListWorkgroupsPagesWithContext(_ aws.Context, input *redshiftserverless.ListWorkgroupsInput, fn func(*redshiftserverless.ListWorkgroupsOutput, bool) bool, _ ...request.Option) error

type STSMock 

type STSMock struct {
	stsiface.STSAPI
	ARN string
	URL *url.URL
	// contains filtered or unexported fields
}

STSMock mocks AWS STS API.

func (*STSMock) AssumeRole 

func (m *STSMock) AssumeRole(in *sts.AssumeRoleInput) (*sts.AssumeRoleOutput, error)

func (*STSMock) AssumeRoleWithContext 

func (m *STSMock) AssumeRoleWithContext(ctx aws.Context, in *sts.AssumeRoleInput, _ ...request.Option) (*sts.AssumeRoleOutput, error)

func (*STSMock) GetAssumedRoleARNs 

func (m *STSMock) GetAssumedRoleARNs() []string

func (*STSMock) GetAssumedRoleExternalIDs 

func (m *STSMock) GetAssumedRoleExternalIDs() []string

func (*STSMock) GetCallerIdentityRequest 

func (m *STSMock) GetCallerIdentityRequest(req *sts.GetCallerIdentityInput) (*request.Request, *sts.GetCallerIdentityOutput)

func (*STSMock) GetCallerIdentityWithContext 

func (m *STSMock) GetCallerIdentityWithContext(aws.Context, *sts.GetCallerIdentityInput, ...request.Option) (*sts.GetCallerIdentityOutput, error)

func (*STSMock) ResetAssumeRoleHistory 

func (m *STSMock) ResetAssumeRoleHistory()

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.