data

Documentation

Index

• type Service
  • func New(dbRepo database.Repo, promRepo prometheus.Repo, chRepo clickhouse.Repo, ...) Service

Types

type Service

type Service interface {
	GetDataSource(ctx core.Context) (response.GetDatasourceResponse, error)
	GetDataGroup(ctx core.Context, req *request.GetDataGroupRequest) (response.GetDataGroupResponse, error)
	GetGroupDatasource(ctx core.Context, req *request.GetGroupDatasourceRequest) (response.GetGroupDatasourceResponse, error)
	DataGroupOperation(ctx core.Context, req *request.DataGroupOperationRequest) error
	GetSubjectDataGroup(ctx core.Context, req *request.GetSubjectDataGroupRequest) (response.GetSubjectDataGroupResponse, error)

	CheckGroupPermission(ctx core.Context, groupID int64) (bool, error)
	CheckScopePermission(ctx core.Context, cluster, namespace, service string) (bool, error)
	CheckServicesPermission(ctx core.Context, services ...string) (bool, error)

	GroupSubsOperation(ctx core.Context, req *request.GroupSubsOperationRequest) error
	GetGroupSubs(ctx core.Context, req *request.GetGroupSubsRequest) (response.GetGroupSubsResponse, error)

	ListDataGroupV2(ctx core.Context) (*datagroup.DataGroupTreeNode, error)

	ListDataScopeByGroupID(ctx core.Context, req *request.DGScopeListRequest) (*response.ListDataScopesResponse, error)
	GetGroupDetailWithSubGroup(ctx core.Context, groupID int64) (*response.SubGroupDetailResponse, error)

	CreateDataGroupV2(ctx core.Context, req *request.CreateDataGroupRequest) error
	UpdateDataGroupV2(ctx core.Context, req *request.UpdateDataGroupRequest) error
	DeleteDataGroupV2(ctx core.Context, req *request.DeleteDataGroupRequest) error

	GetFilterByGroupID(ctx core.Context, req *request.DGFilterRequest) (*response.ListDataScopeFilterResponse, error)

	CleanExpiredDataScope(ctx core.Context, groupID int64, clean bool) (*response.CleanExpiredDataScopeResponse, error)
}

func New

func New(dbRepo database.Repo, promRepo prometheus.Repo, chRepo clickhouse.Repo, k8sRepo kubernetes.Repo) Service