service

Documentation

Index

• type BadgerService
  • func NewBadgerService(cfg *config.Config) (*BadgerService, error)
  • func (bs *BadgerService) Close() error
  • func (bs *BadgerService) Delete(key []byte) error
  • func (bs *BadgerService) Get(key []byte) ([]byte, error)
  • func (bs *BadgerService) GetAllBadger() ([]map[string]interface{}, error)
  • func (bs *BadgerService) Set(key, value []byte) error
• type BboltService
  • func NewBboltService(cfg *config.Config) (*BboltService, error)
  • func (bs *BboltService) CreateIndex(index *models.Index) error
  • func (bs *BboltService) Delete(filename string, bucket, key []byte) error
  • func (bs *BboltService) Get(filename string, bucket, key []byte) ([]byte, error)
  • func (bs *BboltService) GetAllBbolt() ([]map[string]interface{}, error)
  • func (bs *BboltService) GetAndParseAsNode(filename string, bucket, key []byte) (*models.Node, error)
  • func (bs *BboltService) GetFileNameFromIndex(index *models.Index) string
  • func (bs *BboltService) Set(filename string, bucket, key, value []byte) error
  • func (bs *BboltService) SetNode(filename string, bucket []byte, node *models.Node) error
• type ParquetService
  • func NewParquetService() (*ParquetService, error)
• type QueueManager
  • func NewQueueManager() *QueueManager
  • func (qm *QueueManager) AddToQueue(name string, item map[string]interface{})
  • func (qm *QueueManager) GetAllCurrentQueueAndTheirFirstData() map[string]map[string]interface{}
  • func (qm *QueueManager) GetFromQueue(name string) map[string]interface{}
  • func (qm *QueueManager) GetOrCreateQueue(name string) *deque.Deque[map[string]interface{}]
• type SQLiteCatalogService
  • func NewSQLiteCatalogService(cfg *config.Config) (*SQLiteCatalogService, error)
  • func (m *SQLiteCatalogService) AddUser(username, password, role string) error
  • func (m *SQLiteCatalogService) Close() error
  • func (m *SQLiteCatalogService) CreateCollection(collection *models.Collection) error
  • func (m *SQLiteCatalogService) CreateIndex(index *models.Index) error
  • func (m *SQLiteCatalogService) CreateShard(shard *models.Shard) error
  • func (m *SQLiteCatalogService) CreateWorkspace(workspace *models.Workspace) error
  • func (m *SQLiteCatalogService) GetCollectionByID(id int) (*models.Collection, error)
  • func (m *SQLiteCatalogService) GetCollectionByName(name string) (*models.Collection, error)
  • func (m *SQLiteCatalogService) GetIndexByID(id int) (*models.Index, error)
  • func (m *SQLiteCatalogService) GetIndexesByServer(server string) ([]models.Index, error)
  • func (m *SQLiteCatalogService) GetModelWithAllAssociations(model interface{}, id int) error
  • func (m *SQLiteCatalogService) GetServerByHost(host string) (*models.Server, error)
  • func (m *SQLiteCatalogService) GetUser(username string) (*models.User, error)
  • func (m *SQLiteCatalogService) GetWorkspaceByID(id int) (*models.Workspace, error)
  • func (m *SQLiteCatalogService) GetWorkspaceByName(name string) (*models.Workspace, error)
  • func (m *SQLiteCatalogService) UpdateIndex(index *models.Index) error

Types

type BadgerService

type BadgerService struct {
	Db *badger.DB
}

BadgerService struct đại diện cho một dịch vụ lưu trữ dữ liệu sử dụng Badger Một key có dạng <collection_id>||<key>

func NewBadgerService

func NewBadgerService(cfg *config.Config) (*BadgerService, error)

NewBadgerService tạo một instance mới của BadgerService và mở kết nối tới cơ sở dữ liệu Badger

func (*BadgerService) Close

func (bs *BadgerService) Close() error

Close đóng kết nối tới cơ sở dữ liệu Badger

func (*BadgerService) Delete

func (bs *BadgerService) Delete(key []byte) error

Delete xóa một cặp khóa-giá trị từ cơ sở dữ liệu Badger

func (*BadgerService) Get

func (bs *BadgerService) Get(key []byte) ([]byte, error)

Get đọc giá trị từ cơ sở dữ liệu Badger dựa trên khóa

func (*BadgerService) GetAllBadger

func (bs *BadgerService) GetAllBadger() ([]map[string]interface{}, error)

func (*BadgerService) Set

func (bs *BadgerService) Set(key, value []byte) error

Set ghi một cặp khóa-giá trị vào cơ sở dữ liệu Badger

type BboltService

type BboltService struct {
	DbConnection map[string]*bbolt.DB
	// contains filtered or unexported fields
}

func NewBboltService

func NewBboltService(cfg *config.Config) (*BboltService, error)

func (*BboltService) CreateIndex

func (bs *BboltService) CreateIndex(index *models.Index) error

CreateIndex tạo một cơ sở dữ liệu mới với tên file là collection_id_<collection_id>_table_id_<table_id>.db

func (*BboltService) Delete

func (bs *BboltService) Delete(filename string, bucket, key []byte) error

Delete dữ liệu từ bbolt database

func (*BboltService) Get

func (bs *BboltService) Get(filename string, bucket, key []byte) ([]byte, error)

Get dữ liệu từ bbolt database

func (*BboltService) GetAllBbolt

func (bs *BboltService) GetAllBbolt() ([]map[string]interface{}, error)

GetAllBbolt lấy tất cả dữ liệu từ tất cả các bucket trong tất cả các cơ sở dữ liệu

func (*BboltService) GetAndParseAsNode

func (bs *BboltService) GetAndParseAsNode(filename string, bucket, key []byte) (*models.Node, error)

GetAndParseAsNode lấy dữ liệu từ bbolt database và parse thành models.Node

func (*BboltService) GetFileNameFromIndex

func (bs *BboltService) GetFileNameFromIndex(index *models.Index) string

Hàm lấy filename từ models.Index

func (*BboltService) Set

func (bs *BboltService) Set(filename string, bucket, key, value []byte) error

Set dữ liệu vào bbolt database

func (*BboltService) SetNode

func (bs *BboltService) SetNode(filename string, bucket []byte, node *models.Node) error

SetNode lưu models.Node vào bbolt database

type ParquetService

type ParquetService struct{}

ParquetManager quản lý các hoạt động liên quan đến tệp Parquet

func NewParquetService

func NewParquetService() (*ParquetService, error)

NewParquetManager tạo một instance mới của ParquetManager

type QueueManager

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

QueueManager to manage multiple queues

func NewQueueManager

func NewQueueManager() *QueueManager

NewQueueManager creates a new QueueManager

func (*QueueManager) AddToQueue

func (qm *QueueManager) AddToQueue(name string, item map[string]interface{})

AddToQueue adds an item to a specific queue by name

func (*QueueManager) GetAllCurrentQueueAndTheirFirstData

func (qm *QueueManager) GetAllCurrentQueueAndTheirFirstData() map[string]map[string]interface{}

func (*QueueManager) GetFromQueue

func (qm *QueueManager) GetFromQueue(name string) map[string]interface{}

GetFromQueue retrieves and removes an item from a specific queue by name

func (*QueueManager) GetOrCreateQueue

func (qm *QueueManager) GetOrCreateQueue(name string) *deque.Deque[map[string]interface{}]

GetOrCreateQueue retrieves an existing queue or creates a new one if not exists

type SQLiteCatalogService

type SQLiteCatalogService struct {
	Db *gorm.DB
}

func NewSQLiteCatalogService

func NewSQLiteCatalogService(cfg *config.Config) (*SQLiteCatalogService, error)

func (*SQLiteCatalogService) AddUser

func (m *SQLiteCatalogService) AddUser(username, password, role string) error

AddUser thêm người dùng mới với mật khẩu đã mã hóa

func (*SQLiteCatalogService) Close

func (m *SQLiteCatalogService) Close() error

Close đóng kết nối cơ sở dữ liệu

func (*SQLiteCatalogService) CreateCollection

func (m *SQLiteCatalogService) CreateCollection(collection *models.Collection) error

CreateCollection tạo một collection mới

func (*SQLiteCatalogService) CreateIndex

func (m *SQLiteCatalogService) CreateIndex(index *models.Index) error

func (*SQLiteCatalogService) CreateShard

func (m *SQLiteCatalogService) CreateShard(shard *models.Shard) error

Tạo shard mới

func (*SQLiteCatalogService) CreateWorkspace

func (m *SQLiteCatalogService) CreateWorkspace(workspace *models.Workspace) error

CreatWorkspace

func (*SQLiteCatalogService) GetCollectionByID

func (m *SQLiteCatalogService) GetCollectionByID(id int) (*models.Collection, error)

func (*SQLiteCatalogService) GetCollectionByName

func (m *SQLiteCatalogService) GetCollectionByName(name string) (*models.Collection, error)

func (*SQLiteCatalogService) GetIndexByID

func (m *SQLiteCatalogService) GetIndexByID(id int) (*models.Index, error)

func (*SQLiteCatalogService) GetIndexesByServer

func (m *SQLiteCatalogService) GetIndexesByServer(server string) ([]models.Index, error)

func (*SQLiteCatalogService) GetModelWithAllAssociations

func (m *SQLiteCatalogService) GetModelWithAllAssociations(model interface{}, id int) error

Hàm chung để preload tất cả các quan hệ của một model đầu vào

func (*SQLiteCatalogService) GetServerByHost

func (m *SQLiteCatalogService) GetServerByHost(host string) (*models.Server, error)

Lấy Server theo host

func (*SQLiteCatalogService) GetUser

func (m *SQLiteCatalogService) GetUser(username string) (*models.User, error)

GetUser lấy thông tin người dùng từ cơ sở dữ liệu

func (*SQLiteCatalogService) GetWorkspaceByID

func (m *SQLiteCatalogService) GetWorkspaceByID(id int) (*models.Workspace, error)

func (*SQLiteCatalogService) GetWorkspaceByName

func (m *SQLiteCatalogService) GetWorkspaceByName(name string) (*models.Workspace, error)

Lấy workspace theo tên

func (*SQLiteCatalogService) UpdateIndex

func (m *SQLiteCatalogService) UpdateIndex(index *models.Index) error

UpdateIndex cập nhật thông tin index