Versions in this module Expand all Collapse all v1 v1.0.0 Oct 13, 2022 Changes in this version + const CONTROLLER_STR + const DATASOURCE_STR + const ErrDuplicatePluginName + const ErrInvalidPluginExec + const ErrInvalidPluginString + const ErrInvalidPluginType + const ErrPluginExecNotFound + const ErrPluginNotReady + const ErrPluginNotStarted + const ErrPluginTimeout + const ErrUnregsiteredPlugin + const MissingKey + const PluginEOF + func ChangeCfgExec(os string, cfgs []*lanirpc.PluginConfig) []*lanirpc.PluginConfig + func ValidatePluginConfig(cfg *lanirpc.PluginConfig, pluginDir string, isTesting bool) error + type LogWriter struct + func (w *LogWriter) Write(data []byte) (int, error) + type PluginInstance struct + type PluginLogger struct + func NewPluginLogger(name string, logger *zerolog.Logger) *PluginLogger + func (l *PluginLogger) Debug(msg string, args ...interface{}) + func (l *PluginLogger) Error(msg string, args ...interface{}) + func (l *PluginLogger) ImpliedArgs() []interface{} + func (l *PluginLogger) Info(msg string, args ...interface{}) + func (l *PluginLogger) IsDebug() bool + func (l *PluginLogger) IsError() bool + func (l *PluginLogger) IsInfo() bool + func (l *PluginLogger) IsTrace() bool + func (l *PluginLogger) IsWarn() bool + func (l *PluginLogger) Log(level hclog.Level, msg string, args ...interface{}) + func (l *PluginLogger) Name() string + func (l *PluginLogger) Named(name string) hclog.Logger + func (l *PluginLogger) ResetNamed(name string) hclog.Logger + func (l *PluginLogger) SetLevel(level hclog.Level) + func (l *PluginLogger) StandardLogger(opts *hclog.StandardLoggerOptions) *log.Logger + func (l *PluginLogger) StandardWriter(opts *hclog.StandardLoggerOptions) io.Writer + func (l *PluginLogger) Trace(msg string, args ...interface{}) + func (l *PluginLogger) Warn(msg string, args ...interface{}) + func (l *PluginLogger) With(args ...interface{}) hclog.Logger + type PluginManager struct + func NewPluginManager(pluginDir string, pluginCfgs []*lanirpc.PluginConfig, zl zerolog.Logger, ...) *PluginManager + func (p *PluginManager) AddMacaroonService(service *macaroons.Service) + func (p *PluginManager) AddPermission(method string, ops []bakery.Op) error + func (p *PluginManager) AddPermissions(perms map[string][]bakery.Op) error + func (p *PluginManager) AddPlugin(ctx context.Context, req *lanirpc.PluginConfig) (*lanirpc.Plugin, error) + func (p *PluginManager) Command(req *lanirpc.ControllerPluginRequest, stream lanirpc.PluginAPI_CommandServer) error + func (p *PluginManager) GetPlugin(ctx context.Context, req *lanirpc.PluginRequest) (*lanirpc.Plugin, error) + func (p *PluginManager) ListPlugins(ctx context.Context, _ *proto.Empty) (*lanirpc.PluginsList, error) + func (p *PluginManager) Ping(ctx context.Context) error + func (p *PluginManager) RegisterWithGrpcServer(grpcServer *grpc.Server) error + func (p *PluginManager) RegisterWithRestProxy(ctx context.Context, mux *proxy.ServeMux, restDialOpts []grpc.DialOption, ...) error + func (p *PluginManager) Start(ctx context.Context) error + func (p *PluginManager) StartPlugin(ctx context.Context, req *lanirpc.PluginRequest) (*proto.Empty, error) + func (p *PluginManager) StartRecord(ctx context.Context, req *lanirpc.PluginRequest) (*proto.Empty, error) + func (p *PluginManager) Stop() error + func (p *PluginManager) StopPlugin(ctx context.Context, req *lanirpc.PluginRequest) (*proto.Empty, error) + func (p *PluginManager) StopRecord(ctx context.Context, req *lanirpc.PluginRequest) (*proto.Empty, error) + func (p *PluginManager) Subscribe(req *lanirpc.PluginRequest, stream lanirpc.PluginAPI_SubscribeServer) error + func (p *PluginManager) SubscribePluginState(req *lanirpc.PluginRequest, ...) error + type PluginRecordState int32 + const NOTRECORDING + const RECORDING + type StateListener struct + IsConnected bool + Signal chan lanirpc.PluginState