server

Dec 7, 2023

Changes in this version

type Server

+ func (m *Server) Download(ctx context.Context, req *pb.FileDownloadRequest) (*pb.FilesResult, error)

+ func (m *Server) SetupHostParams(ctx context.Context, hostParams *pb.HostParams) (*emptypb.Empty, error)

Nov 12, 2023

Changes in this version

+ func BuildEmptyCreds(logger *zap.Logger) credentials.Credentials

Nov 10, 2023

Changes in this version

+ var ErrUnauthorized = errors.New("unauthorized")

+ func BuildCreds(login, password string, logger *zap.Logger) credentials.Credentials

+ func MakeFileResult(path string, f streamer.File) *pb.FileResult

+ func MakeFilesResult(files map[string]streamer.File) *pb.FilesResult

+ type Auth struct

+ func NewAuth(logger *zap.Logger, login string, password credentials.Secret) *Auth

+ func NewAuthInsecure(logger *zap.Logger) *Auth

+ func (m *Auth) AuthenticateStream(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error

+ func (m *Auth) AuthenticateUnary(ctx context.Context, req interface{}, servInfo *grpc.UnaryServerInfo, ...) (interface{}, error)

+ type MultiTrace interface

+ AddTrace func(gtrace.Trace) int

+ DelTrace func(int) error

+ type MultiTraceImp struct

+ func NewMultiTrace() *MultiTraceImp

+ func (m *MultiTraceImp) Add(op gtrace.Operation, data []byte)

+ func (m *MultiTraceImp) AddTrace(tr gtrace.Trace) int

+ func (m *MultiTraceImp) DelTrace(index int) error

+ func (m *MultiTraceImp) List() []gtrace.Item

+ type Option func(*Server)

+ func WithCredentials(creds credentials.Credentials) Option

+ func WithLogger(logger *zap.Logger) Option

+ type Server struct

+ func New(opts ...Option) *Server

+ func (m *Server) AddDevice(ctx context.Context, device *pb.Device) (*pb.DeviceResult, error)

+ func (m *Server) Downloads(ctx context.Context, req *pb.FileDownloadRequest) (*pb.FilesResult, error)

+ func (m *Server) Exec(ctx context.Context, cmd *pb.CMD) (*pb.CMDResult, error)

+ func (m *Server) ExecChat(stream pb.Gnetcli_ExecChatServer) error

+ func (m *Server) Upload(ctx context.Context, req *pb.FileUploadRequest) (*emptypb.Empty, error)