summaryrefslogtreecommitdiffstats
path: root/vendor/github.com/gopackage/ddp/ddp.go
diff options
context:
space:
mode:
authorWim <wim@42.be>2021-10-17 00:47:22 +0200
committerGitHub <noreply@github.com>2021-10-17 00:47:22 +0200
commit4dd8bae5c91fa4aef09d865d8fef1acd84f90925 (patch)
treeffad9b242daccaf8c86d1c1fbd59032302bd3be9 /vendor/github.com/gopackage/ddp/ddp.go
parent7ae45c42e712bd0e66c101f3f714c05aa1dc2104 (diff)
downloadmatterbridge-msglm-4dd8bae5c91fa4aef09d865d8fef1acd84f90925.tar.gz
matterbridge-msglm-4dd8bae5c91fa4aef09d865d8fef1acd84f90925.tar.bz2
matterbridge-msglm-4dd8bae5c91fa4aef09d865d8fef1acd84f90925.zip
Update dependencies (#1610)
* Update dependencies * Update module to go 1.17
Diffstat (limited to 'vendor/github.com/gopackage/ddp/ddp.go')
-rw-r--r--vendor/github.com/gopackage/ddp/ddp.go79
1 files changed, 0 insertions, 79 deletions
diff --git a/vendor/github.com/gopackage/ddp/ddp.go b/vendor/github.com/gopackage/ddp/ddp.go
deleted file mode 100644
index 910adafd..00000000
--- a/vendor/github.com/gopackage/ddp/ddp.go
+++ /dev/null
@@ -1,79 +0,0 @@
-// Package ddp implements the MeteorJS DDP protocol over websockets. Fallback
-// to longpolling is NOT supported (and is not planned on ever being supported
-// by this library). We will try to model the library after `net/http` - right
-// now the library is barebones and doesn't provide the pluggability of http.
-// However, that's the goal for the package eventually.
-package ddp
-
-import (
- "fmt"
- "log"
- "sync"
- "time"
-)
-
-// debugLog is true if we should log debugging information about the connection
-var debugLog = true
-
-// The main file contains common utility types.
-
-// -------------------------------------------------------------------
-
-// idManager provides simple incrementing IDs for ddp messages.
-type idManager struct {
- // nextID is the next ID for API calls
- nextID uint64
- // idMutex is a mutex to protect ID updates
- idMutex *sync.Mutex
-}
-
-// newidManager creates a new instance and sets up resources.
-func newidManager() *idManager {
- return &idManager{idMutex: new(sync.Mutex)}
-}
-
-// newID issues a new ID for use in calls.
-func (id *idManager) newID() string {
- id.idMutex.Lock()
- next := id.nextID
- id.nextID++
- id.idMutex.Unlock()
- return fmt.Sprintf("%x", next)
-}
-
-// -------------------------------------------------------------------
-
-// pingTracker tracks in-flight pings.
-type pingTracker struct {
- handler func(error)
- timeout time.Duration
- timer *time.Timer
-}
-
-// -------------------------------------------------------------------
-
-// Call represents an active RPC call.
-type Call struct {
- ID string // The uuid for this method call
- ServiceMethod string // The name of the service and method to call.
- Args interface{} // The argument to the function (*struct).
- Reply interface{} // The reply from the function (*struct).
- Error error // After completion, the error status.
- Done chan *Call // Strobes when call is complete.
- Owner *Client // Client that owns the method call
-}
-
-// done removes the call from any owners and strobes the done channel with itself.
-func (call *Call) done() {
- delete(call.Owner.calls, call.ID)
- select {
- case call.Done <- call:
- // ok
- default:
- // We don't want to block here. It is the caller's responsibility to make
- // sure the channel has enough buffer space. See comment in Go().
- if debugLog {
- log.Println("rpc: discarding Call reply due to insufficient Done chan capacity")
- }
- }
-}