eventstore

type CreateEntityOptions struct {
	Entity string      `json:"entity"`
	Input  interface{} `json:"input"`
}

type DeleteEntityOptions struct {
	Entity   string `json:"entity"`
	EntityID string `json:"entityId"`
}

type Event struct {
	ID            string         `json:"id"`
	Cursor        string         `json:"cursor"`
	OperationName *string        `json:"operationName"`
	Entity        string         `json:"entity"`
	EntityID      string         `json:"entityId"`
	Data          interface{}    `json:"data"`
	OldValues     []EventValue   `json:"oldValues"`
	NewValues     []EventValue   `json:"newValues"`
	Type          FetchEventType `json:"type"`
	Date          time.Time      `json:"date"`
	PrincipalID   *string        `json:"principalId"`
	Columns       []string       `json:"columns"`
}

type EventValue struct {
	Name  string       `json:"name"`
	Value *interface{} `json:"value"`
}

type FetchEventType string

type FetchEventsOptions struct {
	ID         *string
	Entity     *string
	CursorFrom *string
	Limit      *int
	Sort       *FetchEventsSort
}

type FetchEventsResponse struct {
	Events []Event
}

type FetchEventsSort string

type OnEventOptions struct {
	Topic       string
	Channel     string
	HandlerFunc func(e Event) error
}

type UpdateEntityOptions struct {
	Entity   string      `json:"entity"`
	EntityID string      `json:"entityId"`
	Input    interface{} `json:"input"`
}