subscription

type FilterFunc func(ctx context.Context, payload interface{}) bool

type PubSub interface {
	Subscribe(topic string, options interface{}, callback func(interface{}) error) (Subscription, error)
	Unsubscribe(sub Subscription) error
}

type SetupFunction func(config *SubscriptionConfig, args map[string]interface{}, subscriptionName string) TriggerMap

type SetupFunctionMap map[string]SetupFunction

type Subscription interface{}

type SubscriptionConfig struct {
	Query          string
	Context        context.Context
	VariableValues map[string]interface{}
	OperationName  string
	Callback       func(*graphql.Result) error
}

type SubscriptionId uint64

type SubscriptionManager struct {
	// contains filtered or unexported fields
}

type SubscriptionManagerConfig struct {
	Schema         graphql.Schema
	PubSub         PubSub
	SetupFunctions SetupFunctionMap
}

type TriggerConfig struct {
	Options interface{}
	Filter  FilterFunc
}

type TriggerMap map[string]*TriggerConfig