client

Documentation

Index

• type AppRuntimeSyncClient
  • func NewClient(ctx context.Context, conf AppRuntimeSyncClientConf) (*AppRuntimeSyncClient, error)
  • func (a *AppRuntimeSyncClient) Error(err error)
  • func (a *AppRuntimeSyncClient) GetAllAppDisk() map[string]float64
  • func (a *AppRuntimeSyncClient) GetAllStatus() map[string]string
  • func (a *AppRuntimeSyncClient) GetAppsDisk(serviceIDs string) map[string]float64
  • func (a *AppRuntimeSyncClient) GetNeedBillingStatus() (map[string]string, 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) IsClosedStatus(curStatus string) bool
• 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) Error

func (a *AppRuntimeSyncClient) Error(err error)

when watch occurred error,will exec this method

func (*AppRuntimeSyncClient) GetAllAppDisk

func (a *AppRuntimeSyncClient) GetAllAppDisk() map[string]float64

GetAllAppDisk get all service disk

func (*AppRuntimeSyncClient) GetAllStatus

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

GetAllStatus get all status

func (*AppRuntimeSyncClient) GetAppsDisk

func (a *AppRuntimeSyncClient) GetAppsDisk(serviceIDs string) map[string]float64

GetAppsDisk get define service disk

func (*AppRuntimeSyncClient) GetNeedBillingStatus

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

GetNeedBillingStatus get need billing status

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) IsClosedStatus

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

IsClosedStatus check status

type AppRuntimeSyncClientConf

type AppRuntimeSyncClientConf struct {
	EtcdEndpoints        []string
	DefaultServerAddress []string
}

AppRuntimeSyncClientConf client conf