mongo

Documentation

Index

• Constants
• func NewEventRepository(ctx context.Context, db *mongo.Database, dequeueTimeout time.Duration, ...) (eventbus.EventRepository, error)
• type Event

Constants

const EventCollection = "events"

Functions

func NewEventRepository

func NewEventRepository(ctx context.Context, db *mongo.Database, dequeueTimeout time.Duration, runningTimeout time.Duration) (eventbus.EventRepository, error)

Types

type Event

type Event struct {
	EventID string `json:"id" bson:"id"`
	Type    string `json:"type" bson:"type"`
	Status  string `json:"status" bson:"status"`
	// todo record reason why in current status
	Reason      string              `bson:"reason" bson:"reason"`
	Payload     string              `json:"payload" bson:"payload"`
	RetryCount  int                 `json:"retryCount" bson:"retryCount"`
	CreatedAt   primitive.DateTime  `json:"createdAt" bson:"createdAt"`
	UpdatedAt   primitive.DateTime  `json:"updatedAt" bson:"updatedAt"`
	ScheduledAt primitive.DateTime  `json:"scheduledAt" bson:"scheduledAt"`
	DeletedAt   *primitive.DateTime `json:"deletedAt" bson:"deletedAt"`
}

Event represents an event to be processed