mongo

Documentation

Index

• Variables
• type DB
  • func NewMongoDB(database *mongo.Database) *DB
  • func (s *DB) GetAction(ctx context.Context, id primitive.ObjectID) (model.Action, error)
  • func (s *DB) GetEvent(ctx context.Context, eventID string, actionID string) (model.Event, error)
  • func (s *DB) GetEventStatus(ctx context.Context, actionID string) ([]response.EventStatusResponse, error)
  • func (s *DB) GetEvents(ctx context.Context, actionID string) ([]response.EventResponse, error)
  • func (s *DB) StoreAction(ctx context.Context, id primitive.ObjectID, t []string, eventCount int) (string, error)
  • func (s *DB) StoreEvent(ctx context.Context, event *model.Event) (string, error)
  • func (s *DB) UpdateEventStatus(ctx context.Context, eventID string) *mongo.UpdateResult

Variables

var (
	ActionCollection = "actions"
	EventsCollection = "events"
)

Types

type DB

type DB struct {
	DB *mongo.Database
}

func NewMongoDB

func NewMongoDB(database *mongo.Database) *DB

func (*DB) GetAction

func (s *DB) GetAction(ctx context.Context, id primitive.ObjectID) (model.Action, error)

func (*DB) GetEvent

func (s *DB) GetEvent(ctx context.Context, eventID string, actionID string) (model.Event, error)

func (*DB) GetEventStatus

func (s *DB) GetEventStatus(ctx context.Context, actionID string) ([]response.EventStatusResponse, error)

func (*DB) GetEvents

func (s *DB) GetEvents(ctx context.Context, actionID string) ([]response.EventResponse, error)

func (*DB) StoreAction

func (s *DB) StoreAction(ctx context.Context, id primitive.ObjectID, t []string, eventCount int) (string, error)

func (*DB) StoreEvent

func (s *DB) StoreEvent(ctx context.Context, event *model.Event) (string, error)

func (*DB) UpdateEventStatus

func (s *DB) UpdateEventStatus(ctx context.Context, eventID string) *mongo.UpdateResult