proxy

package
v0.0.0-...-a1208dc Latest Latest
Warning

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

 Go to latest Published: Dec 30, 2024 License: Apache-2.0 Imports: 11 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	// Domain
	UpdateDomainPath     = "/api/v1/domain/update"
	QueryDomainPath      = "/api/v1/domain/query"
	BatchQueryDomainPath = "/api/v1/domain/batchQuery"
	// Domain Route
	CreateDomainRoutePath     = "/api/v1/route/create"
	DeleteDomainRoutePath     = "/api/v1/route/delete"
	QueryDomainRoutePath      = "/api/v1/route/query"
	BatchQueryDomainRoutePath = "/api/v1/route/status/batchQuery"
	// Domain Data
	CreateDomainDataPath     = "/api/v1/domaindata/create"
	UpdateDomainDataPath     = "/api/v1/domaindata/update"
	DeleteDomainDataPath     = "/api/v1/domaindata/delete"
	QueryDomainDataPath      = "/api/v1/domaindata/query"
	BatchQueryDomainDataPath = "/api/v1/domaindata/batchQuery"
	ListDomainDataPath       = "/api/v1/domaindata/list"
	// Kuscia Job
	CreateJobPath     = "/api/v1/job/create"
	DeleteJobPath     = "/api/v1/job/delete"
	QueryJobPath      = "/api/v1/job/query"
	StopJobPath       = "/api/v1/job/stop"
	SuspendJobPath    = "/api/v1/job/suspend"
	RestartJobPath    = "/api/v1/job/restart"
	CancelJobPath     = "/api/v1/job/cancel"
	ApproveJobPath    = "/api/v1/job/approve"
	BatchQueryJobPath = "/api/v1/job/status/batchQuery"
	WatchJobPath      = "/api/v1/job/watch"
	// Log
	QueryPodNodePath = "/api/v1/log/node/query"

	// Kuscia Serving
	CreateServingPath     = "/api/v1/serving/create"
	UpdateServingPath     = "/api/v1/serving/update"
	DeleteServingPath     = "/api/v1/serving/delete"
	QueryServingPath      = "/api/v1/serving/query"
	BatchQueryServingPath = "/api/v1/serving/status/batchQuery"
	// AppImage
	CreateAppImagePath = "/api/v1/appimage/create"
	UpdateAppImagePath = "/api/v1/appimage/update"
	DeleteAppImagePath = "/api/v1/appimage/delete"
	QueryAppImagePath  = "/api/v1/appimage/query"
	// KusciaAPIHostName kuscia API service name
	KusciaAPIHostName = "kusciaapi.master.svc"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type KusciaAPIClient 

type KusciaAPIClient interface {
	Send(ctx context.Context, request proto.Message, response proto.Message, path string) error

	UpdateDomain(ctx context.Context, request *kusciaapi.UpdateDomainRequest) (response *kusciaapi.UpdateDomainResponse, err error)

	QueryDomain(ctx context.Context, request *kusciaapi.QueryDomainRequest) (response *kusciaapi.QueryDomainResponse, err error)

	BatchQueryDomain(ctx context.Context, request *kusciaapi.BatchQueryDomainRequest) (response *kusciaapi.BatchQueryDomainResponse, err error)

	CreateDomainRoute(ctx context.Context, request *kusciaapi.CreateDomainRouteRequest) (response *kusciaapi.CreateDomainRouteResponse, err error)

	DeleteDomainRoute(ctx context.Context, request *kusciaapi.DeleteDomainRouteRequest) (response *kusciaapi.DeleteDomainRouteResponse, err error)

	QueryDomainRoute(ctx context.Context, request *kusciaapi.QueryDomainRouteRequest) (response *kusciaapi.QueryDomainRouteResponse, err error)

	BatchQueryDomainRoute(ctx context.Context, request *kusciaapi.BatchQueryDomainRouteStatusRequest) (response *kusciaapi.BatchQueryDomainRouteStatusResponse, err error)

	CreateDomainData(ctx context.Context, request *kusciaapi.CreateDomainDataRequest) (response *kusciaapi.CreateDomainDataResponse, err error)

	UpdateDomainData(ctx context.Context, request *kusciaapi.UpdateDomainDataRequest) (response *kusciaapi.UpdateDomainDataResponse, err error)

	DeleteDomainData(ctx context.Context, request *kusciaapi.DeleteDomainDataRequest) (response *kusciaapi.DeleteDomainDataResponse, err error)

	QueryDomainData(ctx context.Context, request *kusciaapi.QueryDomainDataRequest) (response *kusciaapi.QueryDomainDataResponse, err error)

	BatchQueryDomainData(ctx context.Context, request *kusciaapi.BatchQueryDomainDataRequest) (response *kusciaapi.BatchQueryDomainDataResponse, err error)

	ListDomainData(ctx context.Context, request *kusciaapi.ListDomainDataRequest) (response *kusciaapi.ListDomainDataResponse, err error)

	CreateJob(ctx context.Context, request *kusciaapi.CreateJobRequest) (response *kusciaapi.CreateJobResponse, err error)

	DeleteJob(ctx context.Context, request *kusciaapi.DeleteJobRequest) (response *kusciaapi.DeleteJobResponse, err error)

	QueryJob(ctx context.Context, request *kusciaapi.QueryJobRequest) (response *kusciaapi.QueryJobResponse, err error)

	StopJob(ctx context.Context, request *kusciaapi.StopJobRequest) (response *kusciaapi.StopJobResponse, err error)

	SuspendJob(ctx context.Context, request *kusciaapi.SuspendJobRequest) (response *kusciaapi.SuspendJobResponse, err error)

	RestartJob(ctx context.Context, request *kusciaapi.RestartJobRequest) (response *kusciaapi.RestartJobResponse, err error)

	CancelJob(ctx context.Context, request *kusciaapi.CancelJobRequest) (response *kusciaapi.CancelJobResponse, err error)

	BatchQueryJob(ctx context.Context, request *kusciaapi.BatchQueryJobStatusRequest) (response *kusciaapi.BatchQueryJobStatusResponse, err error)

	WatchJob(ctx context.Context, request *kusciaapi.WatchJobRequest, eventCh chan<- *kusciaapi.WatchJobEventResponse) error

	CreateServing(ctx context.Context, request *kusciaapi.CreateServingRequest) (response *kusciaapi.CreateServingResponse, err error)

	UpdateServing(ctx context.Context, request *kusciaapi.UpdateServingRequest) (response *kusciaapi.UpdateServingResponse, err error)

	DeleteServing(ctx context.Context, request *kusciaapi.DeleteServingRequest) (response *kusciaapi.DeleteServingResponse, err error)

	QueryServing(ctx context.Context, request *kusciaapi.QueryServingRequest) (response *kusciaapi.QueryServingResponse, err error)

	BatchQueryServing(ctx context.Context, request *kusciaapi.BatchQueryServingStatusRequest) (response *kusciaapi.BatchQueryServingStatusResponse, err error)

	UpdateAppImage(ctx context.Context, request *kusciaapi.UpdateAppImageRequest) (response *kusciaapi.UpdateAppImageResponse, err error)

	QueryAppImage(ctx context.Context, request *kusciaapi.QueryAppImageRequest) (response *kusciaapi.QueryAppImageResponse, err error)

	ApproveJob(ctx context.Context, request *kusciaapi.ApproveJobRequest) (response *kusciaapi.ApproveJobResponse, err error)

	QueryPodNode(ctx context.Context, request *kusciaapi.QueryPodNodeRequest) (response *kusciaapi.QueryPodNodeResponse, err error)
}

func NewKusciaAPIClient 

func NewKusciaAPIClient(endpoint string) KusciaAPIClient

type KusciaAPIHttpClient 

type KusciaAPIHttpClient struct {
	HostName string
	Client   *http.Client
}

func (*KusciaAPIHttpClient) ApproveJob 

func (c *KusciaAPIHttpClient) ApproveJob(ctx context.Context, request *kusciaapi.ApproveJobRequest) (response *kusciaapi.ApproveJobResponse, err error)

func (*KusciaAPIHttpClient) BatchQueryDomain 

func (c *KusciaAPIHttpClient) BatchQueryDomain(ctx context.Context, request *kusciaapi.BatchQueryDomainRequest) (response *kusciaapi.BatchQueryDomainResponse, err error)

func (*KusciaAPIHttpClient) BatchQueryDomainData 

func (c *KusciaAPIHttpClient) BatchQueryDomainData(ctx context.Context, request *kusciaapi.BatchQueryDomainDataRequest) (response *kusciaapi.BatchQueryDomainDataResponse, err error)

func (*KusciaAPIHttpClient) BatchQueryDomainRoute 

func (c *KusciaAPIHttpClient) BatchQueryDomainRoute(ctx context.Context, request *kusciaapi.BatchQueryDomainRouteStatusRequest) (response *kusciaapi.BatchQueryDomainRouteStatusResponse, err error)

func (*KusciaAPIHttpClient) BatchQueryJob 

func (c *KusciaAPIHttpClient) BatchQueryJob(ctx context.Context, request *kusciaapi.BatchQueryJobStatusRequest) (response *kusciaapi.BatchQueryJobStatusResponse, err error)

func (*KusciaAPIHttpClient) BatchQueryServing 

func (c *KusciaAPIHttpClient) BatchQueryServing(ctx context.Context, request *kusciaapi.BatchQueryServingStatusRequest) (response *kusciaapi.BatchQueryServingStatusResponse, err error)

func (*KusciaAPIHttpClient) CancelJob 

func (c *KusciaAPIHttpClient) CancelJob(ctx context.Context, request *kusciaapi.CancelJobRequest) (response *kusciaapi.CancelJobResponse, err error)

func (*KusciaAPIHttpClient) CreateDomainData 

func (c *KusciaAPIHttpClient) CreateDomainData(ctx context.Context, request *kusciaapi.CreateDomainDataRequest) (response *kusciaapi.CreateDomainDataResponse, err error)

func (*KusciaAPIHttpClient) CreateDomainRoute 

func (c *KusciaAPIHttpClient) CreateDomainRoute(ctx context.Context, request *kusciaapi.CreateDomainRouteRequest) (response *kusciaapi.CreateDomainRouteResponse, err error)

func (*KusciaAPIHttpClient) CreateJob 

func (c *KusciaAPIHttpClient) CreateJob(ctx context.Context, request *kusciaapi.CreateJobRequest) (response *kusciaapi.CreateJobResponse, err error)

func (*KusciaAPIHttpClient) CreateServing 

func (c *KusciaAPIHttpClient) CreateServing(ctx context.Context, request *kusciaapi.CreateServingRequest) (response *kusciaapi.CreateServingResponse, err error)

func (*KusciaAPIHttpClient) DeleteDomainData 

func (c *KusciaAPIHttpClient) DeleteDomainData(ctx context.Context, request *kusciaapi.DeleteDomainDataRequest) (response *kusciaapi.DeleteDomainDataResponse, err error)

func (*KusciaAPIHttpClient) DeleteDomainRoute 

func (c *KusciaAPIHttpClient) DeleteDomainRoute(ctx context.Context, request *kusciaapi.DeleteDomainRouteRequest) (response *kusciaapi.DeleteDomainRouteResponse, err error)

func (*KusciaAPIHttpClient) DeleteJob 

func (c *KusciaAPIHttpClient) DeleteJob(ctx context.Context, request *kusciaapi.DeleteJobRequest) (response *kusciaapi.DeleteJobResponse, err error)

func (*KusciaAPIHttpClient) DeleteServing 

func (c *KusciaAPIHttpClient) DeleteServing(ctx context.Context, request *kusciaapi.DeleteServingRequest) (response *kusciaapi.DeleteServingResponse, err error)

func (*KusciaAPIHttpClient) ListDomainData 

func (c *KusciaAPIHttpClient) ListDomainData(ctx context.Context, request *kusciaapi.ListDomainDataRequest) (response *kusciaapi.ListDomainDataResponse, err error)

func (*KusciaAPIHttpClient) QueryAppImage 

func (c *KusciaAPIHttpClient) QueryAppImage(ctx context.Context, request *kusciaapi.QueryAppImageRequest) (response *kusciaapi.QueryAppImageResponse, err error)

func (*KusciaAPIHttpClient) QueryDomain 

func (c *KusciaAPIHttpClient) QueryDomain(ctx context.Context, request *kusciaapi.QueryDomainRequest) (response *kusciaapi.QueryDomainResponse, err error)

func (*KusciaAPIHttpClient) QueryDomainData 

func (c *KusciaAPIHttpClient) QueryDomainData(ctx context.Context, request *kusciaapi.QueryDomainDataRequest) (response *kusciaapi.QueryDomainDataResponse, err error)

func (*KusciaAPIHttpClient) QueryDomainRoute 

func (c *KusciaAPIHttpClient) QueryDomainRoute(ctx context.Context, request *kusciaapi.QueryDomainRouteRequest) (response *kusciaapi.QueryDomainRouteResponse, err error)

func (*KusciaAPIHttpClient) QueryJob 

func (c *KusciaAPIHttpClient) QueryJob(ctx context.Context, request *kusciaapi.QueryJobRequest) (response *kusciaapi.QueryJobResponse, err error)

func (*KusciaAPIHttpClient) QueryPodNode 

func (c *KusciaAPIHttpClient) QueryPodNode(ctx context.Context, request *kusciaapi.QueryPodNodeRequest) (response *kusciaapi.QueryPodNodeResponse, err error)

func (*KusciaAPIHttpClient) QueryServing 

func (c *KusciaAPIHttpClient) QueryServing(ctx context.Context, request *kusciaapi.QueryServingRequest) (response *kusciaapi.QueryServingResponse, err error)

func (*KusciaAPIHttpClient) RestartJob 

func (c *KusciaAPIHttpClient) RestartJob(ctx context.Context, request *kusciaapi.RestartJobRequest) (response *kusciaapi.RestartJobResponse, err error)

func (*KusciaAPIHttpClient) Send 

func (c *KusciaAPIHttpClient) Send(ctx context.Context, request proto.Message, response proto.Message, path string) error

func (*KusciaAPIHttpClient) StopJob 

func (c *KusciaAPIHttpClient) StopJob(ctx context.Context, request *kusciaapi.StopJobRequest) (response *kusciaapi.StopJobResponse, err error)

func (*KusciaAPIHttpClient) SuspendJob 

func (c *KusciaAPIHttpClient) SuspendJob(ctx context.Context, request *kusciaapi.SuspendJobRequest) (response *kusciaapi.SuspendJobResponse, err error)

func (*KusciaAPIHttpClient) UpdateAppImage 

func (c *KusciaAPIHttpClient) UpdateAppImage(ctx context.Context, request *kusciaapi.UpdateAppImageRequest) (response *kusciaapi.UpdateAppImageResponse, err error)

func (*KusciaAPIHttpClient) UpdateDomain 

func (c *KusciaAPIHttpClient) UpdateDomain(ctx context.Context, request *kusciaapi.UpdateDomainRequest) (response *kusciaapi.UpdateDomainResponse, err error)

func (*KusciaAPIHttpClient) UpdateDomainData 

func (c *KusciaAPIHttpClient) UpdateDomainData(ctx context.Context, request *kusciaapi.UpdateDomainDataRequest) (response *kusciaapi.UpdateDomainDataResponse, err error)

func (*KusciaAPIHttpClient) UpdateServing 

func (c *KusciaAPIHttpClient) UpdateServing(ctx context.Context, request *kusciaapi.UpdateServingRequest) (response *kusciaapi.UpdateServingResponse, err error)

func (*KusciaAPIHttpClient) WatchJob 

func (c *KusciaAPIHttpClient) WatchJob(ctx context.Context, request *kusciaapi.WatchJobRequest, eventCh chan<- *kusciaapi.WatchJobEventResponse) error

Source Files

View all Source files

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.