manager

Documentation

Index

• Variables
• func Main(ctx context.Context, _ ...string) error
• 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 ReverseConnProvider
  • func (p *ReverseConnProvider) BuildClient(ctx context.Context, conn *grpc.ClientConn) (managerutil.SystemaCRUDClient, error)
  • func (p *ReverseConnProvider) GetAPIKey(ctx context.Context) (string, error)
  • func (p *ReverseConnProvider) GetCloudConfig(ctx context.Context) (*manager.AmbassadorCloudConfig, error)
  • func (p *ReverseConnProvider) GetExtraHeaders(ctx context.Context) (map[string]string, error)
  • func (p *ReverseConnProvider) GetInstallID(ctx context.Context) (string, error)
• type Service
  • func NewService(ctx context.Context) (Service, context.Context, error)

Variables

var (
	DisplayName                                                            = "OSS Traffic Manager" //nolint:gochecknoglobals // extension point
	NewServiceFunc func(context.Context) (Service, context.Context, error) = NewService            //nolint:gochecknoglobals // extension point
)

Functions

func Main

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

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

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 ReverseConnProvider

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

func (*ReverseConnProvider) BuildClient

func (p *ReverseConnProvider) BuildClient(ctx context.Context, conn *grpc.ClientConn) (managerutil.SystemaCRUDClient, error)

func (*ReverseConnProvider) GetAPIKey

func (p *ReverseConnProvider) GetAPIKey(ctx context.Context) (string, error)

func (*ReverseConnProvider) GetCloudConfig

func (p *ReverseConnProvider) GetCloudConfig(ctx context.Context) (*manager.AmbassadorCloudConfig, error)

func (*ReverseConnProvider) GetExtraHeaders

func (p *ReverseConnProvider) GetExtraHeaders(ctx context.Context) (map[string]string, error)

func (*ReverseConnProvider) GetInstallID

func (p *ReverseConnProvider) GetInstallID(ctx context.Context) (string, error)

type Service

type Service interface {
	rpc.ManagerServer
	InstallID() string
	RegisterServers(grpcHandler *grpc.Server)
	RunConfigWatcher(context.Context) error
	ServePrometheus(context.Context) error
	RunSessionGCLoop(context.Context) error
	TrafficManagerConfig() []byte
	State() *state.State
}

func NewService

func NewService(ctx context.Context) (Service, context.Context, error)