entities

Documentation

Index

• type DeadLetterItem
  • func NewDeadLetterItem(event Event) DeadLetterItem
• type Event
• type EventStoreItem
  • func NewEventStoreItem(event Event) EventStoreItem
• type Registration
  • func CreateNewRegistration(event string, callback string) Registration

Types

type DeadLetterItem

type DeadLetterItem struct {
	Id               bson.ObjectId `bson:"_id"`
	Event            Event         `bson:"event,omitempty"`
	CreationDate     time.Time     `bson:"creation_date,omitempty"`
	FirstFailureDate time.Time     `bson:"first_failure_date,omitempty"`
	NextRetryDate    time.Time     `bson:"next_retry_date,omitempty"`
	FailureCount     int           `bson:"failure_count,omitempty"`
	CallbackUrl      string        `bson:"callback_url,omitempty"`
}

func NewDeadLetterItem

func NewDeadLetterItem(event Event) DeadLetterItem

type Event

type Event struct {
	EventName string `json:"event_name" bson:"event_name"`
	Payload   string `json:"payload" bson:"payload"`
}

this needs separated into data entities and api entities

type EventStoreItem

type EventStoreItem struct {
	Id           bson.ObjectId `bson:"_id"`
	Event        Event         `bson:"event,omitempty"`
	CreationDate time.Time     `bson:"creation_date,omitempty"`
}

func NewEventStoreItem

func NewEventStoreItem(event Event) EventStoreItem

type Registration

type Registration struct {
	Id           bson.ObjectId `bson:"_id"`
	EventName    string        `bson:"event_name,omitempty"`
	CallbackUrl  string        `bson:"callback_url,omitempty"`
	CreationDate time.Time     `bson:"creation_date,omitempty"`
}

func CreateNewRegistration

func CreateNewRegistration(event string, callback string) Registration