service

Documentation

Index

• Constants
• func CheckDomainDataSourceExists(kusciaClient kusciaclientset.Interface, domainID, domainDataSourceID string) (kusciaError pberrorcode.ErrorCode, errorMsg string)
• func CheckDomainExists(kusciaClient kusciaclientset.Interface, domainID string) (kusciaError pberrorcode.ErrorCode, errorMsg string)
• func GetRoleAndDomainFromCtx(ctx context.Context) (role, domain string)
• type IAppImageService
  • func NewAppImageService(config *config.KusciaAPIConfig) IAppImageService
• type IConfigService
  • func NewConfigService(conf *config.KusciaAPIConfig, cmConfigService cmservice.IConfigService) IConfigService
• type IDomainDataGrantService
  • func NewDomainDataGrantService(config *config.KusciaAPIConfig) IDomainDataGrantService
• type IDomainDataService
  • func NewDomainDataService(config *config.KusciaAPIConfig) IDomainDataService
• type IDomainDataSourceService
  • func NewDomainDataSourceService(config *config.KusciaAPIConfig, configService cmservice.IConfigService) IDomainDataSourceService
• type IDomainRouteService
  • func NewDomainRouteService(config *config.KusciaAPIConfig) IDomainRouteService
• type IDomainService
  • func NewDomainService(config *config.KusciaAPIConfig) IDomainService
• type IHealthService
  • func NewHealthService() IHealthService
• type IJobService
  • func NewJobService(config *config.KusciaAPIConfig) IJobService
• type ILogService
  • func NewLogService(config *config.KusciaAPIConfig) ILogService
• type IServingService
  • func NewServingService(config *config.KusciaAPIConfig) IServingService
• type RequestWithDomainID
• type RequestWithDstAndSrc

Constants

const (
	QueryLogPath  = "/api/v1/log/task/query"
	OutputLineNum = 100
	OutputPeriod  = 5 * time.Second
)

Functions

func CheckDomainDataSourceExists

func CheckDomainDataSourceExists(kusciaClient kusciaclientset.Interface, domainID, domainDataSourceID string) (kusciaError pberrorcode.ErrorCode, errorMsg string)

func CheckDomainExists

func CheckDomainExists(kusciaClient kusciaclientset.Interface, domainID string) (kusciaError pberrorcode.ErrorCode, errorMsg string)

func GetRoleAndDomainFromCtx

func GetRoleAndDomainFromCtx(ctx context.Context) (role, domain string)

Types

type IAppImageService

type IAppImageService interface {
	CreateAppImage(ctx context.Context, request *kusciaapi.CreateAppImageRequest) *kusciaapi.CreateAppImageResponse
	QueryAppImage(ctx context.Context, request *kusciaapi.QueryAppImageRequest) *kusciaapi.QueryAppImageResponse
	UpdateAppImage(ctx context.Context, request *kusciaapi.UpdateAppImageRequest) *kusciaapi.UpdateAppImageResponse
	DeleteAppImage(ctx context.Context, request *kusciaapi.DeleteAppImageRequest) *kusciaapi.DeleteAppImageResponse
	BatchQueryAppImage(ctx context.Context, request *kusciaapi.BatchQueryAppImageRequest) *kusciaapi.BatchQueryAppImageResponse
}

func NewAppImageService

func NewAppImageService(config *config.KusciaAPIConfig) IAppImageService

type IConfigService

type IConfigService interface {
	CreateConfig(ctx context.Context, request *kusciaapi.CreateConfigRequest) *kusciaapi.CreateConfigResponse
	QueryConfig(ctx context.Context, request *kusciaapi.QueryConfigRequest) *kusciaapi.QueryConfigResponse
	BatchQueryConfig(ctx context.Context, request *kusciaapi.BatchQueryConfigRequest) *kusciaapi.BatchQueryConfigResponse
	UpdateConfig(ctx context.Context, request *kusciaapi.UpdateConfigRequest) *kusciaapi.UpdateConfigResponse
	DeleteConfig(ctx context.Context, request *kusciaapi.DeleteConfigRequest) *kusciaapi.DeleteConfigResponse
}

func NewConfigService

func NewConfigService(conf *config.KusciaAPIConfig, cmConfigService cmservice.IConfigService) IConfigService

type IDomainDataGrantService

type IDomainDataGrantService interface {
	CreateDomainDataGrant(ctx context.Context, request *kusciaapi.CreateDomainDataGrantRequest) *kusciaapi.CreateDomainDataGrantResponse
	QueryDomainDataGrant(ctx context.Context, request *kusciaapi.QueryDomainDataGrantRequest) *kusciaapi.QueryDomainDataGrantResponse
	UpdateDomainDataGrant(ctx context.Context, request *kusciaapi.UpdateDomainDataGrantRequest) *kusciaapi.UpdateDomainDataGrantResponse
	DeleteDomainDataGrant(ctx context.Context, request *kusciaapi.DeleteDomainDataGrantRequest) *kusciaapi.DeleteDomainDataGrantResponse
	BatchQueryDomainDataGrant(ctx context.Context, request *kusciaapi.BatchQueryDomainDataGrantRequest) *kusciaapi.BatchQueryDomainDataGrantResponse
	ListDomainDataGrant(ctx context.Context, request *kusciaapi.ListDomainDataGrantRequest) *kusciaapi.ListDomainDataGrantResponse
}

func NewDomainDataGrantService

func NewDomainDataGrantService(config *config.KusciaAPIConfig) IDomainDataGrantService

type IDomainDataService

type IDomainDataService interface {
	CreateDomainData(ctx context.Context, request *kusciaapi.CreateDomainDataRequest) *kusciaapi.CreateDomainDataResponse
	UpdateDomainData(ctx context.Context, request *kusciaapi.UpdateDomainDataRequest) *kusciaapi.UpdateDomainDataResponse
	DeleteDomainData(ctx context.Context, request *kusciaapi.DeleteDomainDataRequest) *kusciaapi.DeleteDomainDataResponse
	QueryDomainData(ctx context.Context, request *kusciaapi.QueryDomainDataRequest) *kusciaapi.QueryDomainDataResponse
	BatchQueryDomainData(ctx context.Context, request *kusciaapi.BatchQueryDomainDataRequest) *kusciaapi.BatchQueryDomainDataResponse
	ListDomainData(ctx context.Context, request *kusciaapi.ListDomainDataRequest) *kusciaapi.ListDomainDataResponse
}

func NewDomainDataService

func NewDomainDataService(config *config.KusciaAPIConfig) IDomainDataService

type IDomainDataSourceService

type IDomainDataSourceService interface {
	CreateDomainDataSource(ctx context.Context, request *kusciaapi.CreateDomainDataSourceRequest) *kusciaapi.CreateDomainDataSourceResponse
	UpdateDomainDataSource(ctx context.Context, request *kusciaapi.UpdateDomainDataSourceRequest) *kusciaapi.UpdateDomainDataSourceResponse
	DeleteDomainDataSource(ctx context.Context, request *kusciaapi.DeleteDomainDataSourceRequest) *kusciaapi.DeleteDomainDataSourceResponse
	QueryDomainDataSource(ctx context.Context, request *kusciaapi.QueryDomainDataSourceRequest) *kusciaapi.QueryDomainDataSourceResponse
	BatchQueryDomainDataSource(ctx context.Context, request *kusciaapi.BatchQueryDomainDataSourceRequest) *kusciaapi.BatchQueryDomainDataSourceResponse
	ListDomainDataSource(ctx context.Context, request *kusciaapi.ListDomainDataSourceRequest) *kusciaapi.ListDomainDataSourceResponse
}

func NewDomainDataSourceService

func NewDomainDataSourceService(config *config.KusciaAPIConfig, configService cmservice.IConfigService) IDomainDataSourceService

type IDomainRouteService

type IDomainRouteService interface {
	CreateDomainRoute(ctx context.Context, request *kusciaapi.CreateDomainRouteRequest) *kusciaapi.CreateDomainRouteResponse
	DeleteDomainRoute(ctx context.Context, request *kusciaapi.DeleteDomainRouteRequest) *kusciaapi.DeleteDomainRouteResponse
	QueryDomainRoute(ctx context.Context, request *kusciaapi.QueryDomainRouteRequest) *kusciaapi.QueryDomainRouteResponse
	BatchQueryDomainRouteStatus(ctx context.Context, request *kusciaapi.BatchQueryDomainRouteStatusRequest) *kusciaapi.BatchQueryDomainRouteStatusResponse
}

func NewDomainRouteService

func NewDomainRouteService(config *config.KusciaAPIConfig) IDomainRouteService

type IDomainService

type IDomainService interface {
	CreateDomain(ctx context.Context, request *kusciaapi.CreateDomainRequest) *kusciaapi.CreateDomainResponse
	QueryDomain(ctx context.Context, request *kusciaapi.QueryDomainRequest) *kusciaapi.QueryDomainResponse
	UpdateDomain(ctx context.Context, request *kusciaapi.UpdateDomainRequest) *kusciaapi.UpdateDomainResponse
	DeleteDomain(ctx context.Context, request *kusciaapi.DeleteDomainRequest) *kusciaapi.DeleteDomainResponse
	BatchQueryDomain(ctx context.Context, request *kusciaapi.BatchQueryDomainRequest) *kusciaapi.BatchQueryDomainResponse
}

func NewDomainService

func NewDomainService(config *config.KusciaAPIConfig) IDomainService

type IHealthService

type IHealthService interface {
	HealthZ(ctx context.Context, request *kusciaapi.HealthRequest) *kusciaapi.HealthResponse
}

func NewHealthService

func NewHealthService() IHealthService

type IJobService

type IJobService interface {
	CreateJob(ctx context.Context, request *kusciaapi.CreateJobRequest) *kusciaapi.CreateJobResponse
	QueryJob(ctx context.Context, request *kusciaapi.QueryJobRequest) *kusciaapi.QueryJobResponse
	BatchQueryJobStatus(ctx context.Context, request *kusciaapi.BatchQueryJobStatusRequest) *kusciaapi.BatchQueryJobStatusResponse
	StopJob(ctx context.Context, request *kusciaapi.StopJobRequest) *kusciaapi.StopJobResponse
	DeleteJob(ctx context.Context, request *kusciaapi.DeleteJobRequest) *kusciaapi.DeleteJobResponse
	WatchJob(ctx context.Context, request *kusciaapi.WatchJobRequest, event chan<- *kusciaapi.WatchJobEventResponse) error
	ApproveJob(ctx context.Context, request *kusciaapi.ApproveJobRequest) *kusciaapi.ApproveJobResponse
	SuspendJob(ctx context.Context, request *kusciaapi.SuspendJobRequest) *kusciaapi.SuspendJobResponse
	RestartJob(ctx context.Context, request *kusciaapi.RestartJobRequest) *kusciaapi.RestartJobResponse
	CancelJob(ctx context.Context, request *kusciaapi.CancelJobRequest) *kusciaapi.CancelJobResponse
}

func NewJobService

func NewJobService(config *config.KusciaAPIConfig) IJobService

type ILogService

type ILogService interface {
	QueryTaskLog(ctx context.Context, request *kusciaapi.QueryLogRequest, eventCh chan<- *kusciaapi.QueryLogResponse)
	QueryPodNode(ctx context.Context, request *kusciaapi.QueryPodNodeRequest) *kusciaapi.QueryPodNodeResponse
}

func NewLogService

func NewLogService(config *config.KusciaAPIConfig) ILogService

type IServingService

type IServingService interface {
	CreateServing(ctx context.Context, request *kusciaapi.CreateServingRequest) *kusciaapi.CreateServingResponse
	QueryServing(ctx context.Context, request *kusciaapi.QueryServingRequest) *kusciaapi.QueryServingResponse
	BatchQueryServingStatus(ctx context.Context, request *kusciaapi.BatchQueryServingStatusRequest) *kusciaapi.BatchQueryServingStatusResponse
	UpdateServing(ctx context.Context, request *kusciaapi.UpdateServingRequest) *kusciaapi.UpdateServingResponse
	DeleteServing(ctx context.Context, request *kusciaapi.DeleteServingRequest) *kusciaapi.DeleteServingResponse
}

func NewServingService

func NewServingService(config *config.KusciaAPIConfig) IServingService

type RequestWithDomainID

type RequestWithDomainID interface {
	GetDomainId() string
}

type RequestWithDstAndSrc

type RequestWithDstAndSrc interface {
	GetDestination() string
	GetSource() string
}