diff --git a/pkg/collections/events.go b/pkg/collections/events.go index bdc92e7769a7cd7ffc880825caaf3098fb5495fb..516d5c5cbf8ece7bd338e02a9919f4411a10c2fa 100644 --- a/pkg/collections/events.go +++ b/pkg/collections/events.go @@ -1,8 +1,8 @@ package collections const ( - EventCollectionCreate = "collection_create" - EventCollectionUpdate = "collection_update" - EventCollectionDelete = "collection_delete" - EventCollectionSetSchema = "collection_set_schema" + EventCreate = "collection.create" + EventUpdate = "collection.update" + EventDelete = "collection.delete" + EventSetSchema = "collection.set_schema" ) diff --git a/pkg/collections/middleware/logging_middleware.go b/pkg/collections/middleware/logging_middleware.go index 14c28d1385e0476741f89086061b95ba788d15f3..3c80eda411e9905791e59042a31f2af8f300cefd 100644 --- a/pkg/collections/middleware/logging_middleware.go +++ b/pkg/collections/middleware/logging_middleware.go @@ -31,7 +31,7 @@ func (m *loggingMiddleware) Create(ctx context.Context, collection *collections. } logger := m.logger.With( logzap.CallerFromContext(ctx, spaceID), - logzap.Event(collections.EventCollectionCreate), + logzap.Event(collections.EventCreate), ) created, err = m.next.Create(ctx, collection) @@ -47,7 +47,7 @@ func (m *loggingMiddleware) Create(ctx context.Context, collection *collections. func (m *loggingMiddleware) Delete(ctx context.Context, spaceId string, envId string, collectionId string) (err error) { logger := m.logger.With( logzap.CallerFromContext(ctx, spaceId), - logzap.Event(collections.EventCollectionDelete), + logzap.Event(collections.EventDelete), logzap.Object(id.NewCollectionId(spaceId, envId, collectionId)), ) @@ -92,7 +92,7 @@ func (m *loggingMiddleware) List(ctx context.Context, spaceId string, envId stri func (m *loggingMiddleware) SetSchema(ctx context.Context, spaceId string, envId string, collectionId string, schema *schema.Schema) (err error) { logger := m.logger.With( logzap.CallerFromContext(ctx, spaceId), - logzap.Event(collections.EventCollectionSetSchema), + logzap.Event(collections.EventSetSchema), logzap.Object(id.NewCollectionId(spaceId, envId, collectionId)), ) @@ -128,7 +128,7 @@ func (m *loggingMiddleware) Update(ctx context.Context, coll *collections.Collec } logger := m.logger.With( logzap.CallerFromContext(ctx, spaceID), - logzap.Event(collections.EventCollectionUpdate), + logzap.Event(collections.EventUpdate), logzap.Object(coll), )