client

Documentation

Index

• type AppRuntimeSyncClient
  • func NewClient(ctx context.Context, conf AppRuntimeSyncClientConf) (*AppRuntimeSyncClient, error)
  • func (a *AppRuntimeSyncClient) AddThirdPartyEndpoint(req *model.Endpoint)
  • func (a *AppRuntimeSyncClient) DelThirdPartyEndpoint(req *model.Endpoint)
  • func (a *AppRuntimeSyncClient) Error(err error)
  • func (a *AppRuntimeSyncClient) GetAllStatus() map[string]string
  • func (a *AppRuntimeSyncClient) GetAllTenantEnvResource() (*pb.TenantEnvResourceList, error)
  • func (a *AppRuntimeSyncClient) GetAppResources(appID string) (*pb.AppStatus, error)
  • func (a *AppRuntimeSyncClient) GetAppVolumeStatus(serviceID string) (*pb.ServiceVolumeStatusMessage, error)
  • func (a *AppRuntimeSyncClient) GetComponentPodNums(ctx context.Context, componentIDs []string) (map[string]int32, error)
  • func (a *AppRuntimeSyncClient) GetMultiServicePods(serviceIDs []string) (*pb.MultiServiceAppPodList, error)
  • func (a *AppRuntimeSyncClient) GetNeedBillingStatus() (map[string]string, error)
  • func (a *AppRuntimeSyncClient) GetPodDetail(sid, name string) (*pb.PodDetail, error)
  • func (a *AppRuntimeSyncClient) GetServiceDeployInfo(serviceID string) (*pb.DeployInfo, error)
  • func (a *AppRuntimeSyncClient) GetServicePods(serviceID string) (*pb.ServiceAppPodList, error)
  • func (a *AppRuntimeSyncClient) GetStatus(serviceID string) string
  • func (a *AppRuntimeSyncClient) GetStatuss(serviceIDs string) map[string]string
  • func (a *AppRuntimeSyncClient) GetStorageClasses() (storageclasses *pb.StorageClasses, err error)
  • func (a *AppRuntimeSyncClient) GetTenantEnvResource(tenantEnvID string) (*pb.TenantEnvResource, error)
  • func (a *AppRuntimeSyncClient) IsClosedStatus(curStatus string) bool
  • func (a *AppRuntimeSyncClient) ListThirdPartyEndpoints(sid string) (*pb.ThirdPartyEndpoints, error)
  • func (a *AppRuntimeSyncClient) UpdThirdPartyEndpoint(req *model.Endpoint)
• type AppRuntimeSyncClientConf

Types

type AppRuntimeSyncClient

type AppRuntimeSyncClient struct {
	pb.AppRuntimeSyncClient
	AppRuntimeSyncClientConf
	// contains filtered or unexported fields
}

AppRuntimeSyncClient grpc client

func NewClient

func NewClient(ctx context.Context, conf AppRuntimeSyncClientConf) (*AppRuntimeSyncClient, error)

NewClient new client ctx must be cancel where client not used

func (*AppRuntimeSyncClient) AddThirdPartyEndpoint

func (a *AppRuntimeSyncClient) AddThirdPartyEndpoint(req *model.Endpoint)

AddThirdPartyEndpoint -

func (*AppRuntimeSyncClient) DelThirdPartyEndpoint

func (a *AppRuntimeSyncClient) DelThirdPartyEndpoint(req *model.Endpoint)

DelThirdPartyEndpoint -

func (*AppRuntimeSyncClient) Error

func (a *AppRuntimeSyncClient) Error(err error)

when watch occurred error,will exec this method

func (*AppRuntimeSyncClient) GetAllStatus

func (a *AppRuntimeSyncClient) GetAllStatus() map[string]string

GetAllStatus get all status

func (*AppRuntimeSyncClient) GetAllTenantEnvResource

func (a *AppRuntimeSyncClient) GetAllTenantEnvResource() (*pb.TenantEnvResourceList, error)

GetAllTenantEnvResource get all tenant env resource

func (*AppRuntimeSyncClient) GetAppResources

func (a *AppRuntimeSyncClient) GetAppResources(appID string) (*pb.AppStatus, error)

GetAppResources -

func (*AppRuntimeSyncClient) GetAppVolumeStatus

func (a *AppRuntimeSyncClient) GetAppVolumeStatus(serviceID string) (*pb.ServiceVolumeStatusMessage, error)

GetAppVolumeStatus get app volume status

func (*AppRuntimeSyncClient) GetComponentPodNums

func (a *AppRuntimeSyncClient) GetComponentPodNums(ctx context.Context, componentIDs []string) (map[string]int32, error)

GetComponentPodNums -

func (*AppRuntimeSyncClient) GetMultiServicePods

func (a *AppRuntimeSyncClient) GetMultiServicePods(serviceIDs []string) (*pb.MultiServiceAppPodList, error)

GetMultiServicePods get multi service pods list

func (*AppRuntimeSyncClient) GetNeedBillingStatus

func (a *AppRuntimeSyncClient) GetNeedBillingStatus() (map[string]string, error)

GetNeedBillingStatus get need billing status

func (*AppRuntimeSyncClient) GetPodDetail

func (a *AppRuntimeSyncClient) GetPodDetail(sid, name string) (*pb.PodDetail, error)

GetPodDetail -

func (*AppRuntimeSyncClient) GetServiceDeployInfo

func (a *AppRuntimeSyncClient) GetServiceDeployInfo(serviceID string) (*pb.DeployInfo, error)

GetServiceDeployInfo get service deploy info

func (*AppRuntimeSyncClient) GetServicePods

func (a *AppRuntimeSyncClient) GetServicePods(serviceID string) (*pb.ServiceAppPodList, error)

GetServicePods get service pods list

func (*AppRuntimeSyncClient) GetStatus

func (a *AppRuntimeSyncClient) GetStatus(serviceID string) string

GetStatus get status

func (*AppRuntimeSyncClient) GetStatuss

func (a *AppRuntimeSyncClient) GetStatuss(serviceIDs string) map[string]string

GetStatuss get multiple app status

func (*AppRuntimeSyncClient) GetStorageClasses

func (a *AppRuntimeSyncClient) GetStorageClasses() (storageclasses *pb.StorageClasses, err error)

GetStorageClasses client GetStorageClasses

func (*AppRuntimeSyncClient) GetTenantEnvResource

func (a *AppRuntimeSyncClient) GetTenantEnvResource(tenantEnvID string) (*pb.TenantEnvResource, error)

GetTenantEnvResource get tenant env resource

func (*AppRuntimeSyncClient) IsClosedStatus

func (a *AppRuntimeSyncClient) IsClosedStatus(curStatus string) bool

IsClosedStatus check status

func (*AppRuntimeSyncClient) ListThirdPartyEndpoints

func (a *AppRuntimeSyncClient) ListThirdPartyEndpoints(sid string) (*pb.ThirdPartyEndpoints, error)

ListThirdPartyEndpoints -

func (*AppRuntimeSyncClient) UpdThirdPartyEndpoint

func (a *AppRuntimeSyncClient) UpdThirdPartyEndpoint(req *model.Endpoint)

UpdThirdPartyEndpoint -

type AppRuntimeSyncClientConf

type AppRuntimeSyncClientConf struct {
	NonBlock             bool
	EtcdEndpoints        []string
	EtcdCaFile           string
	EtcdCertFile         string
	EtcdKeyFile          string
	DefaultServerAddress []string
}

AppRuntimeSyncClientConf client conf