traverser

Documentation

Index

• func TraverserCreatePath(f *NotificationFilter) []uint64
• func TraverserTraverse(data interface{}) pubsub.Paths
• type Notification
• type NotificationFilter
• type Producer

Functions

func TraverserCreatePath

func TraverserCreatePath(f *NotificationFilter) []uint64

func TraverserTraverse

func TraverserTraverse(data interface{}) pubsub.Paths

Types

type Notification

type Notification struct {
	Added    bool
	Key      string
	Producer Producer
}

Notification is used in the PubSub to alert upon producers coming and going.

type NotificationFilter

type NotificationFilter struct {
	Added *bool
	Key   *string
}

type Producer

type Producer interface {
	// Produce implements streamaggregator.Producer
	Produce(ctx context.Context, request interface{}, c chan<- interface{})
}

Producer is a type copy of streamaggregator.Producer