object

Documentation

Index

• type Server
  • func New(c objectSvc.ServiceServer) *Server
  • func (s *Server) Delete(ctx context.Context, req *objectGRPC.DeleteRequest) (*objectGRPC.DeleteResponse, error)
  • func (s *Server) Get(req *objectGRPC.GetRequest, gStream objectGRPC.ObjectService_GetServer) error
  • func (s *Server) GetRange(req *objectGRPC.GetRangeRequest, ...) error
  • func (s *Server) GetRangeHash(ctx context.Context, req *objectGRPC.GetRangeHashRequest) (*objectGRPC.GetRangeHashResponse, error)
  • func (s *Server) Head(ctx context.Context, req *objectGRPC.HeadRequest) (*objectGRPC.HeadResponse, error)
  • func (s *Server) Patch(gStream objectGRPC.ObjectService_PatchServer) error
  • func (s *Server) Put(gStream objectGRPC.ObjectService_PutServer) error
  • func (s *Server) PutSingle(ctx context.Context, req *objectGRPC.PutSingleRequest) (*objectGRPC.PutSingleResponse, error)
  • func (s *Server) Search(req *objectGRPC.SearchRequest, gStream objectGRPC.ObjectService_SearchServer) error

Types

type Server

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

Server wraps FrostFS API Object service and provides gRPC Object service server interface.

func New

func New(c objectSvc.ServiceServer) *Server

New creates, initializes and returns Server instance.

func (*Server) Delete

func (s *Server) Delete(ctx context.Context, req *objectGRPC.DeleteRequest) (*objectGRPC.DeleteResponse, error)

Delete converts gRPC DeleteRequest message and passes it to internal Object service.

func (*Server) Get

func (s *Server) Get(req *objectGRPC.GetRequest, gStream objectGRPC.ObjectService_GetServer) error

Get converts gRPC GetRequest message and server-side stream and overtakes its data to gRPC stream.

func (*Server) GetRange

func (s *Server) GetRange(req *objectGRPC.GetRangeRequest, gStream objectGRPC.ObjectService_GetRangeServer) error

GetRange converts gRPC GetRangeRequest message and server-side stream and overtakes its data to gRPC stream.

func (*Server) GetRangeHash

func (s *Server) GetRangeHash(ctx context.Context, req *objectGRPC.GetRangeHashRequest) (*objectGRPC.GetRangeHashResponse, error)

GetRangeHash converts gRPC GetRangeHashRequest message and passes it to internal Object service.

func (*Server) Head

func (s *Server) Head(ctx context.Context, req *objectGRPC.HeadRequest) (*objectGRPC.HeadResponse, error)

Head converts gRPC HeadRequest message and passes it to internal Object service.

func (*Server) Patch

func (s *Server) Patch(gStream objectGRPC.ObjectService_PatchServer) error

Patch opens internal Object patch stream and feeds it by the data read from gRPC stream.

func (*Server) Put

func (s *Server) Put(gStream objectGRPC.ObjectService_PutServer) error

Put opens internal Object service Put stream and overtakes data from gRPC stream to it.

func (*Server) PutSingle

func (s *Server) PutSingle(ctx context.Context, req *objectGRPC.PutSingleRequest) (*objectGRPC.PutSingleResponse, error)

func (*Server) Search

func (s *Server) Search(req *objectGRPC.SearchRequest, gStream objectGRPC.ObjectService_SearchServer) error

Search converts gRPC SearchRequest message and server-side stream and overtakes its data to gRPC stream.