storage

Documentation

Index

• type AccountStats
• type AdminHelper
  • func CreateAdminHelper(ctx context.Context, uri string) (*AdminHelper, error)
  • func (h AdminHelper) IsCommandRunning(ctx context.Context, jobId int64) (bool, error)
• type EventsRepository
  • func CreateEventsRepository(ctx context.Context, conn config.MongoConnection) (*EventsRepository, error)
  • func (r *EventsRepository) Close(ctx context.Context) error
  • func (r *EventsRepository) CountByAccount(ctx context.Context) ([]AccountStats, error)
  • func (r *EventsRepository) Delete(ctx context.Context, corrId int64, q models.DataQuery) (int64, error)
  • func (r *EventsRepository) Exists(ctx context.Context, q models.DataQuery) (bool, error)
  • func (r *EventsRepository) Get(ctx context.Context, c models.ClientId, u models.UserId, t models.EventTypeId, ...) ([]entities.Event, error)
  • func (r *EventsRepository) InsertMany(ctx context.Context, ls []interface{}) (int, error)

Types

type AccountStats

type AccountStats struct {
	AccountId int64 `bson:"_id"`
	Events    int64 `bson:"events"`
}

type AdminHelper

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

func CreateAdminHelper

func CreateAdminHelper(ctx context.Context, uri string) (*AdminHelper, error)

func (AdminHelper) IsCommandRunning

func (h AdminHelper) IsCommandRunning(ctx context.Context, jobId int64) (bool, error)

type EventsRepository

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

func CreateEventsRepository

func CreateEventsRepository(ctx context.Context, conn config.MongoConnection) (*EventsRepository, error)

func (*EventsRepository) Close

func (r *EventsRepository) Close(ctx context.Context) error

func (*EventsRepository) CountByAccount

func (r *EventsRepository) CountByAccount(ctx context.Context) ([]AccountStats, error)

func (*EventsRepository) Delete

func (r *EventsRepository) Delete(ctx context.Context, corrId int64, q models.DataQuery) (int64, error)

func (*EventsRepository) Exists

func (r *EventsRepository) Exists(ctx context.Context, q models.DataQuery) (bool, error)

func (*EventsRepository) Get

func (r *EventsRepository) Get(ctx context.Context, c models.ClientId, u models.UserId, t models.EventTypeId, skip int64, take int64) ([]entities.Event, error)

func (*EventsRepository) InsertMany

func (r *EventsRepository) InsertMany(ctx context.Context, ls []interface{}) (int, error)