mocks

type MockEC2Service struct {
	DescribeSubnetsFunc func(ctx context.Context, subnetIds []string) (*ec2.DescribeSubnetsOutput, error)
}

type MockKafkaAdmin struct {
	ListTopicsWithConfigsFunc       func() (map[string]sarama.TopicDetail, error)
	GetClusterKafkaMetadataFunc     func() (*client.ClusterKafkaMetadata, error)
	DescribeConfigFunc              func() ([]sarama.ConfigEntry, error)
	ListAclsFunc                    func() ([]sarama.ResourceAcls, error)
	GetAllMessagesWithKeyFilterFunc func(topicName string, keyPrefix string) (map[string]string, error)
	GetConnectorStatusMessagesFunc  func(topicName string) (map[string]string, error)
	CloseFunc                       func() error
}

type MockMSKService struct {
	GetBootstrapBrokersFunc        func(ctx context.Context, clusterArn string) (*kafka.GetBootstrapBrokersOutput, error)
	ParseBrokerAddressesFunc       func(brokers kafka.GetBootstrapBrokersOutput, authType types.AuthType) ([]string, error)
	GetCompatibleKafkaVersionsFunc func(ctx context.Context, clusterArn string) (*kafka.GetCompatibleKafkaVersionsOutput, error)
	GetClusterPolicyFunc           func(ctx context.Context, clusterArn string) (*kafka.GetClusterPolicyOutput, error)
	DescribeClusterV2Func          func(ctx context.Context, clusterArn string) (*kafka.DescribeClusterV2Output, error)
	ListClientVpcConnectionsFunc   func(ctx context.Context, clusterArn string) ([]kafkatypes.ClientVpcConnection, error)
	ListClusterOperationsV2Func    func(ctx context.Context, clusterArn string) ([]kafkatypes.ClusterOperationV2Summary, error)
	ListNodesFunc                  func(ctx context.Context, clusterArn string) ([]kafkatypes.NodeInfo, error)
	ListScramSecretsFunc           func(ctx context.Context, clusterArn string) ([]string, error)
}