application

package
v0.0.0-...-271e206 Latest Latest
Warning

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

 Go to latest Published: Sep 25, 2025 License: Apache-2.0 Imports: 57 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitTagApplication 

func InitTagApplication(idgen2 idgen.IIDGenerator, db2 db.Provider, cmdable redis.Cmdable, configLoader conf.IConfigLoader, userClient userservice.Client, authAdapter rpc.IAuthProvider) (tag.TagService, error)

func NewItemProviderDAO 

func NewItemProviderDAO(batchObjectStorage fileserver.BatchObjectStorage) map[entity.Provider]item_dao.ItemDAO

func NewTagApplicationImpl 

func NewTagApplicationImpl(tagSvc service.ITagService, tagRepo repo2.ITagAPI, auth rpc.IAuthProvider, userInfoService userinfo.UserInfoService) tag.TagService

Types

type DatasetApplicationImpl 

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

func (*DatasetApplicationImpl) BatchCreateDatasetItems 

func (h *DatasetApplicationImpl) BatchCreateDatasetItems(ctx context.Context, req *dataset.BatchCreateDatasetItemsRequest) (resp *dataset.BatchCreateDatasetItemsResponse, err error)

func (*DatasetApplicationImpl) BatchDeleteDatasetItems 

func (h *DatasetApplicationImpl) BatchDeleteDatasetItems(ctx context.Context, req *dataset.BatchDeleteDatasetItemsRequest) (resp *dataset.BatchDeleteDatasetItemsResponse, err error)

func (*DatasetApplicationImpl) BatchGetDatasetItems 

func (h *DatasetApplicationImpl) BatchGetDatasetItems(ctx context.Context, req *dataset.BatchGetDatasetItemsRequest) (resp *dataset.BatchGetDatasetItemsResponse, err error)

func (*DatasetApplicationImpl) BatchGetDatasetItemsByVersion 

func (h *DatasetApplicationImpl) BatchGetDatasetItemsByVersion(ctx context.Context, req *dataset.BatchGetDatasetItemsByVersionRequest) (resp *dataset.BatchGetDatasetItemsByVersionResponse, err error)

func (*DatasetApplicationImpl) BatchGetDatasetVersions 

func (h *DatasetApplicationImpl) BatchGetDatasetVersions(ctx context.Context, req *dataset.BatchGetDatasetVersionsRequest) (resp *dataset.BatchGetDatasetVersionsResponse, err error)

func (*DatasetApplicationImpl) BatchGetDatasets 

func (h *DatasetApplicationImpl) BatchGetDatasets(ctx context.Context, req *dataset.BatchGetDatasetsRequest) (r *dataset.BatchGetDatasetsResponse, err error)

func (*DatasetApplicationImpl) ClearDatasetItem 

func (h *DatasetApplicationImpl) ClearDatasetItem(ctx context.Context, req *dataset.ClearDatasetItemRequest) (r *dataset.ClearDatasetItemResponse, err error)

func (*DatasetApplicationImpl) CreateDataset 

func (h *DatasetApplicationImpl) CreateDataset(ctx context.Context, req *dataset.CreateDatasetRequest) (resp *dataset.CreateDatasetResponse, err error)

func (*DatasetApplicationImpl) CreateDatasetVersion 

func (h *DatasetApplicationImpl) CreateDatasetVersion(ctx context.Context, req *dataset.CreateDatasetVersionRequest) (resp *dataset.CreateDatasetVersionResponse, err error)

func (*DatasetApplicationImpl) DeleteDataset 

func (h *DatasetApplicationImpl) DeleteDataset(ctx context.Context, req *dataset.DeleteDatasetRequest) (resp *dataset.DeleteDatasetResponse, err error)

func (*DatasetApplicationImpl) DeleteDatasetItem 

func (h *DatasetApplicationImpl) DeleteDatasetItem(ctx context.Context, req *dataset.DeleteDatasetItemRequest) (resp *dataset.DeleteDatasetItemResponse, err error)

func (*DatasetApplicationImpl) GetDataset 

func (h *DatasetApplicationImpl) GetDataset(ctx context.Context, req *dataset.GetDatasetRequest) (resp *dataset.GetDatasetResponse, err error)

func (*DatasetApplicationImpl) GetDatasetIOJob 

func (h *DatasetApplicationImpl) GetDatasetIOJob(ctx context.Context, req *dataset.GetDatasetIOJobRequest) (r *dataset.GetDatasetIOJobResponse, err error)

func (*DatasetApplicationImpl) GetDatasetItem 

func (h *DatasetApplicationImpl) GetDatasetItem(ctx context.Context, req *dataset.GetDatasetItemRequest) (resp *dataset.GetDatasetItemResponse, err error)

func (*DatasetApplicationImpl) GetDatasetSchema 

func (h *DatasetApplicationImpl) GetDatasetSchema(ctx context.Context, req *dataset.GetDatasetSchemaRequest) (resp *dataset.GetDatasetSchemaResponse, err error)

func (*DatasetApplicationImpl) GetDatasetVersion 

func (h *DatasetApplicationImpl) GetDatasetVersion(ctx context.Context, req *dataset.GetDatasetVersionRequest) (resp *dataset.GetDatasetVersionResponse, err error)

func (*DatasetApplicationImpl) ImportDataset 

func (h *DatasetApplicationImpl) ImportDataset(ctx context.Context, req *dataset.ImportDatasetRequest) (r *dataset.ImportDatasetResponse, err error)

func (*DatasetApplicationImpl) ListDatasetIOJobs 

func (h *DatasetApplicationImpl) ListDatasetIOJobs(ctx context.Context, req *dataset.ListDatasetIOJobsRequest) (r *dataset.ListDatasetIOJobsResponse, err error)

func (*DatasetApplicationImpl) ListDatasetItems 

func (h *DatasetApplicationImpl) ListDatasetItems(ctx context.Context, req *dataset.ListDatasetItemsRequest) (resp *dataset.ListDatasetItemsResponse, err error)

func (*DatasetApplicationImpl) ListDatasetItemsByVersion 

func (h *DatasetApplicationImpl) ListDatasetItemsByVersion(ctx context.Context, req *dataset.ListDatasetItemsByVersionRequest) (resp *dataset.ListDatasetItemsByVersionResponse, err error)

func (*DatasetApplicationImpl) ListDatasetVersions 

func (h *DatasetApplicationImpl) ListDatasetVersions(ctx context.Context, req *dataset.ListDatasetVersionsRequest) (resp *dataset.ListDatasetVersionsResponse, err error)

func (*DatasetApplicationImpl) ListDatasets 

func (h *DatasetApplicationImpl) ListDatasets(ctx context.Context, req *dataset.ListDatasetsRequest) (resp *dataset.ListDatasetsResponse, err error)

func (*DatasetApplicationImpl) RunIOJob 

func (h *DatasetApplicationImpl) RunIOJob(ctx context.Context, msg *entity.JobRunMessage) error

func (*DatasetApplicationImpl) RunSnapshotItemJob 

func (h *DatasetApplicationImpl) RunSnapshotItemJob(ctx context.Context, msg *entity.JobRunMessage) error

func (*DatasetApplicationImpl) UpdateDataset 

func (h *DatasetApplicationImpl) UpdateDataset(ctx context.Context, req *dataset.UpdateDatasetRequest) (resp *dataset.UpdateDatasetResponse, err error)

func (*DatasetApplicationImpl) UpdateDatasetItem 

func (h *DatasetApplicationImpl) UpdateDatasetItem(ctx context.Context, req *dataset.UpdateDatasetItemRequest) (resp *dataset.UpdateDatasetItemResponse, err error)

func (*DatasetApplicationImpl) UpdateDatasetSchema 

func (h *DatasetApplicationImpl) UpdateDatasetSchema(ctx context.Context, req *dataset.UpdateDatasetSchemaRequest) (resp *dataset.UpdateDatasetSchemaResponse, err error)

func (*DatasetApplicationImpl) ValidateDatasetItems 

func (h *DatasetApplicationImpl) ValidateDatasetItems(ctx context.Context, req *dataset.ValidateDatasetItemsReq) (r *dataset.ValidateDatasetItemsResp, err error)

type IDatasetApplication 

type IDatasetApplication interface {
	data.DatasetService
	IJobRunMsgHandler
}

func InitDatasetApplication 

func InitDatasetApplication(idgen2 idgen.IIDGenerator, db2 db.Provider, cmdable redis.Cmdable, configFactory conf.IConfigLoaderFactory, configLoader conf.IConfigLoader, mqFactory mq.IFactory, objectStorage fileserver.ObjectStorage, batchObjectStorage fileserver.BatchObjectStorage, auditClient audit.IAuditService, authClient authservice.Client) (IDatasetApplication, error)

func NewDatasetApplicationImpl 

func NewDatasetApplicationImpl(auth rpc.IAuthProvider, svc service.IDatasetAPI, repo repo.IDatasetAPI, auditClient audit.IAuditService) IDatasetApplication

type IJobRunMsgHandler 

type IJobRunMsgHandler interface {
	RunSnapshotItemJob(ctx context.Context, msg *entity.JobRunMessage) error
	RunIOJob(ctx context.Context, msg *entity.JobRunMessage) error
}

type TagApplicationImpl 

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

func (*TagApplicationImpl) ArchiveOptionTag 

func (t *TagApplicationImpl) ArchiveOptionTag(ctx context.Context, req *tag.ArchiveOptionTagRequest) (r *tag.ArchiveOptionTagResponse, err error)

func (*TagApplicationImpl) BatchGetTags 

func (t *TagApplicationImpl) BatchGetTags(ctx context.Context, req *tag.BatchGetTagsRequest) (r *tag.BatchGetTagsResponse, err error)

func (*TagApplicationImpl) BatchUpdateTagStatus 

func (t *TagApplicationImpl) BatchUpdateTagStatus(ctx context.Context, req *tag.BatchUpdateTagStatusRequest) (r *tag.BatchUpdateTagStatusResponse, err error)

func (*TagApplicationImpl) CreateTag 

func (t *TagApplicationImpl) CreateTag(ctx context.Context, req *tag.CreateTagRequest) (r *tag.CreateTagResponse, err error)

func (*TagApplicationImpl) GetTagDetail 

func (t *TagApplicationImpl) GetTagDetail(ctx context.Context, req *tag.GetTagDetailRequest) (r *tag.GetTagDetailResponse, err error)

func (*TagApplicationImpl) GetTagSpec 

func (t *TagApplicationImpl) GetTagSpec(ctx context.Context, req *tag.GetTagSpecRequest) (r *tag.GetTagSpecResponse, err error)

func (*TagApplicationImpl) SearchTags 

func (t *TagApplicationImpl) SearchTags(ctx context.Context, req *tag.SearchTagsRequest) (r *tag.SearchTagsResponse, err error)

func (*TagApplicationImpl) UpdateTag 

func (t *TagApplicationImpl) UpdateTag(ctx context.Context, req *tag.UpdateTagRequest) (r *tag.UpdateTagResponse, err error)

Source Files

View all Source files

Directories

Path Synopsis
convertor
common
dataset

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.