pluginmanager_service

package
v0.22.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 5, 2024 License: AGPL-3.0 Imports: 38 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type PluginManager 

type PluginManager struct {
	pb.UnimplementedPluginManagerServer
	// contains filtered or unexported fields
}

PluginManager is the implementation of grpc.PluginManager

func NewPluginManager 

func NewPluginManager(ctx context.Context, connectionConfig map[string]*sdkproto.ConnectionConfig, pluginConfigs connection.PluginMap, logger hclog.Logger) (*PluginManager, error)

func (*PluginManager) Get 

func (m *PluginManager) Get(req *pb.GetRequest) (_ *pb.GetResponse, err error)

func (*PluginManager) GetConnectionConfig added in v0.21.0 

func (m *PluginManager) GetConnectionConfig() connection.ConnectionConfigMap

func (*PluginManager) HandlePluginLimiterChanges added in v0.21.0 

func (m *PluginManager) HandlePluginLimiterChanges(newLimiters connection.PluginLimiterMap) error

HandlePluginLimiterChanges responds to changes in the plugin rate limiter definitions update the stored limiters, refrresh the rate limiter table and call `setRateLimiters` for all plugins with changed limiters

func (*PluginManager) LoadPluginRateLimiters added in v0.21.0 

func (m *PluginManager) LoadPluginRateLimiters(pluginConnectionMap map[string]string) (connection.PluginLimiterMap, error)

func (*PluginManager) OnConnectionConfigChanged 

func (m *PluginManager) OnConnectionConfigChanged(ctx context.Context, configMap connection.ConnectionConfigMap, plugins map[string]*modconfig.Plugin)

OnConnectionConfigChanged is the callback function invoked by the connection watcher when the config changed

func (*PluginManager) Pool added in v0.21.0 

func (m *PluginManager) Pool() *pgxpool.Pool

func (*PluginManager) RefreshConnections 

func (m *PluginManager) RefreshConnections(*pb.RefreshConnectionsRequest) (*pb.RefreshConnectionsResponse, error)

func (*PluginManager) SendPostgresErrorsAndWarningsNotification added in v0.21.0 

func (m *PluginManager) SendPostgresErrorsAndWarningsNotification(ctx context.Context, errorAndWarnings error_helpers.ErrorAndWarnings)

func (*PluginManager) SendPostgresSchemaNotification added in v0.21.0 

func (m *PluginManager) SendPostgresSchemaNotification(ctx context.Context) error

func (*PluginManager) Serve 

func (m *PluginManager) Serve()

func (*PluginManager) ShouldFetchRateLimiterDefs added in v0.21.0 

func (m *PluginManager) ShouldFetchRateLimiterDefs() bool

func (*PluginManager) Shutdown 

func (m *PluginManager) Shutdown(*pb.ShutdownRequest) (resp *pb.ShutdownResponse, err error)

func (*PluginManager) UpdatePluginColumnsTable added in v0.21.2 

func (m *PluginManager) UpdatePluginColumnsTable(ctx context.Context, update map[string]*proto.Schema, delete []string) error

type PluginMessageServer 

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

func NewPluginMessageServer 

func NewPluginMessageServer(pluginManager *PluginManager) (*PluginMessageServer, error)

func (*PluginMessageServer) AddConnection 

func (m *PluginMessageServer) AddConnection(pluginClient *sdkgrpc.PluginClient, pluginName string, connectionNames ...string) error

Source Files

View all Source files

Directories

Path Synopsis
proto
shared
Package shared contains shared data between the host and plugins.
 Package shared contains shared data between the host and plugins.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.