service

Documentation

Index

• func CheckDomainExists(kusciaclient kusciaclientset.Interface, domainId string) (kusciaError weberrorcode.KusciaErrorCode, errorMsg string)
• func GetRoleAndDomainFromCtx(ctx context.Context) (role, domain string)
• type IDomainDataGrantService
  • func NewDomainDataGrantService(config *config.KusciaAPIConfig) IDomainDataGrantService
• type IDomainDataService
  • func NewDomainDataService(config *config.KusciaAPIConfig) IDomainDataService
• type IDomainDataSourceService
  • func NewDomainDataSourceService(config *config.KusciaAPIConfig, ...) 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 IServingService
  • func NewServingService(config *config.KusciaAPIConfig) IServingService
• type RequestWithDomainID
• type RequestWithDstAndSrc

Functions

func CheckDomainExists

func CheckDomainExists(kusciaclient kusciaclientset.Interface, domainId string) (kusciaError weberrorcode.KusciaErrorCode, errorMsg string)

func GetRoleAndDomainFromCtx

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

Types

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
}

func NewDomainDataSourceService

func NewDomainDataSourceService(config *config.KusciaAPIConfig, configurationService cmservice.IConfigurationService) 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 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
}