crash.software
Projects
Pull Requests
Issues
Builds
scorecard
Code
Files
Commits
Branches
Tags
Pull Requests
Code Comments
Code Compare
Issues
List
Boards
Milestones
Builds
Statistics
Contributions
Source Lines
Child Projects
Projects
STRLCPY
scorecard
Files
🤬
Sign In
0c090b3c
ROOT
/
cron
/
internal
/
pubsub
/
subscriber_gcs.go
Search
History
141 lines
|
ISO-8859-1
|
3 KB
Blame
Outline
2
4
8
No wrap
Soft wrap
Outline
maxMessagesToPull
ackDeadlineExtensionInSec
gracePeriodInSec
gcpPubsubPrefix
gcsSubscriber
ctx
:
context.Context
done
:
chan bool
client
:
*pubsub.SubscriberClient
subscriptionURL
:
string
recvdAckID
:
string
createGCSSubscriber
(ctx context.Context, subscriptionURL string)
:
(*gcsSubscriber, error)
*gcsSubscriber
extendAckDeadline
()
SynchronousPull
()
:
(*data.ScorecardBatchRequest, error)
Ack
()
Nack
()
Close
()
:
error
All occurrences
Please wait...
Page is in error, reload to recover