Documentation ¶
Index ¶
- func AuditLogsSourceBrokerWithPubSubChannelTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func BrokerWithPubSubChannelTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func CloudAuditLogsSourceWithTestImpl(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 CloudStorageSourceWithTestImpl(t *testing.T, assertMetrics bool, authConfig lib.AuthConfig)
- func PubSubSourceBrokerWithPubSubChannelTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func PullSubscriptionWithTargetTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func SchedulerSourceBrokerWithPubSubChannelTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func SmokeCloudPubSubSourceTestImpl(t *testing.T, authConfig lib.AuthConfig)
- func SmokeCloudSchedulerSourceSetup(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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 CloudAuditLogsSourceWithTestImpl ¶ added in v0.12.0
func CloudAuditLogsSourceWithTestImpl(t *testing.T, authConfig lib.AuthConfig)
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 CloudStorageSourceWithTestImpl ¶ added in v0.12.0
func CloudStorageSourceWithTestImpl(t *testing.T, assertMetrics bool, authConfig lib.AuthConfig)
func PubSubSourceBrokerWithPubSubChannelTestImpl ¶ added in v0.13.0
func PubSubSourceBrokerWithPubSubChannelTestImpl(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 SmokeCloudPubSubSourceTestImpl ¶ added in v0.12.0
func SmokeCloudPubSubSourceTestImpl(t *testing.T, authConfig lib.AuthConfig)
SmokeCloudPubSubSourceTestImpl tests we can create a CloudPubSubSource to ready state.
func SmokeCloudSchedulerSourceSetup ¶ added in v0.12.0
func SmokeCloudSchedulerSourceSetup(t *testing.T, authConfig lib.AuthConfig)
SmokeCloudSchedulerSourceSetup tests if a CloudSchedulerSource object can be created and be made ready.
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)
Types ¶
This section is empty.