events

Documentation

Index

• Constants
• type Event
  • func NewEvent(meta EventMetadata) Event
  • func (e *Event) AddNewValue(column string, v EventDataValue)
  • func (e *Event) AddOldValue(column string, v EventDataValue)
  • func (e *Event) Change(column string) (ec *EventChange)
  • func (e Event) ChangedColumns() []string
  • func (e Event) HasChangedColumn(c string) bool
• type EventChange
  • func (ec *EventChange) NewValueAs(data interface{}) error
  • func (ec *EventChange) OldValueAs(data interface{}) error
  • func (ec *EventChange) SetNewValue(value interface{}) error
  • func (ec *EventChange) SetOldValue(value interface{}) error
• type EventController
  • func NewEventController() (ec EventController, err error)
  • func (c *EventController) SendEvent(ctx context.Context, e *Event) (err error)
• type EventDataValue
• type EventMetadata
• type EventType

Constants

const (
	// EventTypeCreated ...
	EventTypeCreated = "CREATED"
	// EventTypeUpdated ...
	EventTypeUpdated = "UPDATED"
	// EventTypeDeleted ...
	EventTypeDeleted = "DELETED"
)

const (
	ORMChangeEvent = "com.graphql.orm.change"
)

Types

type Event

type Event struct {
	EventMetadata
	ID      string         `json:"id"`
	Changes []*EventChange `json:"changes"`
}

Event ...

func NewEvent

func NewEvent(meta EventMetadata) Event

NewEvent ...

func (*Event) AddNewValue

func (e *Event) AddNewValue(column string, v EventDataValue)

AddNewValue ...

func (*Event) AddOldValue

func (e *Event) AddOldValue(column string, v EventDataValue)

AddOldValue ...

func (*Event) Change

func (e *Event) Change(column string) (ec *EventChange)

func (Event) ChangedColumns

func (e Event) ChangedColumns() []string

ChangedColumns returns list of names of changed columns

func (Event) HasChangedColumn

func (e Event) HasChangedColumn(c string) bool

HasChangedColumn check if given event has changes on specific column

type EventChange

type EventChange struct {
	Name     string `json:"name"`
	OldValue string `json:"oldValue"`
	NewValue string `json:"newValue"`
}

EventChange ...

func (*EventChange) NewValueAs

func (ec *EventChange) NewValueAs(data interface{}) error

func (*EventChange) OldValueAs

func (ec *EventChange) OldValueAs(data interface{}) error

func (*EventChange) SetNewValue

func (ec *EventChange) SetNewValue(value interface{}) error

func (*EventChange) SetOldValue

func (ec *EventChange) SetOldValue(value interface{}) error

type EventController

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

func NewEventController

func NewEventController() (ec EventController, err error)

func (*EventController) SendEvent

func (c *EventController) SendEvent(ctx context.Context, e *Event) (err error)

SendEvent ...

type EventDataValue

type EventDataValue interface{}

type EventMetadata

type EventMetadata struct {
	Type        EventType `json:"type"`
	Cursor      string    `json:"cursor"`
	Entity      string    `json:"entity"`
	EntityID    string    `json:"entityId"`
	Date        int64     `json:"date"`
	PrincipalID *string   `json:"principalId"`
}

type EventType

type EventType string

EventType ...