storage

Documentation

Index

• func StartTTLCache(log logger.LoggerI, cache *ttlcache.Cache[string, string]) error
• type EntityI
• type EntityPgI
• type GroupI
• type StorageI
• type StoragePgI

Functions

func StartTTLCache

func StartTTLCache(log logger.LoggerI, cache *ttlcache.Cache[string, string]) error

Types

type EntityI

type EntityI interface {
	Create(ctx context.Context, slug string, body map[string]interface{}) error
	Update(ctx context.Context, slug string, id string, body map[string]interface{}) error
	UpdateMany(ctx context.Context, slug string, ids []string, body map[string]interface{}) error
	Delete(ctx context.Context, slug string, id string) error
	DeleteMany(ctx context.Context, slug string, ids []string) error
	Get(ctx context.Context, slug string, id string) (map[string]interface{}, error)
	List(ctx context.Context, slug, order, sort string, limit, offset int32, filter bson.D) ([]map[string]interface{}, error)
	JoinList(ctx context.Context, slug, order, sort string, limit, offset int32, filter bson.A, aggregate *pd.Aggregate) ([]map[string]interface{}, error)
	Count(ctx context.Context, slug string, filter bson.D) (int64, error)
	JoinCount(ctx context.Context, slug string, filter bson.A) (int64, error)
	QueryFilter(req map[string]interface{}, group *pd.Group, search, location string) (bson.D, error)
	JoinQueryFilter(req map[string]interface{}, group *pd.Group, search, location string) (bson.A, error)
}

type EntityPgI

type EntityPgI interface {
}

type GroupI

type GroupI interface {
	CreateGroup(ctx context.Context, req *pd.Group) error
	GetGroupById(ctx context.Context, req *pd.GetByIdRequest) (*pd.Group, error)
	DeleteGroup(ctx context.Context, req *pd.GetByIdRequest) error
	UpdateGroup(ctx context.Context, req *pd.Group) error
	GetAllGroup(ctx context.Context, req *pd.GetAllGroupRequest) (*pd.GetAllGroupResponse, error)
	CreateField(ctx context.Context, req *pd.Field) error
	GetFieldById(ctx context.Context, req *pd.GetByIdRequest) (*pd.Field, error)
	DeleteField(ctx context.Context, req *pd.GetByIdRequest) error
	UpdateField(ctx context.Context, req *pd.Field) error
	GetAllField(ctx context.Context, req *pd.GetAllFieldRequest) (*pd.GetAllFieldResponse, error)
	GetFullGroup(ctx context.Context, req *pd.GetByIdRequest) (*pd.Group, error)
}

type StorageI

type StorageI interface {
	Disconnect() error
	Group() GroupI
	Entity() EntityI
}

type StoragePgI

type StoragePgI interface {
	CloseDB()
}