manager

Documentation

Index

• Variables
• func IncrementCounter(metric *prometheus.CounterVec, client, installId string)
• func Main(ctx context.Context, _ ...string) error
• func MainWithEnv(ctx context.Context) (err error)
• func SetGauge(metric *prometheus.GaugeVec, client, installId string, workload *string, ...)
• type Clock
• type HealthChecker
  • func (s *HealthChecker) Check(ctx context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
  • func (s *HealthChecker) Watch(_ *grpc_health_v1.HealthCheckRequest, stream grpc_health_v1.Health_WatchServer) error
• type Service
  • func NewService(ctx context.Context) (Service, *dgroup.Group, error)

Variables

var (
	DisplayName                   = "OSS Traffic Manager"               //nolint:gochecknoglobals // extension point
	NewServiceFunc                = NewService                          //nolint:gochecknoglobals // extension point
	WithAgentImageRetrieverFunc   = managerutil.WithAgentImageRetriever //nolint:gochecknoglobals // extension point
	IncrementInterceptCounterFunc = func(metric *prometheus.CounterVec, client, installId string, spec *rpc.InterceptSpec) {
		if metric != nil {
			labels := prometheus.Labels{
				"client":         client,
				"install_id":     installId,
				"intercept_type": "global",
			}

			metric.With(labels).Inc()
		}
	}
)

Functions

func IncrementCounter

func IncrementCounter(metric *prometheus.CounterVec, client, installId string)

func Main

func Main(ctx context.Context, _ ...string) error

Main starts up the traffic manager and blocks until it ends.

func MainWithEnv

func MainWithEnv(ctx context.Context) (err error)

func SetGauge

func SetGauge(metric *prometheus.GaugeVec, client, installId string, workload *string, value float64)

Types

type Clock

type Clock interface {
	Now() time.Time
}

Clock is the mechanism used by the Manager state to get the current time.

type HealthChecker

type HealthChecker struct{}

func (*HealthChecker) Check

func (s *HealthChecker) Check(ctx context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

func (*HealthChecker) Watch

func (s *HealthChecker) Watch(_ *grpc_health_v1.HealthCheckRequest, stream grpc_health_v1.Health_WatchServer) error

type Service

type Service interface {
	rpc.ManagerServer
	ID() string
	InstallID() string
	ClusterID() string
	MakeInterceptID(context.Context, string, string) (string, error)
	RegisterServers(*grpc.Server)
	State() state.State
	ClusterInfo() cluster.Info
	// contains filtered or unexported methods
}

func NewService

func NewService(ctx context.Context) (Service, *dgroup.Group, error)