store

package
v0.16.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 3, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func EnsureIndexes added in v0.9.0 

func EnsureIndexes(ctx context.Context, db *mongo.Database) error

EnsureIndexes crée les index nécessaires pour optimiser les requêtes MongoDB Cette fonction doit être appelée au démarrage de l'application

func GetDatabase added in v0.9.0 

func GetDatabase() *mongo.Database

GetDatabase retourne l'instance de la base de données MongoDB Utilisé pour l'initialisation des index

func NewClient 

func NewClient(collection string) (c *mongo.Collection)

Types

type CatalogStoreClient added in v0.4.0 

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

func NewStoreCatalog added in v0.4.0 

func NewStoreCatalog(collection string) (c *CatalogStoreClient)

func (*CatalogStoreClient) Delete added in v0.4.0 

func (c *CatalogStoreClient) Delete(ctx context.Context, filter map[string]interface{}) (err error)

func (*CatalogStoreClient) Get added in v0.4.0 

func (c *CatalogStoreClient) Get(ctx context.Context, filter map[string]interface{}) (result *v1alpha1.Catalog, err error)

Get an Catalog and creates it. Returns the server's representation of the Catalog, and an error, if there is any.

func (*CatalogStoreClient) List added in v0.4.0 

func (c *CatalogStoreClient) List(ctx context.Context) (results []*v1alpha1.Catalog, err error)

List takes label and field selectors, and returns the list of Catalogs that match those selectors.

func (*CatalogStoreClient) Update added in v0.4.0 

func (c *CatalogStoreClient) Update(ctx context.Context, filter map[string]interface{}, catalogUpdate *v1alpha1.Catalog) (result *v1alpha1.Catalog, err error)

type EventStoreClient 

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

func NewStoreEvent 

func NewStoreEvent(collection string) (c *EventStoreClient)

func (*EventStoreClient) AggregateByMonth added in v0.15.0 

func (c *EventStoreClient) AggregateByMonth(ctx context.Context, matchFilter bson.D, groupByService bool) ([]MonthlyStatsResult, error)

AggregateByMonth aggregates events by month with optional service grouping

func (*EventStoreClient) CountWithFilter added in v0.15.0 

func (c *EventStoreClient) CountWithFilter(ctx context.Context, filter bson.D) (int64, error)

CountWithFilter counts events matching the given filter

func (*EventStoreClient) Create 

func (c *EventStoreClient) Create(ctx context.Context, eventInsert *v1alpha1.Event) (result *v1alpha1.Event, err error)

Create takes the representation of an Event and creates it. Returns the server's representation of the Event, and an error, if there is any.

func (*EventStoreClient) Delete added in v0.3.0 

func (c *EventStoreClient) Delete(ctx context.Context, filter map[string]interface{}) (err error)

func (*EventStoreClient) Get 

func (c *EventStoreClient) Get(ctx context.Context, filter map[string]interface{}) (result *v1alpha1.Event, err error)

Get an Event and creates it. Returns the server's representation of the Event, and an error, if there is any.

func (*EventStoreClient) List 

func (c *EventStoreClient) List(ctx context.Context) (results []*v1alpha1.Event, err error)

List takes label and field selectors, and returns the list of Events that match those selectors.

func (*EventStoreClient) Search 

func (c *EventStoreClient) Search(ctx context.Context, filter map[string]interface{}) (results []*v1alpha1.Event, err error)

Search and returns the list of Events that match those selectors.

func (*EventStoreClient) Update added in v0.3.0 

func (c *EventStoreClient) Update(ctx context.Context, filter map[string]interface{}, eventUpdate *v1alpha1.Event) (result *v1alpha1.Event, err error)

type LockStoreClient 

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

func NewStoreLock 

func NewStoreLock(collection string) (c *LockStoreClient)

func (*LockStoreClient) Create 

func (c *LockStoreClient) Create(ctx context.Context, lockInsert *v1alpha1.Lock) (result *v1alpha1.Lock, err error)

Create takes the representation of an Lock and creates it. Returns the server's representation of the Lock, and an error, if there is any.

func (*LockStoreClient) Get 

func (c *LockStoreClient) Get(ctx context.Context, filter map[string]interface{}) (result *v1alpha1.Lock, err error)

Get an Lock and creates it. Returns the server's representation of the Lock, and an error, if there is any.

func (*LockStoreClient) List 

func (c *LockStoreClient) List(ctx context.Context) (results []*v1alpha1.Lock, err error)

List takes label and field selectors, and returns the list of Locks that match those selectors.

func (*LockStoreClient) Unlock 

func (c *LockStoreClient) Unlock(ctx context.Context, filter map[string]interface{}) (count int64, err error)

Search and returns the list of Locks that match those selectors.

func (*LockStoreClient) Update added in v0.12.0 

func (c *LockStoreClient) Update(ctx context.Context, filter map[string]interface{}, lockUpdate *v1alpha1.Lock) (result *v1alpha1.Lock, err error)

type MongoClient 

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

MongoClient is used to interact with features

func (*MongoClient) Count 

func (c *MongoClient) Count(ctx context.Context) (count int64, err error)

Get an Event and creates it. Returns the server's representation of the Event, and an error, if there is any.

type MonthlyStatsResult added in v0.15.0 

type MonthlyStatsResult struct {
	Year    int32  `bson:"year"`
	Month   int32  `bson:"month"`
	Service string `bson:"service,omitempty"`
	Count   int64  `bson:"count"`
}

MonthlyStatsResult represents a single month's statistics

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.