MCPcopy Create free account

hub / github.com/GoogleCloudPlatform/golang-samples / functions

Functions5,023 in github.com/GoogleCloudPlatform/golang-samples

↓ 5 callersMethodCreateConnector
Connector methods
internal/managedkafka/fake/fake.go:230
↓ 5 callersMethodGetMessage
()
run/grpc-ping/pkg/api/v1/message.pb.go:109
↓ 5 callersFunctionOptions
(t *testing.T)
internal/managedkafka/fake/fake.go:50
↓ 5 callersFunctionRetryWithoutTest
RetryWithoutTest is a variant of Retry that does not use a testing parameter. It is meant for testing utilities that do not pass around the testing co
internal/testutil/retry.go:55
↓ 5 callersMethodURL
URL prepends the deployed service's base URL to the given path. Returns an error if the application has not been deployed.
internal/cloudrunci/cloudrunci.go:236
↓ 5 callersFunctionaddDiskConsistencyGroup
addDiskConsistencyGroup adds a disk to a consistency group for a project in a given region.
compute/disks/consistency_group_add_disk.go:28
↓ 5 callersFunctioncleanupPubsub
(t *testing.T, client *pubsub.Client, topicName, subName string)
dlp/snippets/risk/risk_test.go:36
↓ 5 callersFunctioncreateGlossary
createGlossary creates a glossary to use for other operations.
translate/v3/create_glossary.go:29
↓ 5 callersFunctioncreateProductSet
createProductSet creates a product set.
vision/product_search/create_product_set.go:30
↓ 5 callersFunctioncreateTestKey
Create a key for testing purposes.
storage/service_account/hmac/hmac_test.go:206
↓ 5 callersFunctioncreateTestVodSession
(vodConfigID string, t *testing.T)
media/videostitcher/stitcher_test.go:564
↓ 5 callersFunctiondelete
[END monitoring_uptime_check_update] [START monitoring_uptime_check_delete] delete is an example of deleting an uptime check. resourceName should be o
monitoring/uptime/uptime.go:238
↓ 5 callersFunctiondeleteGlossary
deleteGlossary deletes a glossary.
translate/v3/delete_glossary.go:29
↓ 5 callersFunctiondeleteInstance
deleteInstance sends a delete request to the Compute Engine API and waits for it to complete.
compute/delete_instance.go:28
↓ 5 callersFunctiondeleteSchema
(w io.Writer, projectID, schemaID string)
pubsub/v1samples/schemas/delete_schema.go:26
↓ 5 callersFunctiondeleteSchema
(w io.Writer, projectID, schemaID string)
pubsub/schemas/delete_schema.go:27
↓ 5 callersFunctiongenerateExampleMessages
generateExampleMessages generates a slice of serialized protobuf messages using a statically defined and compiled protocol buffer file, and returns th
bigquery/snippets/managedwriter/bigquerystorage_append_rows_pending.go:35
↓ 5 callersFunctiongetInput
getInput gets a previously-created input endpoint.
media/livestream/get_input.go:28
↓ 5 callersFunctiongetMetadata
getMetadata prints all of the object attributes.
storage/objects/get_metadata.go:28
↓ 5 callersFunctionlistReferenceImages
listReferenceImages lists reference images of a product.
vision/product_search/list_reference_images.go:31
↓ 5 callersFunctionmustGetenv
(k string)
docs/appengine/mail/mailjet/mailjet.go:42
↓ 5 callersFunctionnewClient
(t *testing.T)
language/analyze/analyze_test.go:130
↓ 5 callersMethodoperationLabel
(op string)
internal/cloudrunci/cloudrunci.go:383
↓ 5 callersFunctionprintResp
[END language_classify_text]
language/analyze/analyze.go:143
↓ 5 callersFunctionremoveDiskConsistencyGroup
removeDiskConsistencyGroup removes a disk from consistency group for a project in a given region.
compute/disks/consistency_group_remove_disk.go:28
↓ 5 callersFunctionreserveNewRegionalExternal
reserveNewRegionalExternal reserves a new regional external IP address in Google Cloud Platform.
compute/address/reserve_new_external.go:28
↓ 5 callersFunctionrunBackupScheduleSample
(t *testing.T, f backupScheduleSampleFunc, dbName string, scheduleId string, errMsg string)
spanner/spanner_snippets/spanner/integration_test.go:1477
↓ 5 callersFunctionsanitize
(s string, allowedSeparator string)
bigquery/snippets/bqtestutil/bqtestutil.go:51
↓ 5 callersFunctionsetupClientAndCities
(t *testing.T, projectID string)
firestore/query_multiple_inequality_test.go:33
↓ 5 callersFunctionstopChannel
stopChannel stops a channel.
media/livestream/stop_channel.go:28
↓ 5 callersFunctiontestRegionalSecret
(tb testing.TB, projectID string)
secretmanager/regional_samples/regional_secretmanager_test.go:79
↓ 5 callersFunctionusage
()
datastore/tasks/tasks.go:126
↓ 5 callersFunctionvalidLength
Maximum length of database name is 30 characters, so trim if the generated name is too long
spanner/spanner_snippets/spanner/integration_test.go:1756
↓ 5 callersMethodvalidate
validate confirms all required service properties are present.
internal/cloudrunci/cloudrunci.go:281
↓ 5 callersFunctionwithPool
withPool runs the given function in a transaction, saving the state of the pool if the function returns with a non-nil error.
testing/gimmeproj/main.go:197
↓ 4 callersMethodAddBook
AddBook saves a given book, assigning it a new ID.
getting-started/bookshelf/bookshelf.go:46
↓ 4 callersMethodBuild
Build builds a container image if one has not already been built. If service.Image is specified and this is directly called, it could overwrite an exi
internal/cloudrunci/cloudrunjobs.go:144
↓ 4 callersFunctionCleanup
Cleanup deletes all previous test topics/subscriptions from previous test runs. This prevents previous test failures from building up resources that c
pubsublite/internal/psltest/util.go:31
↓ 4 callersMethodCommandFlags
()
internal/cloudrunci/platform.go:26
↓ 4 callersMethodCreateHMACKey
CreateHMACKey creates a new symmetric key.
kms/kms_helpers_test.go:310
↓ 4 callersMethodDeleteBook
DeleteBook removes a given book by its ID.
getting-started/bookshelf/bookshelf.go:49
↓ 4 callersMethodDeleteCluster
(ctx context.Context, req *managedkafkapb.DeleteClusterRequest)
internal/managedkafka/fake/fake.go:88
↓ 4 callersMethodGenerateVideos
( ctx context.Context, model string, prompt string, img *genai.Image, config *genai.GenerateVideosConfig,
genai/video_generation/video_generation_examples_test.go:31
↓ 4 callersMethodGetVideosOperation
( ctx context.Context, op *genai.GenerateVideosOperation, _ *genai.GetOperationConfig, )
genai/video_generation/video_generation_examples_test.go:45
↓ 4 callersMethodPost
Post performs a POST request to a given path.
getting-started/bookshelf/internal/webtest/webtest.go:84
↓ 4 callersMethodReset
()
internal/pubsub/schemas/us-states.pb.go:52
↓ 4 callersMethodSendUpstream
(ctx context.Context, in *Request, opts ...grpc.CallOption)
run/grpc-ping/pkg/api/v1/message.pb.go:203
↓ 4 callersFunctionSkipCMEKTests
SkipCMEKTests probes whether CMEK-based tests should be skipped.
bigquery/snippets/bqtestutil/bqtestutil.go:61
↓ 4 callersMethodType
()
spanner/spanner_snippets/spanner/testdata/protos/singer.pb.go:78
↓ 4 callersMethodUpdateTopic
(ctx context.Context, req *managedkafkapb.UpdateTopicRequest)
internal/managedkafka/fake/fake.go:147
↓ 4 callersFunctionaddBigQueryExport
(t *testing.T, bigQueryExportID string)
securitycenter/bigqueryv2/bigquery_test.go:45
↓ 4 callersFunctionaddNotificationConfig
(t *testing.T, notificationConfigID string)
securitycenter/notifications/notifications_test.go:64
↓ 4 callersFunctionaddSecurityMarks
addSecurityMarks adds/updates the security marks for the assetName. Specifically, it sets "key_a" and "key_b" to "value_a" and "value_b" respectively.
securitycenter/assets/add_security_marks.go:31
↓ 4 callersFunctionassert
(buf bytes.Buffer, want string, t *testing.T)
videointelligence/video_analyze/video_analyze_test.go:30
↓ 4 callersFunctioncheckGCSFileExists
(t *testing.T, bucketName string, fileName string)
media/transcoder/transcoder_test.go:225
↓ 4 callersFunctioncleanupBigQueryExport
(t *testing.T, bigQueryExportID string)
securitycenter/bigqueryv2/bigquery_test.go:76
↓ 4 callersFunctioncleanupNotificationConfig
(t *testing.T, notificationConfigID string)
securitycenter/notifications/notifications_test.go:98
↓ 4 callersFunctioncreateDataset
createDataset creates a dataset.
healthcare/dataset_create.go:28
↓ 4 callersFunctioncreateInput
createInput creates an input endpoint. You send an input video stream to this endpoint.
media/livestream/create_input.go:29
↓ 4 callersFunctioncreateSnapshotSchedule
createSnapshotSchedule creates a snapshot schedule.
compute/snapshots/create_snapshot_schedule.go:29
↓ 4 callersFunctioncreateTestFinding
(ctx context.Context, client *securitycenter.Client, findingID string, category string)
securitycenter/findingsv2/findings_test.go:37
↓ 4 callersFunctioncreateTestMediaCDNKey
(keyID string, t *testing.T)
media/videostitcher/stitcher_test.go:464
↓ 4 callersFunctiondelete
(w io.Writer, projectID, topicID string)
pubsub/topics/delete.go:27
↓ 4 callersFunctiondeleteInstance
(projectID, zone, instance string)
compute/reservations/reservations_test.go:145
↓ 4 callersFunctiondeleteNote
deleteNote removes an existing Note from the server.
container_registry/container_analysis/delete_note.go:28
↓ 4 callersFunctiondeleteSnapshotSchedule
deleteSnapshotSchedule deletes a snapshot schedule.
compute/snapshots/delete_snapshot_schedule.go:28
↓ 4 callersFunctionerrorIfNot404
Produces a test error only in case it was NOT due to a 404. This avoids flackyness which may result from the ripper cleaning up resources.
compute/disks/disks_test.go:185
↓ 4 callersFunctiongetChannel
getChannel gets a previously-created channel.
media/livestream/get_channel.go:28
↓ 4 callersFunctiongetInstance
( ctx context.Context, projectID, zone, instanceName string, )
compute/disks/disks_test.go:77
↓ 4 callersFunctionisResourceStale
(timestamp string)
media/videostitcher/stitcher_test.go:241
↓ 4 callersFunctionlistProductSets
listProductSets lists product sets.
vision/product_search/list_product_sets.go:31
↓ 4 callersFunctionparseDatabaseName
(databaseUri string)
spanner/spanner_snippets/spanner/spanner_opencensus_capture_grpc_metric.go:87
↓ 4 callersFunctionprintSingerNames
(w io.Writer, iter *spanner.RowIterator)
spanner/spanner_snippets/spanner/pg_spanner_order_nulls.go:116
↓ 4 callersFunctionpublishMsgs
(ctx context.Context, p *pubsub.Publisher, numMsgs int)
pubsub/subscriptions/subscription_test.go:637
↓ 4 callersFunctionqueryMetadataServer
(path string)
run/service-health/main.go:587
↓ 4 callersFunctionrandomZone
()
pubsublite/admin/pubsublite_admin_test.go:469
↓ 4 callersFunctionreadHealth
(instanceId string)
run/service-health/main.go:506
↓ 4 callersFunctionserveError
(ctx context.Context, w http.ResponseWriter, err error)
docs/appengine/blobstore/complete.go:30
↓ 4 callersFunctionsetup
(ctx context.Context, t *testing.T)
firestore/listen_test.go:32
↓ 4 callersFunctionsetup
(t *testing.T)
pubsub/v1samples/schemas/schemas_test.go:52
↓ 4 callersFunctionsetup
(t *testing.T)
pubsub/schemas/schemas_test.go:53
↓ 4 callersFunctionsetupCa
Setup and teardown functions for Certificate Authority Tests
privateca/privateca_test.go:78
↓ 4 callersFunctionsetupCaPool
Setup and teardown functions for CA Pool
privateca/privateca_test.go:54
↓ 4 callersFunctionsetupTests
Setup for all tests
privateca/privateca_test.go:45
↓ 4 callersFunctiontestIamUser
(tb testing.TB)
secretmanager/secretmanager_test.go:233
↓ 4 callersMethodvalidate
validate confirms all required job properties are present.
internal/cloudrunci/cloudrunjobs.go:98
↓ 4 callersMethodversion
version returns the version that the app will be deployed to.
internal/aeintegrate/aeintegrate.go:127
↓ 3 callersFunctionAddTask
AddTask adds a task with the given description to the datastore, returning the key of the newly created entity.
datastore/tasks/add_entity.go:36
↓ 3 callersFunctionCheckMessages
Checks user messages, with the given MessageService and user id
getting-started/devflowapp/services/services.go:95
↓ 3 callersMethodClean
Clean deletes the created Cloud Run service.
internal/cloudrunci/cloudrunjobs.go:184
↓ 3 callersMethodCleanup
Cleanup removes the built binary.
internal/testutil/runmain.go:67
↓ 3 callersMethodCommonGCloudFlags
()
internal/cloudrunci/cloudrunjobs.go:89
↓ 3 callersMethodCreateCluster
(ctx context.Context, req *managedkafkapb.CreateClusterRequest)
internal/managedkafka/fake/fake.go:74
↓ 3 callersFunctionCreateIDToken
CreateIDToken generates an ID token for requests to the fully managed platform. In the future the URL of the targeted service will be used to scope th
internal/cloudrunci/gcloud.go:103
↓ 3 callersMethodCreateSymmetricKey
CreateSymmetricKey creates a new symmetric key.
kms/kms_helpers_test.go:286
↓ 3 callersFunctionDeleteTask
DeleteTask deletes the task with the given ID.
datastore/tasks/delete_entity.go:26
↓ 3 callersFunctionDetectIntentAudio
[END dialogflow_detect_intent_text] [START dialogflow_detect_intent_audio]
dialogflow/detect_intent/detect_intent.go:61
↓ 3 callersMethodGetBook
GetBook retrieves a book by its ID.
getting-started/bookshelf/bookshelf.go:43
↓ 3 callersMethodGetMatchCount
Accepts a query string and returns the number of lines containing that.
profiler/shakesapp/shakesapp/shakesapp.pb.go:143
↓ 3 callersMethodGetTopic
(ctx context.Context, req *managedkafkapb.GetTopicRequest)
internal/managedkafka/fake/fake.go:133
← previousnext →201–300 of 5,023, ranked by callers