incoming

type Destination interface {
	Notify(event.Event) error
}

type EventSource interface {
	SetStorage(EventStorage)
	Events() <-chan []*ReceivedEvent
}

type EventStorage interface {
	Save(context.Context, int64, ...*ReceivedEvent) error
}

type GDatastoreStorage struct {
	ProjectID string
}

type GPubSubSource struct {
	Topic string // PubSub topic name
	// contains filtered or unexported fields
}

type HTTPSource struct {
	http.Handler

	Listen string
	// contains filtered or unexported fields
}

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

type ReceivedEvent struct {
	event.CoreAttrs
	// contains filtered or unexported fields
}

type Rule struct{}

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

type Server struct {
	Rules   RuleMap
	Sources []EventSource
	Storage EventStorage
}