Versions in this module Expand all Collapse all v0 v0.0.0 Jun 1, 2024 Changes in this version + var GetPluginConfig = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnBooted = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnBooting = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnClosed = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnClosing = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnConfigLoaded = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnNewClient = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnNewLogger = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnNewPool = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnNewProxy = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnNewServer = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnOpened = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnOpening = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnRun = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnShutdown = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnSignal = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnTick = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnTraffic = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnTrafficFromClient = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnTrafficFromServer = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnTrafficToClient = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var OnTrafficToServer = promauto.NewCounter(prometheus.CounterOpts{ ... }) + var PluginConfig = map[string]interface + var PluginID = v1.PluginID + var PluginMap = map[string]goplugin.Plugin + type GatewaydPluginTest struct + Impl Plugin + func NewGatewaydPluginTest(impl Plugin) *GatewaydPluginTest + func (p *GatewaydPluginTest) GRPCClient(ctx context.Context, b *goplugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error) + func (p *GatewaydPluginTest) GRPCServer(b *goplugin.GRPCBroker, s *grpc.Server) error + type Plugin struct + Logger hclog.Logger + func (p *Plugin) GetPluginConfig(ctx context.Context, _ *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnBooted(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnBooting(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnClosed(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnClosing(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnConfigLoaded(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnNewClient(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnNewLogger(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnNewPool(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnNewProxy(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnNewServer(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnOpened(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnOpening(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnRun(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnShutdown(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnSignal(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnTick(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnTraffic(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnTrafficFromClient(ctx context.Context, req *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnTrafficFromServer(ctx context.Context, resp *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnTrafficToClient(ctx context.Context, resp *v1.Struct) (*v1.Struct, error) + func (p *Plugin) OnTrafficToServer(ctx context.Context, req *v1.Struct) (*v1.Struct, error)
Go to main page