client

package
v3.7.0-release+incompa... Latest Latest
Warning

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

Go to latest
Published: Aug 14, 2018 License: LGPL-3.0 Imports: 8 Imported by: 0

Documentation

Overview

Package client provides app runtime client code

Client code demo:

    //create app status client
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	cli, err := client.NewClient(ctx, client.AppRuntimeSyncClientConf{
		EtcdEndpoints: s.Config.EtcdEndpoint,
	})
	if err != nil {
		logrus.Errorf("create app status client error, %v", err)
		return err
	}

Index

Constants

View Source
const (
	RUNNING  string = "running"
	CLOSED          = "closed"
	STARTING        = "starting"
	STOPPING        = "stopping"
	CHECKING        = "checking"
	//运行异常
	ABNORMAL = "abnormal"
	//升级中
	UPGRADE  = "upgrade"
	UNDEPLOY = "undeploy"
	//构建中
	DEPLOYING = "deploying"
	//
	UNKNOW = "unknow"
)

These are the available operation types.

Variables

This section is empty.

Functions

This section is empty.

Types

type AppRuntimeSyncClient

type AppRuntimeSyncClient struct {
	pb.AppRuntimeSyncClient
	AppRuntimeSyncClientConf
	ServerAddress []string
	// contains filtered or unexported fields
}

AppRuntimeSyncClient grpc client

func NewClient

NewClient new client ctx must be cancel where client not used

func (*AppRuntimeSyncClient) CheckStatus

func (a *AppRuntimeSyncClient) CheckStatus(serviceID string)

CheckStatus CheckStatus

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

func (a *AppRuntimeSyncClient) IgnoreDelete(name string)

IgnoreDelete IgnoreDelete

func (*AppRuntimeSyncClient) IsClosedStatus

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

IsClosedStatus check status

func (*AppRuntimeSyncClient) RmIgnoreDelete

func (a *AppRuntimeSyncClient) RmIgnoreDelete(name string)

RmIgnoreDelete RmIgnoreDelete

func (*AppRuntimeSyncClient) SetStatus

func (a *AppRuntimeSyncClient) SetStatus(serviceID, status string) error

SetStatus set app status

func (*AppRuntimeSyncClient) UpdateEndpoints

func (a *AppRuntimeSyncClient) UpdateEndpoints(endpoints ...*config.Endpoint)

UpdateEndpoints update endpoints

type AppRuntimeSyncClientConf

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

AppRuntimeSyncClientConf client conf

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL