streamVerifier (reference) in projects: dports

Project(s)

Full Search
Definition
Symbol
File Path
History
Type

Searched refs:streamVerifier (Results 1 – 19 of 19) sorted by relevance

/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/cloud.google.com/go/google-cloud-go-0.72.0/pubsublite/internal/test/
H A D	mock.go	49 AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) 51 AddSubscribeStream(subscription string, partition int, streamVerifier RPCVerifier) 53 AddCommitStream(subscription string, partition int, streamVerifier RPCVerifier) 56 AddAssignmentStream(subscription string, streamVerifier RPCVerifier) 230 func (s mockLiteServer) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier)… 233 s.publishVerifiers.Push(key(topic, partition), streamVerifier) 239 s.subscribeVerifiers.Push(key(subscription, partition), streamVerifier) 242 func (s mockLiteServer) AddCommitStream(subscription string, partition int, streamVerifier RPCVer… 245 s.commitVerifiers.Push(key(subscription, partition), streamVerifier) 248 func (s mockLiteServer) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { [all …]
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/cloud.google.com/go/pubsublite/internal/test/
H A D	mock.go	49 AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) 51 AddSubscribeStream(subscription string, partition int, streamVerifier RPCVerifier) 53 AddCommitStream(subscription string, partition int, streamVerifier RPCVerifier) 56 AddAssignmentStream(subscription string, streamVerifier RPCVerifier) 230 func (s mockLiteServer) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier)… 233 s.publishVerifiers.Push(key(topic, partition), streamVerifier) 239 s.subscribeVerifiers.Push(key(subscription, partition), streamVerifier) 242 func (s mockLiteServer) AddCommitStream(subscription string, partition int, streamVerifier RPCVer… 245 s.commitVerifiers.Push(key(subscription, partition), streamVerifier) 248 func (s mockLiteServer) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { [all …]
/dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/pubsublite/internal/test/
H A D	verifier.go	346 func (tv Verifiers) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) { 349 tv.streamVerifiers.Push(keyPartition(publishStreamType, topic, partition), streamVerifier) 353 func (tv Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier RPCVeri… 356 tv.streamVerifiers.Push(keyPartition(subscribeStreamType, subscription, partition), streamVerifier) 360 func (tv Verifiers) AddCommitStream(subscription string, partition int, streamVerifier RPCVerifie… 363 tv.streamVerifiers.Push(keyPartition(commitStreamType, subscription, partition), streamVerifier) 367 func (tv Verifiers) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { 370 tv.streamVerifiers.Push(key(assignmentStreamType, subscription), streamVerifier)
/dports/net/drive/drive-0.4.0/vendor/cloud.google.com/go/pubsublite/internal/test/
H A D	verifier.go	346 func (tv Verifiers) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) { 349 tv.streamVerifiers.Push(keyPartition(publishStreamType, topic, partition), streamVerifier) 353 func (tv Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier RPCVeri… 356 tv.streamVerifiers.Push(keyPartition(subscribeStreamType, subscription, partition), streamVerifier) 360 func (tv Verifiers) AddCommitStream(subscription string, partition int, streamVerifier RPCVerifie… 363 tv.streamVerifiers.Push(keyPartition(commitStreamType, subscription, partition), streamVerifier) 367 func (tv Verifiers) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { 370 tv.streamVerifiers.Push(key(assignmentStreamType, subscription), streamVerifier)
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/pubsublite/internal/test/
H A D	verifier.go	336 func (tv Verifiers) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) { 339 tv.streamVerifiers.Push(keyPartition(publishStreamType, topic, partition), streamVerifier) 343 func (tv Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier RPCVeri… 346 tv.streamVerifiers.Push(keyPartition(subscribeStreamType, subscription, partition), streamVerifier) 350 func (tv Verifiers) AddCommitStream(subscription string, partition int, streamVerifier RPCVerifie… 353 tv.streamVerifiers.Push(keyPartition(commitStreamType, subscription, partition), streamVerifier) 357 func (tv Verifiers) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { 360 tv.streamVerifiers.Push(key(assignmentStreamType, subscription), streamVerifier)
/dports/net/rclone/rclone-1.57.0/vendor/cloud.google.com/go/pubsublite/internal/test/
H A D	verifier.go	346 func (tv Verifiers) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) { 349 tv.streamVerifiers.Push(keyPartition(publishStreamType, topic, partition), streamVerifier) 353 func (tv Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier RPCVeri… 356 tv.streamVerifiers.Push(keyPartition(subscribeStreamType, subscription, partition), streamVerifier) 360 func (tv Verifiers) AddCommitStream(subscription string, partition int, streamVerifier RPCVerifie… 363 tv.streamVerifiers.Push(keyPartition(commitStreamType, subscription, partition), streamVerifier) 367 func (tv Verifiers) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { 370 tv.streamVerifiers.Push(key(assignmentStreamType, subscription), streamVerifier)
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/cloud.google.com/go/pubsublite/internal/test/
H A D	verifier.go	346 func (tv Verifiers) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) { 349 tv.streamVerifiers.Push(keyPartition(publishStreamType, topic, partition), streamVerifier) 353 func (tv Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier RPCVeri… 356 tv.streamVerifiers.Push(keyPartition(subscribeStreamType, subscription, partition), streamVerifier) 360 func (tv Verifiers) AddCommitStream(subscription string, partition int, streamVerifier RPCVerifie… 363 tv.streamVerifiers.Push(keyPartition(commitStreamType, subscription, partition), streamVerifier) 367 func (tv Verifiers) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { 370 tv.streamVerifiers.Push(key(assignmentStreamType, subscription), streamVerifier)
/dports/www/gohugo/hugo-0.91.2/vendor/cloud.google.com/go/pubsublite/internal/test/
H A D	verifier.go	346 func (tv Verifiers) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) { 349 tv.streamVerifiers.Push(keyPartition(publishStreamType, topic, partition), streamVerifier) 353 func (tv Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier RPCVeri… 356 tv.streamVerifiers.Push(keyPartition(subscribeStreamType, subscription, partition), streamVerifier) 360 func (tv Verifiers) AddCommitStream(subscription string, partition int, streamVerifier RPCVerifie… 363 tv.streamVerifiers.Push(keyPartition(commitStreamType, subscription, partition), streamVerifier) 367 func (tv Verifiers) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { 370 tv.streamVerifiers.Push(key(assignmentStreamType, subscription), streamVerifier)
/dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/pubsublite/internal/test/
H A D	verifier.go	346 func (tv Verifiers) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) { 349 tv.streamVerifiers.Push(keyPartition(publishStreamType, topic, partition), streamVerifier) 353 func (tv Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier RPCVeri… 356 tv.streamVerifiers.Push(keyPartition(subscribeStreamType, subscription, partition), streamVerifier) 360 func (tv Verifiers) AddCommitStream(subscription string, partition int, streamVerifier RPCVerifie… 363 tv.streamVerifiers.Push(keyPartition(commitStreamType, subscription, partition), streamVerifier) 367 func (tv Verifiers) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { 370 tv.streamVerifiers.Push(key(assignmentStreamType, subscription), streamVerifier)
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/cloud.google.com/go/pubsublite/internal/test/
H A D	verifier.go	336 func (tv Verifiers) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) { 339 tv.streamVerifiers.Push(keyPartition(publishStreamType, topic, partition), streamVerifier) 343 func (tv Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier RPCVeri… 346 tv.streamVerifiers.Push(keyPartition(subscribeStreamType, subscription, partition), streamVerifier) 350 func (tv Verifiers) AddCommitStream(subscription string, partition int, streamVerifier RPCVerifie… 353 tv.streamVerifiers.Push(keyPartition(commitStreamType, subscription, partition), streamVerifier) 357 func (tv Verifiers) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { 360 tv.streamVerifiers.Push(key(assignmentStreamType, subscription), streamVerifier)
/dports/sysutils/restic/restic-0.12.1/vendor/cloud.google.com/go/pubsublite/internal/test/
H A D	verifier.go	346 func (tv Verifiers) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) { 349 tv.streamVerifiers.Push(keyPartition(publishStreamType, topic, partition), streamVerifier) 353 func (tv Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier RPCVeri… 356 tv.streamVerifiers.Push(keyPartition(subscribeStreamType, subscription, partition), streamVerifier) 360 func (tv Verifiers) AddCommitStream(subscription string, partition int, streamVerifier RPCVerifie… 363 tv.streamVerifiers.Push(keyPartition(commitStreamType, subscription, partition), streamVerifier) 367 func (tv Verifiers) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { 370 tv.streamVerifiers.Push(key(assignmentStreamType, subscription), streamVerifier)
/dports/sysutils/restic/google-cloud-go-storage-v1.16.0/pubsublite/internal/test/
H A D	verifier.go	346 func (tv Verifiers) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) { 349 tv.streamVerifiers.Push(keyPartition(publishStreamType, topic, partition), streamVerifier) 353 func (tv Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier RPCVeri… 356 tv.streamVerifiers.Push(keyPartition(subscribeStreamType, subscription, partition), streamVerifier) 360 func (tv Verifiers) AddCommitStream(subscription string, partition int, streamVerifier RPCVerifie… 363 tv.streamVerifiers.Push(keyPartition(commitStreamType, subscription, partition), streamVerifier) 367 func (tv Verifiers) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { 370 tv.streamVerifiers.Push(key(assignmentStreamType, subscription), streamVerifier)
/dports/databases/litestream/litestream-0.3.6/vendor/cloud.google.com/go/pubsublite/internal/test/
H A D	verifier.go	336 func (tv Verifiers) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) { 339 tv.streamVerifiers.Push(keyPartition(publishStreamType, topic, partition), streamVerifier) 343 func (tv Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier RPCVeri… 346 tv.streamVerifiers.Push(keyPartition(subscribeStreamType, subscription, partition), streamVerifier) 350 func (tv Verifiers) AddCommitStream(subscription string, partition int, streamVerifier RPCVerifie… 353 tv.streamVerifiers.Push(keyPartition(commitStreamType, subscription, partition), streamVerifier) 357 func (tv Verifiers) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { 360 tv.streamVerifiers.Push(key(assignmentStreamType, subscription), streamVerifier)
/dports/www/tusd/tusd-1.8.0/vendor/cloud.google.com/go/pubsublite/internal/test/
H A D	verifier.go	346 func (tv Verifiers) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) { 349 tv.streamVerifiers.Push(keyPartition(publishStreamType, topic, partition), streamVerifier) 353 func (tv Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier RPCVeri… 356 tv.streamVerifiers.Push(keyPartition(subscribeStreamType, subscription, partition), streamVerifier) 360 func (tv Verifiers) AddCommitStream(subscription string, partition int, streamVerifier RPCVerifie… 363 tv.streamVerifiers.Push(keyPartition(commitStreamType, subscription, partition), streamVerifier) 367 func (tv Verifiers) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { 370 tv.streamVerifiers.Push(key(assignmentStreamType, subscription), streamVerifier)
/dports/www/tusd/google-cloud-go-storage-v1.18.2/pubsublite/internal/test/
H A D	verifier.go	346 func (tv Verifiers) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) { 349 tv.streamVerifiers.Push(keyPartition(publishStreamType, topic, partition), streamVerifier) 353 func (tv Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier RPCVeri… 356 tv.streamVerifiers.Push(keyPartition(subscribeStreamType, subscription, partition), streamVerifier) 360 func (tv Verifiers) AddCommitStream(subscription string, partition int, streamVerifier RPCVerifie… 363 tv.streamVerifiers.Push(keyPartition(commitStreamType, subscription, partition), streamVerifier) 367 func (tv Verifiers) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { 370 tv.streamVerifiers.Push(key(assignmentStreamType, subscription), streamVerifier)
/dports/databases/litestream/google-cloud-go-storage-v1.15.0/pubsublite/internal/test/
H A D	verifier.go	336 func (tv Verifiers) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) { 339 tv.streamVerifiers.Push(keyPartition(publishStreamType, topic, partition), streamVerifier) 343 func (tv Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier RPCVeri… 346 tv.streamVerifiers.Push(keyPartition(subscribeStreamType, subscription, partition), streamVerifier) 350 func (tv Verifiers) AddCommitStream(subscription string, partition int, streamVerifier RPCVerifie… 353 tv.streamVerifiers.Push(keyPartition(commitStreamType, subscription, partition), streamVerifier) 357 func (tv Verifiers) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { 360 tv.streamVerifiers.Push(key(assignmentStreamType, subscription), streamVerifier)
/dports/www/grafana8/google-cloud-go-storage-v1.14.0/pubsublite/internal/test/
H A D	verifier.go	336 func (tv Verifiers) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) { 339 tv.streamVerifiers.Push(keyPartition(publishStreamType, topic, partition), streamVerifier) 343 func (tv Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier RPCVeri… 346 tv.streamVerifiers.Push(keyPartition(subscribeStreamType, subscription, partition), streamVerifier) 350 func (tv Verifiers) AddCommitStream(subscription string, partition int, streamVerifier RPCVerifie… 353 tv.streamVerifiers.Push(keyPartition(commitStreamType, subscription, partition), streamVerifier) 357 func (tv Verifiers) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { 360 tv.streamVerifiers.Push(key(assignmentStreamType, subscription), streamVerifier)
/dports/sysutils/terraform/terraform-1.0.11/vendor/cloud.google.com/go/pubsublite/internal/test/
H A D	verifier.go	336 func (tv Verifiers) AddPublishStream(topic string, partition int, streamVerifier RPCVerifier) { 339 tv.streamVerifiers.Push(keyPartition(publishStreamType, topic, partition), streamVerifier) 343 func (tv Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier RPCVeri… 346 tv.streamVerifiers.Push(keyPartition(subscribeStreamType, subscription, partition), streamVerifier) 350 func (tv Verifiers) AddCommitStream(subscription string, partition int, streamVerifier RPCVerifie… 353 tv.streamVerifiers.Push(keyPartition(commitStreamType, subscription, partition), streamVerifier) 357 func (tv Verifiers) AddAssignmentStream(subscription string, streamVerifier RPCVerifier) { 360 tv.streamVerifiers.Push(key(assignmentStreamType, subscription), streamVerifier)
/dports/java/bouncycastle15/crypto-169/tls/src/main/java/org/bouncycastle/tls/
H A D	TlsUtils.java	2297 if (streamVerifier != null) in verifyCertificateVerifyClient() 2299 handshakeHash.copyBufferTo(streamVerifier.getOutputStream()); in verifyCertificateVerifyClient() 2300 verified = streamVerifier.isVerified(); in verifyCertificateVerifyClient() 2410 TlsStreamVerifier streamVerifier = verifier.getStreamVerifier(certificateVerify); in verify13CertificateVerify() local 2415 if (null != streamVerifier) in verify13CertificateVerify() 2417 OutputStream output = streamVerifier.getOutputStream(); in verify13CertificateVerify() 2420 return streamVerifier.isVerified(); in verify13CertificateVerify() 2504 TlsStreamVerifier streamVerifier = verifier.getStreamVerifier(digitallySigned); in verifyServerKeyExchangeSignature() local 2507 if (streamVerifier != null) in verifyServerKeyExchangeSignature() 2509 sendSignatureInput(context, digestBuffer, streamVerifier.getOutputStream()); in verifyServerKeyExchangeSignature() [all …]