event

type ActionData struct {
	EntityDescriptor shared.EntityDescriptor
	Operation        shared.Operation
	FieldOperation   shared.Operation
	ErrorHandlers    shared.ErrorHandlers
	Then             shared.Handlers
	Else             shared.Handlers
	Conditions       shared.EvalFuncs
	FieldName        string
	Or               []ActionData
	And              []ActionData
	Not              []ActionData
}

type Alternative interface {
	Else(fns ...shared.Handler) Catchable
	Catch(fn shared.ErrorHandler) Executable
}

type Catchable interface {
	Catch(fn shared.ErrorHandler) Executable
}

type Combinable interface {
	Or(or ...Combinable) Combinable
	And(or ...Combinable) Combinable
	Not(not ...Combinable) Combinable
}

type Executable interface {
	Execute(ctx goka.Context, m *shared.EventContext) shared.ChainHandledState
	SetDescriptor(descr shared.EntityDescriptor) Executable
}

type Neo4jBeforeOrAfter struct {
	Labels     []string          `json:"labels"`
	Properties shared.Properties `json:"properties"`
}

type Neo4jMessage struct {
	Meta    Neo4jMeta    `json:"meta"`
	Payload Neo4jPayload `json:"payload"`
}

type Neo4jMessageCodec struct{}

type Neo4jMeta struct {
	Timestamp     int64            `json:"timestamp"`
	Username      string           `json:"username"`
	TxID          int              `json:"tx_id"`
	TxEventID     int              `json:"tx_event_id"`
	TxEventsCount int              `json:"tx_events_count"`
	Operation     shared.Operation `json:"operation"`
	Source        Neo4jSource      `json:"source"`
}

type Neo4jPayload struct {
	ID       string              `json:"id"`
	Type     string              `json:"type"`
	RelLabel string              `json:"label"`
	Start    *Neo4jStartOrEnd    `json:"start,omitempty"`
	End      *Neo4jStartOrEnd    `json:"end,omitempty"`
	After    *Neo4jBeforeOrAfter `json:"after,omitempty"`
	Before   *Neo4jBeforeOrAfter `json:"before,omitempty"`
}

type Neo4jSource struct {
	Hostname string `json:"hostname"`
}

type Neo4jStartOrEnd struct {
	Labels []string `json:"labels"`
	ID     string   `json:"id"`
}

type Proceedable interface {
	Then(fns ...shared.Handler) Alternative
}

type Selectable interface {
	OnNodeCreated() Combinable
	OnNodeUpdated() Combinable
	OnNodeDeleted() Combinable
	OnFieldCreated(field string) Combinable
	OnFieldUpdated(field string) Combinable
	OnFieldDeleted(field string) Combinable
	With(fn shared.EvalFunc) Combinable
}