Documentation ¶
Index ¶
- func AuditLogsSourceBrokerWithGCPBrokerTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func AuditLogsSourceBrokerWithPubSubChannelTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func BrokerWithPubSubChannelTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func CloudAuditLogsSourceWithTargetTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func CloudBuildSourceWithTargetTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func CloudPubSubSourceWithTargetTestImpl(t *testing.T, assertMetrics bool, authConfig lib.AuthConfig)
- func CloudSchedulerSourceWithTargetTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func CloudStorageSourceWithTargetTestImpl(t *testing.T, assertMetrics bool, authConfig lib.AuthConfig)
- func GCPBrokerMetricsTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func GCPBrokerTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func GCPBrokerTracingTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func PubSubSourceBrokerWithPubSubChannelTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func PubSubSourceWithGCPBrokerTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func PullSubscriptionWithTargetTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func SchedulerSourceBrokerWithPubSubChannelTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func SchedulerSourceWithGCPBrokerTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func SmokeCloudAuditLogsSourceTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func SmokeCloudBuildSourceTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func SmokeCloudPubSubSourceTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func SmokeCloudSchedulerSourceTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func SmokeCloudStorageSourceTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func SmokeGCPBrokerTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func SmokePullSubscriptionTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func SmokeTestChannelImpl(t *testing.T, authConfig lib.AuthConfig)
- func StorageSourceBrokerWithPubSubChannelTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func StorageSourceWithGCPBrokerTestImpl(t *testing.T, authConfig lib.AuthConfig)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AuditLogsSourceBrokerWithGCPBrokerTestImpl ¶ added in v0.15.0
func AuditLogsSourceBrokerWithGCPBrokerTestImpl(t *testing.T, authConfig lib.AuthConfig)
func AuditLogsSourceBrokerWithPubSubChannelTestImpl ¶ added in v0.13.0
func AuditLogsSourceBrokerWithPubSubChannelTestImpl(t *testing.T, authConfig lib.AuthConfig)
func BrokerWithPubSubChannelTestImpl ¶ added in v0.11.0
func BrokerWithPubSubChannelTestImpl(t *testing.T, authConfig lib.AuthConfig)
func CloudAuditLogsSourceWithTargetTestImpl ¶ added in v0.15.0
func CloudAuditLogsSourceWithTargetTestImpl(t *testing.T, authConfig lib.AuthConfig)
func CloudBuildSourceWithTargetTestImpl ¶ added in v0.16.0
func CloudBuildSourceWithTargetTestImpl(t *testing.T, authConfig lib.AuthConfig)
CloudBuildSourceWithTargetTestImpl tests we can receive an event from a CloudBuildSource.
func CloudPubSubSourceWithTargetTestImpl ¶ added in v0.12.0
func CloudPubSubSourceWithTargetTestImpl(t *testing.T, assertMetrics bool, authConfig lib.AuthConfig)
CloudPubSubSourceWithTargetTestImpl tests we can receive an event from a CloudPubSubSource. If assertMetrics is set to true, we also assert for StackDriver metrics.
func CloudSchedulerSourceWithTargetTestImpl ¶ added in v0.12.0
func CloudSchedulerSourceWithTargetTestImpl(t *testing.T, authConfig lib.AuthConfig)
CloudSchedulerSourceWithTargetTestImpl injects a scheduler event and checks if it is in the log of the receiver.
func CloudStorageSourceWithTargetTestImpl ¶ added in v0.15.0
func CloudStorageSourceWithTargetTestImpl(t *testing.T, assertMetrics bool, authConfig lib.AuthConfig)
func GCPBrokerMetricsTestImpl ¶ added in v0.16.0
func GCPBrokerMetricsTestImpl(t *testing.T, authConfig lib.AuthConfig)
func GCPBrokerTestImpl ¶ added in v0.15.0
func GCPBrokerTestImpl(t *testing.T, authConfig lib.AuthConfig)
func GCPBrokerTracingTestImpl ¶ added in v0.16.0
func GCPBrokerTracingTestImpl(t *testing.T, authConfig lib.AuthConfig)
func PubSubSourceBrokerWithPubSubChannelTestImpl ¶ added in v0.13.0
func PubSubSourceBrokerWithPubSubChannelTestImpl(t *testing.T, authConfig lib.AuthConfig)
func PubSubSourceWithGCPBrokerTestImpl ¶ added in v0.15.0
func PubSubSourceWithGCPBrokerTestImpl(t *testing.T, authConfig lib.AuthConfig)
func PullSubscriptionWithTargetTestImpl ¶ added in v0.9.0
func PullSubscriptionWithTargetTestImpl(t *testing.T, authConfig lib.AuthConfig)
PullSubscriptionWithTargetTestImpl tests we can receive an event from a PullSubscription.
func SchedulerSourceBrokerWithPubSubChannelTestImpl ¶ added in v0.13.0
func SchedulerSourceBrokerWithPubSubChannelTestImpl(t *testing.T, authConfig lib.AuthConfig)
func SchedulerSourceWithGCPBrokerTestImpl ¶ added in v0.15.0
func SchedulerSourceWithGCPBrokerTestImpl(t *testing.T, authConfig lib.AuthConfig)
func SmokeCloudAuditLogsSourceTestImpl ¶ added in v0.16.0
func SmokeCloudAuditLogsSourceTestImpl(t *testing.T, authConfig lib.AuthConfig)
SmokeCloudAuditLogsSourceTestImpl tests if a CloudAuditLogsSource object can be created to ready state and delete a CloudAuditLogsSource resource and its underlying resources..
func SmokeCloudBuildSourceTestImpl ¶ added in v0.16.0
func SmokeCloudBuildSourceTestImpl(t *testing.T, authConfig lib.AuthConfig)
SmokeCloudBuildSourceTestImpl tests we can create a CloudBuildSource to ready state and we can delete a CloudBuildSource and its underlying resources.
func SmokeCloudPubSubSourceTestImpl ¶ added in v0.12.0
func SmokeCloudPubSubSourceTestImpl(t *testing.T, authConfig lib.AuthConfig)
SmokeCloudPubSubSourceTestImpl tests we can create a CloudPubSubSource to ready state and we can delete a CloudPubSubSource and its underlying resources.
func SmokeCloudSchedulerSourceTestImpl ¶ added in v0.16.0
func SmokeCloudSchedulerSourceTestImpl(t *testing.T, authConfig lib.AuthConfig)
SmokeCloudSchedulerSourceTestImpl tests if a CloudSchedulerSource object can be created to ready state and delete a CloudSchedulerSource resource and its underlying resources..
func SmokeCloudStorageSourceTestImpl ¶ added in v0.16.0
func SmokeCloudStorageSourceTestImpl(t *testing.T, authConfig lib.AuthConfig)
SmokeCloudStorageSourceTestImpl tests if a CloudStorageSource object can be created to ready state and delete a CloudStorageSource resource and its underlying resources..
func SmokeGCPBrokerTestImpl ¶ added in v0.16.0
func SmokeGCPBrokerTestImpl(t *testing.T, authConfig lib.AuthConfig)
SmokeGCPBrokerTestImpl tests we can create a GCPBroker to ready state and we can delete a GCPBroker and its underlying resources.
func SmokePullSubscriptionTestImpl ¶
func SmokePullSubscriptionTestImpl(t *testing.T, authConfig lib.AuthConfig)
SmokePullSubscriptionTestImpl tests we can create a pull subscription to ready state.
func SmokeTestChannelImpl ¶ added in v0.9.0
func SmokeTestChannelImpl(t *testing.T, authConfig lib.AuthConfig)
SmokeTestChannelImpl makes sure we can run tests.
func StorageSourceBrokerWithPubSubChannelTestImpl ¶ added in v0.13.0
func StorageSourceBrokerWithPubSubChannelTestImpl(t *testing.T, authConfig lib.AuthConfig)
func StorageSourceWithGCPBrokerTestImpl ¶ added in v0.15.0
func StorageSourceWithGCPBrokerTestImpl(t *testing.T, authConfig lib.AuthConfig)
Types ¶
This section is empty.