pkg

Documentation

Index

• type GRPCController
  • func NewGRPCController(GRPCServerAddr string, pluginConfigCache types.PodPluginConfigCache, ...) (*GRPCController, error)
  • func (c *GRPCController) NotifyPodChange(updateEvent *types.UpdatePodPluginConfigEvent)
  • func (c *GRPCController) Ping(ctx context.Context, _ *protov1.Empty) (*protov1.HealthCheckResponse, error)
  • func (c *GRPCController) Run(stopCh <-chan struct{})
  • func (c *GRPCController) StreamPlugins(req *protov1.PluginsRequest, srv protov1.AmeshService_StreamPluginsServer) error
• type InstanceManager
  • func NewInstanceManager(collector metrics.Collector) *InstanceManager
• type ProxyInstance

Types

type GRPCController

type GRPCController struct {
	protov1.UnimplementedAmeshServiceServer
	protov1.UnimplementedHealthCheckServiceServer
	Log logr.Logger
	// contains filtered or unexported fields
}

func NewGRPCController

func NewGRPCController(GRPCServerAddr string, pluginConfigCache types.PodPluginConfigCache, collector metrics.Collector) (*GRPCController, error)

func (*GRPCController) NotifyPodChange

func (c *GRPCController) NotifyPodChange(updateEvent *types.UpdatePodPluginConfigEvent)

func (*GRPCController) Ping

func (c *GRPCController) Ping(ctx context.Context, _ *protov1.Empty) (*protov1.HealthCheckResponse, error)

func (*GRPCController) Run

func (c *GRPCController) Run(stopCh <-chan struct{})

func (*GRPCController) StreamPlugins

func (c *GRPCController) StreamPlugins(req *protov1.PluginsRequest, srv protov1.AmeshService_StreamPluginsServer) error

type InstanceManager

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

func NewInstanceManager

func NewInstanceManager(collector metrics.Collector) *InstanceManager

type ProxyInstance

type ProxyInstance struct {
	UpdateNotifyChan chan struct{}
}