events

Documentation

Index

• Constants
• func AssetsAPI(path string, uid string)
• func BlogPostCreate(d Data)
• func BlogPostDelete(d Data)
• func BlogPostUpdate(d Data)
• 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 PersonCreate(d Data)
• func PersonDelete(d Data)
• func PersonUpdate(d Data)
• func PublisherCreate(d Data)
• func PublisherUpdate(d Data)
• func RemoveFile(uid string)
• func RunListener()
• func SourceCreate(d Data)
• func SourceUpdate(d Data)
• func TagCreate(d Data)
• func TagUpdate(d Data)
• func TweetCreate(d Data)
• func TweetDelete(d Data)
• func TweetUpdate(d Data)
• func WaitTimeout(wg *sync.WaitGroup, timeout time.Duration) bool
• type Data
• type FileBackendRequest
• type IndexerQueue
  • func (q *IndexerQueue) Close()
  • func (q *IndexerQueue) Enqueue(task WorkTask)
  • func (q *IndexerQueue) Init()
• type IndexerTask
  • func (t IndexerTask) Do()
• type MessageHandler
• type WorkQueue
• type WorkTask

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_FILE_REMOVE    = "FILE_REMOVE"

	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"

	E_BLOG_POST_CREATE = "BLOG_POST_CREATE"
	E_BLOG_POST_UPDATE = "BLOG_POST_UPDATE"
	E_BLOG_POST_DELETE = "BLOG_POST_DELETE"

	E_TWEET_CREATE = "TWEET_CREATE"
	E_TWEET_UPDATE = "TWEET_UPDATE"
	E_TWEET_DELETE = "TWEET_DELETE"
)

Functions

func AssetsAPI

func AssetsAPI(path string, uid string)

AssetsAPI sends request to unzip api by file UID

func BlogPostCreate

func BlogPostCreate(d Data)

func BlogPostDelete

func BlogPostDelete(d Data)

func BlogPostUpdate

func BlogPostUpdate(d Data)

func CollectionContentUnitsChange

func CollectionContentUnitsChange(d Data)

func CollectionCreate

func CollectionCreate(d Data)

func CollectionDelete

func CollectionDelete(d Data)

func CollectionPublishedChange

func CollectionPublishedChange(d Data)

func CollectionUpdate

func CollectionUpdate(d Data)

func ContentUnitCreate

func ContentUnitCreate(d Data)

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 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 RemoveFile

func RemoveFile(uid string)

RemoveFile to send post req to file-api and remove file from search?

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)

func TweetCreate

func TweetCreate(d Data)

func TweetDelete

func TweetDelete(d Data)

func TweetUpdate

func TweetUpdate(d Data)

func WaitTimeout

func WaitTimeout(wg *sync.WaitGroup, timeout time.Duration) bool

WaitTimeout does a Wait on a sync.WaitGroup object but with a specified timeout. Returns true if the wait completed without timing out, false otherwise.

Types

type Data

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

Data struct for unmarshaling data from nats

type FileBackendRequest

type FileBackendRequest struct {
	SHA1 string `json:"sha1"`
	Name string `json:"name"`
}

type IndexerQueue

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

func (*IndexerQueue) Close

func (q *IndexerQueue) Close()

func (*IndexerQueue) Enqueue

func (q *IndexerQueue) Enqueue(task WorkTask)

func (*IndexerQueue) Init

func (q *IndexerQueue) Init()

type IndexerTask

type IndexerTask struct {
	F func(s string) error
	S string
}

func (IndexerTask) Do

func (t IndexerTask) Do()

type MessageHandler

type MessageHandler func(d Data)

type WorkQueue

type WorkQueue interface {
	Init()
	Close()
	Enqueue(WorkTask)
}

type WorkTask

type WorkTask interface {
	Do()
}