grpc

Documentation

Index

• func NewServerWithBackend(backend backend.Storage) *grpc.Server
• type Server
  • func InitServer(backend backend.Storage) *Server
  • func (g *Server) ComposeObject(ctx context.Context, req *pb.ComposeObjectRequest) (*pb.Empty, error)
  • func (g *Server) DeleteBucket(ctx context.Context, req *pb.DeleteBucketRequest) (*pb.Empty, error)
  • func (g *Server) DeleteObject(ctx context.Context, req *pb.DeleteObjectRequest) (*pb.Empty, error)
  • func (g *Server) GetBucket(ctx context.Context, req *pb.GetBucketRequest) (*pb.Bucket, error)
  • func (g *Server) GetObject(ctx context.Context, req *pb.GetObjectRequest) (*pb.GetObjectMediaResponse, error)
  • func (g *Server) InsertBucket(ctx context.Context, req *pb.InsertBucketRequest) (*pb.Empty, error)
  • func (g *Server) InsertObject(ctx context.Context, req *pb.InsertObjectRequest) (*pb.Empty, error)
  • func (g *Server) ListBuckets(context.Context, *pb.ListBucketsRequest) (*pb.Buckets, error)
  • func (g *Server) ListObjects(ctx context.Context, req *pb.ListObjectsRequest) (*pb.Objects, error)
  • func (g *Server) PatchObject(ctx context.Context, req *pb.PatchObjectRequest) (*pb.Empty, error)
  • func (g *Server) UpdateObject(ctx context.Context, req *pb.UpdateObjectRequest) (*pb.Empty, error)

Functions

func NewServerWithBackend

func NewServerWithBackend(backend backend.Storage) *grpc.Server

Types

type Server

type Server struct {
	pb.UnimplementedStorageServerServer // To satisfy the interface without having to implement every method
	// contains filtered or unexported fields
}

func InitServer

func InitServer(backend backend.Storage) *Server

func (*Server) ComposeObject

func (g *Server) ComposeObject(ctx context.Context, req *pb.ComposeObjectRequest) (*pb.Empty, error)

ComposeObject(bucketName string, objectNames []string, destinationName string, metadata map[string]string, contentType string)

func (*Server) DeleteBucket

func (g *Server) DeleteBucket(ctx context.Context, req *pb.DeleteBucketRequest) (*pb.Empty, error)

func (*Server) DeleteObject

func (g *Server) DeleteObject(ctx context.Context, req *pb.DeleteObjectRequest) (*pb.Empty, error)

func (*Server) GetBucket

func (g *Server) GetBucket(ctx context.Context, req *pb.GetBucketRequest) (*pb.Bucket, error)

func (*Server) GetObject

func (g *Server) GetObject(ctx context.Context, req *pb.GetObjectRequest) (*pb.GetObjectMediaResponse, error)

func (*Server) InsertBucket

func (g *Server) InsertBucket(ctx context.Context, req *pb.InsertBucketRequest) (*pb.Empty, error)

func (*Server) InsertObject

func (g *Server) InsertObject(ctx context.Context, req *pb.InsertObjectRequest) (*pb.Empty, error)

func (*Server) ListBuckets

func (g *Server) ListBuckets(context.Context, *pb.ListBucketsRequest) (*pb.Buckets, error)

func (*Server) ListObjects

func (g *Server) ListObjects(ctx context.Context, req *pb.ListObjectsRequest) (*pb.Objects, error)

func (*Server) PatchObject

func (g *Server) PatchObject(ctx context.Context, req *pb.PatchObjectRequest) (*pb.Empty, error)

func (*Server) UpdateObject

func (g *Server) UpdateObject(ctx context.Context, req *pb.UpdateObjectRequest) (*pb.Empty, error)