events

Documentation

Index

• Constants
• func CollectionContentUnitsChange(d Data)
• func CollectionCreate(d Data)
• func CollectionDelete(d Data)
• func CollectionPublishedChange(d Data)
• func CollectionUpdate(d Data)
• func ContentUnitCreate(d Data)
• func ContentUnitDelete(d Data)
• func ContentUnitDerivativesChange(d Data)
• func ContentUnitPersonsChange(d Data)
• func ContentUnitPublishedChange(d Data)
• func ContentUnitPublishersChange(d Data)
• func ContentUnitSourcesChange(d Data)
• func ContentUnitTagsChange(d Data)
• func ContentUnitUpdate(d Data)
• func FileInsert(d Data)
• func FilePublished(d Data)
• func FileReplace(d Data)
• func FileUpdate(d Data)
• func GetFileObj(uid string) *mdbmodels.File
• func GetUnitObj(uid string) *mdbmodels.ContentUnit
• func PersonCreate(d Data)
• func PersonDelete(d Data)
• func PersonUpdate(d Data)
• func PublisherCreate(d Data)
• func PublisherUpdate(d Data)
• func RunListener()
• func SourceCreate(d Data)
• func SourceUpdate(d Data)
• func TagCreate(d Data)
• func TagUpdate(d Data)
• type Data
• type MessageHandler

Constants

const (
	E_COLLECTION_CREATE               = "COLLECTION_CREATE"
	E_COLLECTION_UPDATE               = "COLLECTION_UPDATE"
	E_COLLECTION_DELETE               = "COLLECTION_DELETE"
	E_COLLECTION_PUBLISHED_CHANGE     = "COLLECTION_PUBLISHED_CHANGE"
	E_COLLECTION_CONTENT_UNITS_CHANGE = "COLLECTION_CONTENT_UNITS_CHANGE"

	E_CONTENT_UNIT_CREATE             = "CONTENT_UNIT_CREATE"
	E_CONTENT_UNIT_UPDATE             = "CONTENT_UNIT_UPDATE"
	E_CONTENT_UNIT_DELETE             = "CONTENT_UNIT_DELETE"
	E_CONTENT_UNIT_PUBLISHED_CHANGE   = "CONTENT_UNIT_PUBLISHED_CHANGE"
	E_CONTENT_UNIT_DERIVATIVES_CHANGE = "CONTENT_UNIT_DERIVATIVES_CHANGE"
	E_CONTENT_UNIT_SOURCES_CHANGE     = "CONTENT_UNIT_SOURCES_CHANGE"
	E_CONTENT_UNIT_TAGS_CHANGE        = "CONTENT_UNIT_TAGS_CHANGE"
	E_CONTENT_UNIT_PERSONS_CHANGE     = "CONTENT_UNIT_PERSONS_CHANGE"
	E_CONTENT_UNIT_PUBLISHERS_CHANGE  = "CONTENT_UNIT_PUBLISHERS_CHANGE"

	E_FILE_UPDATE    = "FILE_UPDATE"
	E_FILE_PUBLISHED = "FILE_PUBLISHED"
	E_FILE_INSERT    = "FILE_INSERT"
	E_FILE_REPLACE   = "FILE_REPLACE"

	E_SOURCE_CREATE = "SOURCE_CREATE"
	E_SOURCE_UPDATE = "SOURCE_UPDATE"

	E_TAG_CREATE = "TAG_CREATE"
	E_TAG_UPDATE = "TAG_UPDATE"

	E_PERSON_CREATE = "PERSON_CREATE"
	E_PERSON_UPDATE = "PERSON_UPDATE"
	E_PERSON_DELETE = "PERSON_DELETE"

	E_PUBLISHER_CREATE = "PUBLISHER_CREATE"
	E_PUBLISHER_UPDATE = "PUBLISHER_UPDATE"
)

Functions

func CollectionContentUnitsChange

func CollectionContentUnitsChange(d Data)

func CollectionCreate

func CollectionCreate(d Data)

collection functions

func CollectionDelete

func CollectionDelete(d Data)

func CollectionPublishedChange

func CollectionPublishedChange(d Data)

func CollectionUpdate

func CollectionUpdate(d Data)

func ContentUnitCreate

func ContentUnitCreate(d Data)

//event functions

func ContentUnitDelete

func ContentUnitDelete(d Data)

func ContentUnitDerivativesChange

func ContentUnitDerivativesChange(d Data)

func ContentUnitPersonsChange

func ContentUnitPersonsChange(d Data)

func ContentUnitPublishedChange

func ContentUnitPublishedChange(d Data)

func ContentUnitPublishersChange

func ContentUnitPublishersChange(d Data)

func ContentUnitSourcesChange

func ContentUnitSourcesChange(d Data)

func ContentUnitTagsChange

func ContentUnitTagsChange(d Data)

func ContentUnitUpdate

func ContentUnitUpdate(d Data)

func FileInsert

func FileInsert(d Data)

func FilePublished

func FilePublished(d Data)

func FileReplace

func FileReplace(d Data)

func FileUpdate

func FileUpdate(d Data)

func GetFileObj

func GetFileObj(uid string) *mdbmodels.File

GetFileObj gets the file object from db

func GetUnitObj

func GetUnitObj(uid string) *mdbmodels.ContentUnit

func PersonCreate

func PersonCreate(d Data)

func PersonDelete

func PersonDelete(d Data)

func PersonUpdate

func PersonUpdate(d Data)

func PublisherCreate

func PublisherCreate(d Data)

func PublisherUpdate

func PublisherUpdate(d Data)

func RunListener

func RunListener()

func SourceCreate

func SourceCreate(d Data)

func SourceUpdate

func SourceUpdate(d Data)

func TagCreate

func TagCreate(d Data)

func TagUpdate

func TagUpdate(d Data)

Types

type Data

type Data struct {
	ID      string                 `json:"id"`
	Type    string                 `json:"type"`
	Payload map[string]interface{} `json:"payload"`
}

Data struct for unmarshaling data

type MessageHandler

type MessageHandler func(d Data)