container

Documentation

Index

• type Server
  • func New(c containersvc.Server) *Server
  • func (s *Server) AnnounceUsedSpace(ctx context.Context, req *containerGRPC.AnnounceUsedSpaceRequest) (*containerGRPC.AnnounceUsedSpaceResponse, error)
  • func (s *Server) Delete(ctx context.Context, req *containerGRPC.DeleteRequest) (*containerGRPC.DeleteResponse, error)
  • func (s *Server) Get(ctx context.Context, req *containerGRPC.GetRequest) (*containerGRPC.GetResponse, error)
  • func (s *Server) GetExtendedACL(ctx context.Context, req *containerGRPC.GetExtendedACLRequest) (*containerGRPC.GetExtendedACLResponse, error)
  • func (s *Server) List(ctx context.Context, req *containerGRPC.ListRequest) (*containerGRPC.ListResponse, error)
  • func (s *Server) Put(ctx context.Context, req *containerGRPC.PutRequest) (*containerGRPC.PutResponse, error)
  • func (s *Server) SetExtendedACL(ctx context.Context, req *containerGRPC.SetExtendedACLRequest) (*containerGRPC.SetExtendedACLResponse, error)

Types

type Server

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

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

func New

func New(c containersvc.Server) *Server

New creates, initializes and returns Server instance.

func (*Server) AnnounceUsedSpace

func (s *Server) AnnounceUsedSpace(ctx context.Context, req *containerGRPC.AnnounceUsedSpaceRequest) (*containerGRPC.AnnounceUsedSpaceResponse, error)

AnnounceUsedSpace converts gRPC AnnounceUsedSpaceRequest message and passes it to internal Container service.

func (*Server) Delete

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

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

func (*Server) Get

func (s *Server) Get(ctx context.Context, req *containerGRPC.GetRequest) (*containerGRPC.GetResponse, error)

Get converts gRPC GetRequest message and passes it to internal Container service.

func (*Server) GetExtendedACL

func (s *Server) GetExtendedACL(ctx context.Context, req *containerGRPC.GetExtendedACLRequest) (*containerGRPC.GetExtendedACLResponse, error)

GetExtendedACL converts gRPC GetExtendedACLRequest message and passes it to internal Container service.

func (*Server) List

func (s *Server) List(ctx context.Context, req *containerGRPC.ListRequest) (*containerGRPC.ListResponse, error)

List converts gRPC ListRequest message and passes it to internal Container service.

func (*Server) Put

func (s *Server) Put(ctx context.Context, req *containerGRPC.PutRequest) (*containerGRPC.PutResponse, error)

Put converts gRPC PutRequest message and passes it to internal Container service.

func (*Server) SetExtendedACL

func (s *Server) SetExtendedACL(ctx context.Context, req *containerGRPC.SetExtendedACLRequest) (*containerGRPC.SetExtendedACLResponse, error)

SetExtendedACL converts gRPC SetExtendedACLRequest message and passes it to internal Container service.