Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager manages subscriptions
func NewManager ¶
func NewManager() *Manager
func (*Manager) HasSubscription ¶
HasSubscription returns true if the subscription exists
func (*Manager) Subscribe ¶
func (m *Manager) Subscribe(sub *Subscription) error
Subscribe performs a subscribe operation
func (*Manager) Unsubscribe ¶
Unsubscribe removes a single operation
func (*Manager) UnsubscribeAll ¶
func (m *Manager) UnsubscribeAll()
Unsubscribe all unsubscribes and removes all operations for a specific connection id
type Subscription ¶
type Subscription struct {
Channel chan *graphql.Result
ConnectionID string
OperationID string
Context context.Context
CancelFunc context.CancelFunc
}
Subscription interface between ws and graphql execution
Source Files
Click to show internal directories.
Click to hide internal directories.