service

package

v0.0.0-...-cb472e6 Latest Latest Go to latest Published: Aug 27, 2021 License: MIT Imports: 34 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/tareya/configcenter

Links

Open Source Insights

Documentation ¶

Index ¶

type HTTPClient
type Limiter
- func NewLimiter(zkCli *zkclient.ZkClient) *Limiter
type RequestType
type Service
- func NewService() Service
type URLPath

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type HTTPClient ¶

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

HTTPClient http client method

type Limiter ¶

type Limiter struct {
	// contains filtered or unexported fields
}

func NewLimiter ¶

func NewLimiter(zkCli *zkclient.ZkClient) *Limiter

func (*Limiter) GetMatchedRule ¶

func (l *Limiter) GetMatchedRule(req *restful.Request) *metadata.LimiterRule

GetMatchedRule get the matched limiter rule according request

func (*Limiter) GetRules ¶

func (l *Limiter) GetRules() map[string]*metadata.LimiterRule

GetRules get all rules of limiter

func (*Limiter) LenOfRules ¶

func (l *Limiter) LenOfRules() int

LenOfRules get the count of limiter's rules

func (*Limiter) SyncLimiterRules ¶

func (l *Limiter) SyncLimiterRules() error

SyncLimiterRules sync the api limiter rules from zk

type RequestType ¶

type RequestType string

const (
	UnknownType     RequestType = "unknown"
	TopoType        RequestType = "topo"
	HostType        RequestType = "host"
	ProcType        RequestType = "proc"
	EventType       RequestType = "event"
	DataCollectType RequestType = "collect"
	OperationType   RequestType = "operation"
	TaskType        RequestType = "task"
	AdminType       RequestType = "admin"
	CloudType       RequestType = "cloud"
)

type Service ¶

type Service interface {
	WebServices() []*restful.WebService
	SetConfig(engine *backbone.Engine, httpClient HTTPClient, discovery discovery.DiscoveryInterface,
		clientSet apimachinery.ClientSetInterface, cache *redis.Client, limiter *Limiter)
}

Service service methods

func NewService ¶

func NewService() Service

NewService create a new service instance

type URLPath ¶

type URLPath string

URLPath url path filter

func (URLPath) FilterChain ¶

func (u URLPath) FilterChain(req *restful.Request) (RequestType, error)

FilterChain url path filter

func (*URLPath) WithAdmin ¶

func (u *URLPath) WithAdmin(req *restful.Request) (isHit bool)

WithAdmin transform admin server url

func (*URLPath) WithCloud ¶

func (u *URLPath) WithCloud(req *restful.Request) (isHit bool)

WithCloud transform cloud's url

func (*URLPath) WithDataCollect ¶

func (u *URLPath) WithDataCollect(req *restful.Request) (isHit bool)

WithDataCollect transform DataCollect's url

func (*URLPath) WithEvent ¶

func (u *URLPath) WithEvent(req *restful.Request) (isHit bool)

WithEvent transform event's url

func (*URLPath) WithHost ¶

func (u *URLPath) WithHost(req *restful.Request) (isHit bool)

WithHost transform the host's url

func (*URLPath) WithOperation ¶

func (u *URLPath) WithOperation(req *restful.Request) (isHit bool)

WithOperation transform OperationStatistic's url

func (*URLPath) WithProc ¶

func (u *URLPath) WithProc(req *restful.Request) (isHit bool)

WithProc transform the proc's url

func (*URLPath) WithTask ¶

func (u *URLPath) WithTask(req *restful.Request) (isHit bool)

WithTask transform task server url

func (*URLPath) WithTopo ¶

func (u *URLPath) WithTopo(req *restful.Request) (isHit bool)

WithTopo parse topo api's url

Source Files ¶

View all Source files

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