server

Documentation

Index

• Variables
• type Server
  • func New(isProd bool) *Server
  • func (s *Server) Aggregate(ctx context.Context, in *pb.AggregateRequest) (*pb.Response, error)
  • func (s *Server) Batch(ctx context.Context, in *pb.BatchRequest) (*pb.Response, error)
  • func (s *Server) Call(ctx context.Context, in *pb.FunctionsRequest) (*pb.Response, error)
  • func (s *Server) Create(ctx context.Context, in *pb.CreateRequest) (*pb.Response, error)
  • func (s *Server) CreateFolder(ctx context.Context, in *pb.CreateFolderRequest) (*pb.Response, error)
  • func (s *Server) Delete(ctx context.Context, in *pb.DeleteRequest) (*pb.Response, error)
  • func (s *Server) DeleteFile(ctx context.Context, in *pb.DeleteFileRequest) (*pb.Response, error)
  • func (s *Server) DownloadFile(in *pb.DownloadFileRequest, stream pb.SpaceCloud_DownloadFileServer) error
  • func (s *Server) EditProfile(ctx context.Context, in *pb.EditProfileRequest) (*pb.Response, error)
  • func (s *Server) ListFiles(ctx context.Context, in *pb.ListFilesRequest) (*pb.Response, error)
  • func (s *Server) LoadConfig(config *config.Project) error
  • func (s *Server) Profile(ctx context.Context, in *pb.ProfileRequest) (*pb.Response, error)
  • func (s *Server) Profiles(ctx context.Context, in *pb.ProfilesRequest) (*pb.Response, error)
  • func (s *Server) Read(ctx context.Context, in *pb.ReadRequest) (*pb.Response, error)
  • func (s *Server) RealTime(stream pb.SpaceCloud_RealTimeServer) error
  • func (s *Server) Routes()
  • func (s *Server) RoutineMetrics()
  • func (s *Server) RunNatsServer(opts *nats.Options)
  • func (s *Server) Service(stream pb.SpaceCloud_ServiceServer) error
  • func (s *Server) SignIn(ctx context.Context, in *pb.SignInRequest) (*pb.Response, error)
  • func (s *Server) SignUp(ctx context.Context, in *pb.SignUpRequest) (*pb.Response, error)
  • func (s *Server) Start(port, grpcPort string) error
  • func (s *Server) Update(ctx context.Context, in *pb.UpdateRequest) (*pb.Response, error)
  • func (s *Server) UploadFile(stream pb.SpaceCloud_UploadFileServer) error

Variables

var DefaultNatsOptions = &nats.Options{
	Host:   "0.0.0.0",
	Port:   4222,
	NoLog:  false,
	NoSigs: true,
	Cluster: nats.ClusterOpts{
		Host: "0.0.0.0",
		Port: 4248,
	},
}

Types

type Server

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

func New

func New(isProd bool) *Server

func (*Server) Aggregate

func (s *Server) Aggregate(ctx context.Context, in *pb.AggregateRequest) (*pb.Response, error)

func (*Server) Batch

func (s *Server) Batch(ctx context.Context, in *pb.BatchRequest) (*pb.Response, error)

func (*Server) Call

func (s *Server) Call(ctx context.Context, in *pb.FunctionsRequest) (*pb.Response, error)

func (*Server) Create

func (s *Server) Create(ctx context.Context, in *pb.CreateRequest) (*pb.Response, error)

func (*Server) CreateFolder

func (s *Server) CreateFolder(ctx context.Context, in *pb.CreateFolderRequest) (*pb.Response, error)

func (*Server) Delete

func (s *Server) Delete(ctx context.Context, in *pb.DeleteRequest) (*pb.Response, error)

func (*Server) DeleteFile

func (s *Server) DeleteFile(ctx context.Context, in *pb.DeleteFileRequest) (*pb.Response, error)

func (*Server) DownloadFile

func (s *Server) DownloadFile(in *pb.DownloadFileRequest, stream pb.SpaceCloud_DownloadFileServer) error

func (*Server) EditProfile

func (s *Server) EditProfile(ctx context.Context, in *pb.EditProfileRequest) (*pb.Response, error)

func (*Server) ListFiles

func (s *Server) ListFiles(ctx context.Context, in *pb.ListFilesRequest) (*pb.Response, error)

func (*Server) LoadConfig

func (s *Server) LoadConfig(config *config.Project) error

func (*Server) Profile

func (s *Server) Profile(ctx context.Context, in *pb.ProfileRequest) (*pb.Response, error)

func (*Server) Profiles

func (s *Server) Profiles(ctx context.Context, in *pb.ProfilesRequest) (*pb.Response, error)

func (*Server) Read

func (s *Server) Read(ctx context.Context, in *pb.ReadRequest) (*pb.Response, error)

func (*Server) RealTime

func (s *Server) RealTime(stream pb.SpaceCloud_RealTimeServer) error

func (*Server) Routes

func (s *Server) Routes()

func (*Server) RoutineMetrics

func (s *Server) RoutineMetrics()

func (*Server) RunNatsServer

func (s *Server) RunNatsServer(opts *nats.Options)

func (*Server) Service

func (s *Server) Service(stream pb.SpaceCloud_ServiceServer) error

func (*Server) SignIn

func (s *Server) SignIn(ctx context.Context, in *pb.SignInRequest) (*pb.Response, error)

func (*Server) SignUp

func (s *Server) SignUp(ctx context.Context, in *pb.SignUpRequest) (*pb.Response, error)

func (*Server) Start

func (s *Server) Start(port, grpcPort string) error

func (*Server) Update

func (s *Server) Update(ctx context.Context, in *pb.UpdateRequest) (*pb.Response, error)

func (*Server) UploadFile

func (s *Server) UploadFile(stream pb.SpaceCloud_UploadFileServer) error