Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FilterFunc ¶
type PubSub ¶
type PubSub interface { Subscribe(topic string, options interface{}, callback func(interface{}) error) (Subscription, error) Unsubscribe(sub Subscription) error }
type SetupFunction ¶
type SetupFunction func(config *SubscriptionConfig, args map[string]interface{}, subscriptionName string) TriggerMap
type SetupFunctionMap ¶
type SetupFunctionMap map[string]SetupFunction
type Subscription ¶
type Subscription interface{}
type SubscriptionConfig ¶
type SubscriptionId ¶
type SubscriptionId uint64
type SubscriptionManager ¶
type SubscriptionManager struct {
// contains filtered or unexported fields
}
func NewSubscriptionManager ¶
func NewSubscriptionManager(config SubscriptionManagerConfig) *SubscriptionManager
func (*SubscriptionManager) Subscribe ¶
func (sm *SubscriptionManager) Subscribe(config SubscriptionConfig) (SubscriptionId, error)
func (*SubscriptionManager) Unsubscribe ¶
func (sm *SubscriptionManager) Unsubscribe(id SubscriptionId)
type SubscriptionManagerConfig ¶
type SubscriptionManagerConfig struct { Schema graphql.Schema PubSub PubSub SetupFunctions SetupFunctionMap }
type TriggerConfig ¶
type TriggerConfig struct { Options interface{} Filter FilterFunc }
type TriggerMap ¶
type TriggerMap map[string]*TriggerConfig
Click to show internal directories.
Click to hide internal directories.