Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/GoogleCloudPlatform/golang-samples
/ functions
Functions
5,023 in github.com/GoogleCloudPlatform/golang-samples
⨍
Functions
5,023
◇
Types & classes
329
↓ 5 callers
Method
CreateConnector
Connector methods
internal/managedkafka/fake/fake.go:230
↓ 5 callers
Method
GetMessage
()
run/grpc-ping/pkg/api/v1/message.pb.go:109
↓ 5 callers
Function
Options
(t *testing.T)
internal/managedkafka/fake/fake.go:50
↓ 5 callers
Function
RetryWithoutTest
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 callers
Method
URL
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 callers
Function
addDiskConsistencyGroup
addDiskConsistencyGroup adds a disk to a consistency group for a project in a given region.
compute/disks/consistency_group_add_disk.go:28
↓ 5 callers
Function
cleanupPubsub
(t *testing.T, client *pubsub.Client, topicName, subName string)
dlp/snippets/risk/risk_test.go:36
↓ 5 callers
Function
createGlossary
createGlossary creates a glossary to use for other operations.
translate/v3/create_glossary.go:29
↓ 5 callers
Function
createProductSet
createProductSet creates a product set.
vision/product_search/create_product_set.go:30
↓ 5 callers
Function
createTestKey
Create a key for testing purposes.
storage/service_account/hmac/hmac_test.go:206
↓ 5 callers
Function
createTestVodSession
(vodConfigID string, t *testing.T)
media/videostitcher/stitcher_test.go:564
↓ 5 callers
Function
delete
[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 callers
Function
deleteGlossary
deleteGlossary deletes a glossary.
translate/v3/delete_glossary.go:29
↓ 5 callers
Function
deleteInstance
deleteInstance sends a delete request to the Compute Engine API and waits for it to complete.
compute/delete_instance.go:28
↓ 5 callers
Function
deleteSchema
(w io.Writer, projectID, schemaID string)
pubsub/v1samples/schemas/delete_schema.go:26
↓ 5 callers
Function
deleteSchema
(w io.Writer, projectID, schemaID string)
pubsub/schemas/delete_schema.go:27
↓ 5 callers
Function
generateExampleMessages
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 callers
Function
getInput
getInput gets a previously-created input endpoint.
media/livestream/get_input.go:28
↓ 5 callers
Function
getMetadata
getMetadata prints all of the object attributes.
storage/objects/get_metadata.go:28
↓ 5 callers
Function
listReferenceImages
listReferenceImages lists reference images of a product.
vision/product_search/list_reference_images.go:31
↓ 5 callers
Function
mustGetenv
(k string)
docs/appengine/mail/mailjet/mailjet.go:42
↓ 5 callers
Function
newClient
(t *testing.T)
language/analyze/analyze_test.go:130
↓ 5 callers
Method
operationLabel
(op string)
internal/cloudrunci/cloudrunci.go:383
↓ 5 callers
Function
printResp
[END language_classify_text]
language/analyze/analyze.go:143
↓ 5 callers
Function
removeDiskConsistencyGroup
removeDiskConsistencyGroup removes a disk from consistency group for a project in a given region.
compute/disks/consistency_group_remove_disk.go:28
↓ 5 callers
Function
reserveNewRegionalExternal
reserveNewRegionalExternal reserves a new regional external IP address in Google Cloud Platform.
compute/address/reserve_new_external.go:28
↓ 5 callers
Function
runBackupScheduleSample
(t *testing.T, f backupScheduleSampleFunc, dbName string, scheduleId string, errMsg string)
spanner/spanner_snippets/spanner/integration_test.go:1477
↓ 5 callers
Function
sanitize
(s string, allowedSeparator string)
bigquery/snippets/bqtestutil/bqtestutil.go:51
↓ 5 callers
Function
setupClientAndCities
(t *testing.T, projectID string)
firestore/query_multiple_inequality_test.go:33
↓ 5 callers
Function
stopChannel
stopChannel stops a channel.
media/livestream/stop_channel.go:28
↓ 5 callers
Function
testRegionalSecret
(tb testing.TB, projectID string)
secretmanager/regional_samples/regional_secretmanager_test.go:79
↓ 5 callers
Function
usage
()
datastore/tasks/tasks.go:126
↓ 5 callers
Function
validLength
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 callers
Method
validate
validate confirms all required service properties are present.
internal/cloudrunci/cloudrunci.go:281
↓ 5 callers
Function
withPool
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 callers
Method
AddBook
AddBook saves a given book, assigning it a new ID.
getting-started/bookshelf/bookshelf.go:46
↓ 4 callers
Method
Build
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 callers
Function
Cleanup
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 callers
Method
CommandFlags
()
internal/cloudrunci/platform.go:26
↓ 4 callers
Method
CreateHMACKey
CreateHMACKey creates a new symmetric key.
kms/kms_helpers_test.go:310
↓ 4 callers
Method
DeleteBook
DeleteBook removes a given book by its ID.
getting-started/bookshelf/bookshelf.go:49
↓ 4 callers
Method
DeleteCluster
(ctx context.Context, req *managedkafkapb.DeleteClusterRequest)
internal/managedkafka/fake/fake.go:88
↓ 4 callers
Method
GenerateVideos
( ctx context.Context, model string, prompt string, img *genai.Image, config *genai.GenerateVideosConfig,
genai/video_generation/video_generation_examples_test.go:31
↓ 4 callers
Method
GetVideosOperation
( ctx context.Context, op *genai.GenerateVideosOperation, _ *genai.GetOperationConfig, )
genai/video_generation/video_generation_examples_test.go:45
↓ 4 callers
Method
Post
Post performs a POST request to a given path.
getting-started/bookshelf/internal/webtest/webtest.go:84
↓ 4 callers
Method
Reset
()
internal/pubsub/schemas/us-states.pb.go:52
↓ 4 callers
Method
SendUpstream
(ctx context.Context, in *Request, opts ...grpc.CallOption)
run/grpc-ping/pkg/api/v1/message.pb.go:203
↓ 4 callers
Function
SkipCMEKTests
SkipCMEKTests probes whether CMEK-based tests should be skipped.
bigquery/snippets/bqtestutil/bqtestutil.go:61
↓ 4 callers
Method
Type
()
spanner/spanner_snippets/spanner/testdata/protos/singer.pb.go:78
↓ 4 callers
Method
UpdateTopic
(ctx context.Context, req *managedkafkapb.UpdateTopicRequest)
internal/managedkafka/fake/fake.go:147
↓ 4 callers
Function
addBigQueryExport
(t *testing.T, bigQueryExportID string)
securitycenter/bigqueryv2/bigquery_test.go:45
↓ 4 callers
Function
addNotificationConfig
(t *testing.T, notificationConfigID string)
securitycenter/notifications/notifications_test.go:64
↓ 4 callers
Function
addSecurityMarks
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 callers
Function
assert
(buf bytes.Buffer, want string, t *testing.T)
videointelligence/video_analyze/video_analyze_test.go:30
↓ 4 callers
Function
checkGCSFileExists
(t *testing.T, bucketName string, fileName string)
media/transcoder/transcoder_test.go:225
↓ 4 callers
Function
cleanupBigQueryExport
(t *testing.T, bigQueryExportID string)
securitycenter/bigqueryv2/bigquery_test.go:76
↓ 4 callers
Function
cleanupNotificationConfig
(t *testing.T, notificationConfigID string)
securitycenter/notifications/notifications_test.go:98
↓ 4 callers
Function
createDataset
createDataset creates a dataset.
healthcare/dataset_create.go:28
↓ 4 callers
Function
createInput
createInput creates an input endpoint. You send an input video stream to this endpoint.
media/livestream/create_input.go:29
↓ 4 callers
Function
createSnapshotSchedule
createSnapshotSchedule creates a snapshot schedule.
compute/snapshots/create_snapshot_schedule.go:29
↓ 4 callers
Function
createTestFinding
(ctx context.Context, client *securitycenter.Client, findingID string, category string)
securitycenter/findingsv2/findings_test.go:37
↓ 4 callers
Function
createTestMediaCDNKey
(keyID string, t *testing.T)
media/videostitcher/stitcher_test.go:464
↓ 4 callers
Function
delete
(w io.Writer, projectID, topicID string)
pubsub/topics/delete.go:27
↓ 4 callers
Function
deleteInstance
(projectID, zone, instance string)
compute/reservations/reservations_test.go:145
↓ 4 callers
Function
deleteNote
deleteNote removes an existing Note from the server.
container_registry/container_analysis/delete_note.go:28
↓ 4 callers
Function
deleteSnapshotSchedule
deleteSnapshotSchedule deletes a snapshot schedule.
compute/snapshots/delete_snapshot_schedule.go:28
↓ 4 callers
Function
errorIfNot404
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 callers
Function
getChannel
getChannel gets a previously-created channel.
media/livestream/get_channel.go:28
↓ 4 callers
Function
getInstance
( ctx context.Context, projectID, zone, instanceName string, )
compute/disks/disks_test.go:77
↓ 4 callers
Function
isResourceStale
(timestamp string)
media/videostitcher/stitcher_test.go:241
↓ 4 callers
Function
listProductSets
listProductSets lists product sets.
vision/product_search/list_product_sets.go:31
↓ 4 callers
Function
parseDatabaseName
(databaseUri string)
spanner/spanner_snippets/spanner/spanner_opencensus_capture_grpc_metric.go:87
↓ 4 callers
Function
printSingerNames
(w io.Writer, iter *spanner.RowIterator)
spanner/spanner_snippets/spanner/pg_spanner_order_nulls.go:116
↓ 4 callers
Function
publishMsgs
(ctx context.Context, p *pubsub.Publisher, numMsgs int)
pubsub/subscriptions/subscription_test.go:637
↓ 4 callers
Function
queryMetadataServer
(path string)
run/service-health/main.go:587
↓ 4 callers
Function
randomZone
()
pubsublite/admin/pubsublite_admin_test.go:469
↓ 4 callers
Function
readHealth
(instanceId string)
run/service-health/main.go:506
↓ 4 callers
Function
serveError
(ctx context.Context, w http.ResponseWriter, err error)
docs/appengine/blobstore/complete.go:30
↓ 4 callers
Function
setup
(ctx context.Context, t *testing.T)
firestore/listen_test.go:32
↓ 4 callers
Function
setup
(t *testing.T)
pubsub/v1samples/schemas/schemas_test.go:52
↓ 4 callers
Function
setup
(t *testing.T)
pubsub/schemas/schemas_test.go:53
↓ 4 callers
Function
setupCa
Setup and teardown functions for Certificate Authority Tests
privateca/privateca_test.go:78
↓ 4 callers
Function
setupCaPool
Setup and teardown functions for CA Pool
privateca/privateca_test.go:54
↓ 4 callers
Function
setupTests
Setup for all tests
privateca/privateca_test.go:45
↓ 4 callers
Function
testIamUser
(tb testing.TB)
secretmanager/secretmanager_test.go:233
↓ 4 callers
Method
validate
validate confirms all required job properties are present.
internal/cloudrunci/cloudrunjobs.go:98
↓ 4 callers
Method
version
version returns the version that the app will be deployed to.
internal/aeintegrate/aeintegrate.go:127
↓ 3 callers
Function
AddTask
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 callers
Function
CheckMessages
Checks user messages, with the given MessageService and user id
getting-started/devflowapp/services/services.go:95
↓ 3 callers
Method
Clean
Clean deletes the created Cloud Run service.
internal/cloudrunci/cloudrunjobs.go:184
↓ 3 callers
Method
Cleanup
Cleanup removes the built binary.
internal/testutil/runmain.go:67
↓ 3 callers
Method
CommonGCloudFlags
()
internal/cloudrunci/cloudrunjobs.go:89
↓ 3 callers
Method
CreateCluster
(ctx context.Context, req *managedkafkapb.CreateClusterRequest)
internal/managedkafka/fake/fake.go:74
↓ 3 callers
Function
CreateIDToken
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 callers
Method
CreateSymmetricKey
CreateSymmetricKey creates a new symmetric key.
kms/kms_helpers_test.go:286
↓ 3 callers
Function
DeleteTask
DeleteTask deletes the task with the given ID.
datastore/tasks/delete_entity.go:26
↓ 3 callers
Function
DetectIntentAudio
[END dialogflow_detect_intent_text] [START dialogflow_detect_intent_audio]
dialogflow/detect_intent/detect_intent.go:61
↓ 3 callers
Method
GetBook
GetBook retrieves a book by its ID.
getting-started/bookshelf/bookshelf.go:43
↓ 3 callers
Method
GetMatchCount
Accepts a query string and returns the number of lines containing that.
profiler/shakesapp/shakesapp/shakesapp.pb.go:143
↓ 3 callers
Method
GetTopic
(ctx context.Context, req *managedkafkapb.GetTopicRequest)
internal/managedkafka/fake/fake.go:133
← previous
next →
201–300 of 5,023, ranked by callers