cep

type And struct {
	Expressions []Expression
}

type Context interface {
	Unregister(id string) bool
}

type Emitter interface {
	OnEvent(Event) (Flow, error)
}

type Equals struct {
	Type EventType
}

type Event struct {
	Time UnixTime
	Type EventType
}

type EventType int64

type Expression interface {
	Matches(Event) bool
}

type Flow interface {
	Id() string
	OnEvent(Context, Event) []Event
}

type FlowUnregisterFunc func(id string) bool

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

type FollowedBy struct {
	Statement *Statement
	Within    time.Duration
}

type Graph struct {
	Emitters []Emitter
	Flows    Flows
}

type NotEquals struct {
	Type EventType
}

type Or struct {
	Expressions []Expression
}

type Statement struct {
	Expression Expression
	FollowedBy *FollowedBy
	Triggers   EventType

	// may multiple instances of this statement be in effect at one time
	AllowMultiple bool
}

type StatementEmitter struct {
	Statement Statement
}

type StatementFlow struct {
	Statement *Statement
	// contains filtered or unexported fields
}

type UnixTime int64