shared

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

type ChainHandledState int

type ChangeInfo struct {
	Before interface{} `json:"before"`
	After  interface{} `json:"after"`
}

type ChangeInfos map[string]ChangeInfo

type ContextDefinition map[string]CypherQuery

type CypherQuery string

type DispatcherFunc func(ctx context.Context, kServers, zServers []string) func() error

type EntityContext struct {
	NodeID  int64
	Context map[string]Properties
}

type EntityDescriptor interface {
	HubInputStream() goka.Stream
	HubOutputStream() goka.Stream
	HubGroup() goka.Group
	EventInputStream() goka.Stream
	EventOutputStream() goka.Stream
	EventGroup() goka.Group
	ContextDef() ContextDefinition
	Label() string
}

type ErrorHandler func(err error)

type ErrorHandlers []ErrorHandler

type EvalFunc func(arg interface{}) bool

type EvalFuncs []EvalFunc

type EventContext struct {
	TimeStamp   time.Time   `json:"time_stamp"`
	Operation   Operation   `json:"operation"`
	NodeID      int64       `json:"node_id"`
	ChangeInfos ChangeInfos `json:"change_infos"`
	Properties  Properties  `json:"properties"`
}

type EventContextCodec struct{}

type Executor struct {
	*HandlerContext
}

type Handler func(ctx *HandlerContext) error

type HandlerContext struct {
	GokaContext      goka.Context
	EntityDescriptor EntityDescriptor
	EventContext     *EventContext
	HubContext       *HubContext
	// contains filtered or unexported fields
}

type Handlers []Handler

type HubContext struct {
	Sender     string     `json:"sender"`
	SenderID   int64      `json:"sender_id"`
	Operation  Operation  `json:"operation"`
	Receiver   string     `json:"receiver"`
	ReceiverID int64      `json:"receiver_id"`
	Properties Properties `json:"properties"`
}

type HubContextCodec struct{}

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

type MatcherFunc func() (bool, EvalFunc)

type OnRecordFunc func(rec neo4j.Record) error

type Operation string

type Operations []Operation

type Properties map[string]interface{}