grpcgovern

Documentation

Index

• Constants
• func GenNewZoneCode(env, zoneCode string) string
• func Init()
• type GovernStatus
• type GrpcGovern
  • func InitGrpcGovern() *GrpcGovern
  • func (g *GrpcGovern) ConfiguratorsPut(env, zoneCode string, appName string, regKey string, value string) (ret interface{}, err error)
  • func (g *GrpcGovern) Get(env, zoneCode string, url string, v map[string]string, resp interface{}) (err error)
  • func (g *GrpcGovern) GetBatchPmtInfo(caid int, app *db.CmcAppView, param []db.AppNodeAgentView) (ret []db.CmcUseStatus, err error)
  • func (g *GrpcGovern) GetConfigStatus(env, zoneCode string, appName, param string) (ret []db.ConfigStatus, err error)
  • func (g *GrpcGovern) GovernStatus(zoneCode string) HealthStatus
  • func (g *GrpcGovern) Post(env, zoneCode string, url string, v interface{}, resp interface{}) (err error)
  • func (g *GrpcGovern) PostStream(env, zoneCode string, url string, v interface{}) (stream []byte, err error)
  • func (g *GrpcGovern) Pprof(env, idcCode, ip, port, fileType string) (resp []byte, err error)
  • func (g *GrpcGovern) V1ConfigServerDelete(env, zoneCode string, key string) (ret interface{}, err error)
  • func (g *GrpcGovern) V1ConfigServerPut(env, zoneCode string, params map[string]interface{}) (ret interface{}, err error)
• type HealthStatus
• type ProfResp

Constants

const (
	UrlProviderV2Info = "/v2/provider/info"
	UrlPprofV2Info    = "/v2/pprof/info"
	UrlGovernInfo     = "/v2/govern/%s/%d"
	UrlEtcdInfo       = "/api/etcdctl/%s/%s"
	UrlGovernEvent    = "/api/provider/%s/events" // /api/provider/:appname/events
	UrlConfigurators  = "/v2/configurators/put"
	// 聚合provider,configurators, 第一个为appname,第二个为typeid
	// typeid 1为grpc,2为http
	UrlBaseAggregation  = "/v2/aggregation/base/%s/%d"
	UrlConfigServerPut  = "/v1/configserver/put"
	UrlConfigServerInfo = "/v1/configserver/%s/%d/%s"

	UrlAliLoggerDashboard = "/v1/alilogger/dashboard/%s/%s"
	UrlAliLoggerLogStore  = "/v1/alilogger/logstore/%s/%s/%s"
)

const (
	EtcdRegister     = "register"
	EtcdConfigServer = "config"
	EtcdSentinel     = "sentinel"
)

Functions

func GenNewZoneCode

func GenNewZoneCode(env, zoneCode string) string

func Init

func Init()

Types

type GovernStatus

type GovernStatus string

const (
	GovernOK            GovernStatus = "ok"
	GovernTimeout       GovernStatus = "timeout"
	GovernInvalidDomain GovernStatus = "invalid_domain"
	GovernUnknownError  GovernStatus = "unknown_error"
	GovernUnknown       GovernStatus = "unknown"
)

type GrpcGovern

type GrpcGovern struct {
	DomainMap map[string]string // ZoneCode对应域名
	Token     string

	*resty.Client
	// contains filtered or unexported fields
}

var IGrpcGovern *GrpcGovern

func InitGrpcGovern

func InitGrpcGovern() *GrpcGovern

func (*GrpcGovern) ConfiguratorsPut

func (g *GrpcGovern) ConfiguratorsPut(env, zoneCode string, appName string, regKey string, value string) (ret interface{}, err error)

将appname设置config的value

func (*GrpcGovern) Get

func (g *GrpcGovern) Get(env, zoneCode string, url string, v map[string]string, resp interface{}) (err error)

PostJSON post json 数据请求

func (*GrpcGovern) GetBatchPmtInfo

func (g *GrpcGovern) GetBatchPmtInfo(caid int, app *db.CmcAppView, param []db.AppNodeAgentView) (ret []db.CmcUseStatus, err error)

GetBatchSupervisorInfo 获取配置中心基础信息

func (*GrpcGovern) GetConfigStatus

func (g *GrpcGovern) GetConfigStatus(env, zoneCode string, appName, param string) (ret []db.ConfigStatus, err error)

GetConfigStatus

func (*GrpcGovern) GovernStatus

func (g *GrpcGovern) GovernStatus(zoneCode string) HealthStatus

func (*GrpcGovern) Post

func (g *GrpcGovern) Post(env, zoneCode string, url string, v interface{}, resp interface{}) (err error)

PostJSON post json 数据请求

func (*GrpcGovern) PostStream

func (g *GrpcGovern) PostStream(env, zoneCode string, url string, v interface{}) (stream []byte, err error)

PostJSON post json 数据请求

func (*GrpcGovern) Pprof

func (g *GrpcGovern) Pprof(env, idcCode, ip, port, fileType string) (resp []byte, err error)

将appname设置config的value

func (*GrpcGovern) V1ConfigServerDelete

func (g *GrpcGovern) V1ConfigServerDelete(env, zoneCode string, key string) (ret interface{}, err error)

V1ConfigServerPut 发送配置信息

func (*GrpcGovern) V1ConfigServerPut

func (g *GrpcGovern) V1ConfigServerPut(env, zoneCode string, params map[string]interface{}) (ret interface{}, err error)

V1ConfigServerPut 发送配置信息

type HealthStatus

type HealthStatus struct {
	Status  GovernStatus
	Message string // 如果服务有异常，这里显示错误信息
}

type ProfResp

type ProfResp struct {
	Code int    `json:"code"`
	Msg  string `json:"msg"`
	Data string `json:"data"`
}