| /dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | committer.go | 43 type committer struct { struct
45 cursorClient *vkit.CursorClient
48 metadata pubsubMetadata
51 stream *retryableStream
52 acks *ackTracker
54 pollCommits *periodicTask
55 flushPending *sync.Cond
56 enableCommits bool
58 abstractService
92 func (c *committer) Start() {
[all …]
|
| /dports/net/drive/drive-0.4.0/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | committer.go | 43 type committer struct { struct
45 cursorClient *vkit.CursorClient
48 metadata pubsubMetadata
51 stream *retryableStream
52 acks *ackTracker
54 pollCommits *periodicTask
55 flushPending *sync.Cond
56 enableCommits bool
58 abstractService
92 func (c *committer) Start() {
[all …]
|
| /dports/net/rclone/rclone-1.57.0/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | committer.go | 43 type committer struct { struct
45 cursorClient *vkit.CursorClient
48 metadata pubsubMetadata
51 stream *retryableStream
52 acks *ackTracker
54 pollCommits *periodicTask
55 flushPending *sync.Cond
56 enableCommits bool
58 abstractService
92 func (c *committer) Start() {
[all …]
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | committer.go | 43 type committer struct { struct
45 cursorClient *vkit.CursorClient
48 metadata pubsubMetadata
51 stream *retryableStream
52 acks *ackTracker
54 pollCommits *periodicTask
55 flushPending *sync.Cond
56 enableCommits bool
58 abstractService
92 func (c *committer) Start() {
[all …]
|
| /dports/www/gohugo/hugo-0.91.2/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | committer.go | 43 type committer struct { struct
45 cursorClient *vkit.CursorClient
48 metadata pubsubMetadata
51 stream *retryableStream
52 acks *ackTracker
54 pollCommits *periodicTask
55 flushPending *sync.Cond
56 enableCommits bool
58 abstractService
92 func (c *committer) Start() {
[all …]
|
| /dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | committer.go | 43 type committer struct { struct
45 cursorClient *vkit.CursorClient
48 metadata pubsubMetadata
51 stream *retryableStream
52 acks *ackTracker
54 pollCommits *periodicTask
55 flushPending *sync.Cond
56 enableCommits bool
58 abstractService
92 func (c *committer) Start() {
[all …]
|
| /dports/sysutils/restic/restic-0.12.1/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | committer.go | 43 type committer struct { struct
45 cursorClient *vkit.CursorClient
48 metadata pubsubMetadata
51 stream *retryableStream
52 acks *ackTracker
54 pollCommits *periodicTask
55 flushPending *sync.Cond
56 enableCommits bool
58 abstractService
92 func (c *committer) Start() {
[all …]
|
| /dports/sysutils/restic/google-cloud-go-storage-v1.16.0/pubsublite/internal/wire/ |
| H A D | committer.go | 43 type committer struct { struct
45 cursorClient *vkit.CursorClient
48 metadata pubsubMetadata
51 stream *retryableStream
52 acks *ackTracker
54 pollCommits *periodicTask
55 flushPending *sync.Cond
56 enableCommits bool
58 abstractService
92 func (c *committer) Start() {
[all …]
|
| /dports/www/tusd/tusd-1.8.0/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | committer.go | 43 type committer struct { struct
45 cursorClient *vkit.CursorClient
48 metadata pubsubMetadata
51 stream *retryableStream
52 acks *ackTracker
54 pollCommits *periodicTask
55 flushPending *sync.Cond
56 enableCommits bool
58 abstractService
92 func (c *committer) Start() {
[all …]
|
| /dports/www/tusd/google-cloud-go-storage-v1.18.2/pubsublite/internal/wire/ |
| H A D | committer.go | 43 type committer struct { struct
45 cursorClient *vkit.CursorClient
48 metadata pubsubMetadata
51 stream *retryableStream
52 acks *ackTracker
54 pollCommits *periodicTask
55 flushPending *sync.Cond
56 enableCommits bool
58 abstractService
92 func (c *committer) Start() {
[all …]
|
| /dports/www/grafana8/google-cloud-go-storage-v1.14.0/pubsublite/internal/wire/ |
| H A D | committer.go | 42 type committer struct { struct
44 cursorClient *vkit.CursorClient
45 subscription subscriptionPartition
47 metadata pubsubMetadata
50 stream *retryableStream
51 acks *ackTracker
53 pollCommits *periodicTask
55 abstractService
88 func (c *committer) Start() {
100 func (c *committer) Stop() {
[all …]
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | committer.go | 42 type committer struct { struct
44 cursorClient *vkit.CursorClient
45 subscription subscriptionPartition
47 metadata pubsubMetadata
50 stream *retryableStream
51 acks *ackTracker
53 pollCommits *periodicTask
55 abstractService
88 func (c *committer) Start() {
100 func (c *committer) Stop() {
[all …]
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | committer.go | 42 type committer struct { struct
44 cursorClient *vkit.CursorClient
47 metadata pubsubMetadata
50 stream *retryableStream
51 acks *ackTracker
53 pollCommits *periodicTask
54 enableCommits bool
56 abstractService
89 func (c *committer) Start() {
101 func (c *committer) Stop() {
[all …]
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | committer.go | 42 type committer struct { struct
44 cursorClient *vkit.CursorClient
47 metadata pubsubMetadata
50 stream *retryableStream
51 acks *ackTracker
53 pollCommits *periodicTask
54 enableCommits bool
56 abstractService
89 func (c *committer) Start() {
101 func (c *committer) Stop() {
[all …]
|
| /dports/databases/litestream/litestream-0.3.6/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | committer.go | 42 type committer struct { struct
44 cursorClient *vkit.CursorClient
47 metadata pubsubMetadata
50 stream *retryableStream
51 acks *ackTracker
53 pollCommits *periodicTask
54 enableCommits bool
56 abstractService
89 func (c *committer) Start() {
101 func (c *committer) Stop() {
[all …]
|
| /dports/databases/litestream/google-cloud-go-storage-v1.15.0/pubsublite/internal/wire/ |
| H A D | committer.go | 42 type committer struct { struct
44 cursorClient *vkit.CursorClient
47 metadata pubsubMetadata
50 stream *retryableStream
51 acks *ackTracker
53 pollCommits *periodicTask
54 enableCommits bool
56 abstractService
89 func (c *committer) Start() {
101 func (c *committer) Stop() {
[all …]
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/trie/ |
| H A D | committer.go | 46 type committer struct { struct
47 tmp sliceBuffer
48 sha crypto.KeccakState
50 onleaf LeafCallback
51 leafCh chan *leaf
69 func returnCommitterToPool(h *committer) {
76 func (c *committer) Commit(n node, db *Database) (hashNode, int, error) {
88 func (c *committer) commit(n node, db *Database) (node, int, error) {
176 func (c *committer) store(n node, db *Database) node {
212 func (c *committer) commitLoop(db *Database) {
[all …]
|
| /dports/www/py-aiohttp/aiohttp-3.7.4.post0/docs/ |
| H A D | contributing.rst | 319 .. _GitHub: https://github.com/aio-libs/aiohttp
321 .. _ipdb: https://pypi.python.org/pypi/ipdb
323 .. _black: https://pypi.python.org/pypi/black
325 .. _isort: https://pypi.python.org/pypi/isort
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/devtools-frontend/src/front_end/third_party/lit-html/package/src/lib/ |
| H A D | default-template-processor.ts | 42 const committer = new PropertyCommitter(element, name.slice(1), strings); constant
51 const committer = new AttributeCommitter(element, name, strings); constant
|
| /dports/math/vtk6/VTK-6.2.0/Utilities/Maintenance/release/ |
| H A D | prep-emails.py | 26 committer = '' variable
38 committer = email.group(1) variable
|
| /dports/math/vtk8/VTK-8.2.0/Utilities/Maintenance/release/ |
| H A D | prep-emails.py | 26 committer = '' variable
38 committer = email.group(1) variable
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/devtools-frontend/src/front_end/third_party/lit-html/package/src/lib/ |
| H A D | default-template-processor.ts | 38 const committer = new PropertyCommitter(element, name.slice(1), strings); constant
47 const committer = new AttributeCommitter(element, name, strings); constant
|
| /dports/net/megacmd/MEGAcmd-1.4.1_Win/sdk/src/ |
| H A D | transfer.cpp | 377 void Transfer::removeTransferFile(error e, File* f, DBTableTransactionCommitter* committer) in removeTransferFile()
389 void Transfer::failed(const Error& e, DBTableTransactionCommitter& committer, dstime timeleft) in failed()
584 void Transfer::complete(DBTableTransactionCommitter& committer) in complete()
1789 void TransferList::movetofirst(Transfer *transfer, DBTableTransactionCommitter& committer) in movetofirst()
1794 void TransferList::movetofirst(transfer_list::iterator it, DBTableTransactionCommitter& committer) in movetofirst()
1800 void TransferList::movetolast(Transfer *transfer, DBTableTransactionCommitter& committer) in movetolast()
1805 void TransferList::movetolast(transfer_list::iterator it, DBTableTransactionCommitter& committer) in movetolast()
1811 void TransferList::moveup(Transfer *transfer, DBTableTransactionCommitter& committer) in moveup()
1825 void TransferList::moveup(transfer_list::iterator it, DBTableTransactionCommitter& committer) in moveup()
1836 void TransferList::movedown(Transfer *transfer, DBTableTransactionCommitter& committer) in movedown()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-distcp/src/test/java/org/apache/hadoop/tools/mapred/ |
| H A D | TestCopyCommitter.java | 113 OutputCommitter committer = new CopyCommitter(null, taskAttemptContext); in testNoCommitAction() local
138 OutputCommitter committer = new CopyCommitter(null, taskAttemptContext); in testPreserveStatus() local
189 OutputCommitter committer = new CopyCommitter(null, taskAttemptContext); in testDeleteMissing() local
246 OutputCommitter committer = new CopyCommitter(null, taskAttemptContext); in testDeleteMissingFlatInterleavedFiles() local
311 OutputCommitter committer = new CopyCommitter(null, taskAttemptContext); in testAtomicCommitMissingFinal() local
352 OutputCommitter committer = new CopyCommitter(null, taskAttemptContext); in testAtomicCommitExistingFinal() local
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/tools/distcp2/mapred/ |
| H A D | TestCopyCommitter.java | 127 OutputCommitter committer = new CopyCommitter(null, taskAttemptContext); in testNoCommitAction() local
152 OutputCommitter committer = new CopyCommitter(null, taskAttemptContext); in testPreserveStatus() local
201 OutputCommitter committer = new CopyCommitter(null, taskAttemptContext); in testDeleteMissing() local
258 OutputCommitter committer = new CopyCommitter(null, taskAttemptContext); in testDeleteMissingFlatInterleavedFiles() local
323 OutputCommitter committer = new CopyCommitter(null, taskAttemptContext); in testAtomicCommitMissingFinal() local
363 OutputCommitter committer = new CopyCommitter(null, taskAttemptContext); in testAtomicCommitExistingFinal() local
|