Versions in this module Expand all Collapse all v1 v1.0.0 Oct 13, 2022 Changes in this version + const ErrDeprecatedAction + const ErrEmptyPermissionsList + const ErrGRPCMiddlewareNil + const ErrInvalidMacAction + const ErrInvalidMacEntity + const ErrLogLvlNotFound + const ErrShutdown + func InitLogger(config *Config) (zerolog.Logger, error) + func Main(interceptor *intercept.Interceptor, server *Server) error + func MainGrpcServerPermissions() map[string][]bakery.Op + func NewSubLogger(l *zerolog.Logger, subsystem string) *subLogger + func StreamingPluginAPIPermission() map[string][]bakery.Op + type Config struct + AdminMacPath string + ConsoleOutput bool + DefaultLogDir bool + ExtraIPAddr []string + GrpcPort int64 + LogFileDir string + MacaroonDBPath string + MaxLogFileSize int64 + MaxLogFiles int64 + PluginDir string + Plugins []*lanirpc.PluginConfig + RegenerateMacaroons bool + RestPort int64 + TLSCertPath string + TLSKeyPath string + TestMacPath string + WSPingInterval time.Duration + WSPongWait time.Duration + func InitConfig(isTesting bool) (Config, error) + type RpcServer struct + Active int32 + Listener net.Listener + SubLogger *zerolog.Logger + func NewRpcServer(interceptor *intercept.Interceptor, config *Config, log *zerolog.Logger) (*RpcServer, error) + func (s *RpcServer) AddGrpcInterceptor(i *intercept.GrpcInterceptor) + func (s *RpcServer) AddMacaroonService(svc *macaroons.Service) + func (s *RpcServer) AdminTest(_ context.Context, _ *lanirpc.AdminTestRequest) (*lanirpc.AdminTestResponse, error) + func (s *RpcServer) BakeMacaroon(ctx context.Context, req *lanirpc.BakeMacaroonRequest) (*lanirpc.BakeMacaroonResponse, error) + func (s *RpcServer) InsertROIMarker(ctx context.Context, _ *proto.Empty) (*proto.Empty, error) + func (s *RpcServer) LoadTestPlan(ctx context.Context, _ *proto.Empty) (*proto.Empty, error) + func (s *RpcServer) Ping(ctx context.Context) error + func (s *RpcServer) RegisterWithGrpcServer(grpcServer *grpc.Server) error + func (s *RpcServer) RegisterWithRestProxy(ctx context.Context, mux *proxy.ServeMux, restDialOpts []grpc.DialOption, ...) error + func (s *RpcServer) SetPressure(ctx context.Context, _ *proto.Empty) (*proto.Empty, error) + func (s *RpcServer) SetTemperature(ctx context.Context, _ *proto.Empty) (*proto.Empty, error) + func (s *RpcServer) Start() error + func (s *RpcServer) StartRecording(ctx context.Context, _ *proto.Empty) (*proto.Empty, error) + func (s *RpcServer) StartTestPlan(ctx context.Context, _ *proto.Empty) (*proto.Empty, error) + func (s *RpcServer) Stop() error + func (s *RpcServer) StopDaemon(_ context.Context, _ *lanirpc.StopRequest) (*lanirpc.StopResponse, error) + func (s *RpcServer) StopRecording(ctx context.Context, _ *proto.Empty) (*proto.Empty, error) + func (s *RpcServer) StopTestPlan(ctx context.Context, _ *proto.Empty) (*proto.Empty, error) + func (s *RpcServer) SubscribeDataStream(ctx context.Context, _ *proto.Empty) (*proto.Empty, error) + func (s *RpcServer) TestCommand(_ context.Context, _ *lanirpc.TestRequest) (*lanirpc.TestResponse, error) + type Server struct + Active int32 + func InitServer(config *Config, logger *zerolog.Logger) (*Server, error) + func (s *Server) Start() error + func (s *Server) Stop() error
Go to main page