rpc

Documentation

Index

• func NewInterceptor() *interceptor
• type BasicAuthResponse
• type CloudfsClient
  • func NewCloudfsClient(conn *grpc.ClientConn) *CloudfsClient
  • func (b *CloudfsClient) BasicAuth(ctx context.Context, username, password string) (*BasicAuthResponse, error)
  • func (b *CloudfsClient) Delete(ctx context.Context, userToken, filename string) (*DeleteResponse, error)
  • func (b *CloudfsClient) DownloadObject(ctx context.Context, userToken, filename string) (*GetObjectResult, error)
  • func (b *CloudfsClient) DownloadWithToken(ctx context.Context, shareToken string) (*GetObjectResult, error)
  • func (b *CloudfsClient) Objects(ctx context.Context, userToken, lastFilename string, limit int) (<-chan *Object, error)
  • func (b *CloudfsClient) Register(ctx context.Context, param RegisterParam) (*RegisterResult, error)
  • func (b *CloudfsClient) ShareObject(ctx context.Context, userToken, filename string) (*SharedObject, error)
  • func (b *CloudfsClient) UploadObject(ctx context.Context, userToken, filename, contentType string, size int64, ...) (*UploadResult, error)
• type DeleteResponse
• type GetObjectResult
• type GrpcServer
  • func NewGrpcServer(objects *blob.Storage, accounts *user.Users) *GrpcServer
  • func (g *GrpcServer) BasicAuth(ctx context.Context, req *apipb.BasicAuthRequest) (*apipb.BasicAuthResponse, error)
  • func (g *GrpcServer) DeleteObject(ctx context.Context, req *apipb.DeleteRequest) (*apipb.DeleteResponse, error)
  • func (g *GrpcServer) DownloadObject(req *apipb.DownloadRequest, ...) error
  • func (g *GrpcServer) DownloadSharedObject(req *apipb.DownloadSharedRequest, ...) error
  • func (g *GrpcServer) ListObject(req *apipb.ListObjectRequest, ...) error
  • func (g *GrpcServer) Register(ctx context.Context, req *apipb.RegisterRequest) (*apipb.RegisterResponse, error)
  • func (g *GrpcServer) ShareObject(ctx context.Context, req *apipb.ShareObjectRequest) (*apipb.ShareObjectResponse, error)
  • func (g *GrpcServer) TokenAuth(ctx context.Context, req *apipb.TokenAuthRequest) (*apipb.TokenAuthResponse, error)
  • func (g *GrpcServer) UploadObject(stream grpc.ClientStreamingServer[apipb.UploadRequest, apipb.UploadResponse]) error
• type Object
  • func (o *Object) Err() error
• type RegisterParam
• type RegisterResult
• type SharedObject
• type UploadResult

Functions

func NewInterceptor

func NewInterceptor() *interceptor

Types

type BasicAuthResponse

type BasicAuthResponse struct {
	Token string
}

type CloudfsClient

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

wrap backend grpc api call

func NewCloudfsClient

func NewCloudfsClient(conn *grpc.ClientConn) *CloudfsClient

func (*CloudfsClient) BasicAuth

func (b *CloudfsClient) BasicAuth(ctx context.Context, username, password string) (*BasicAuthResponse, error)

func (*CloudfsClient) Delete

func (b *CloudfsClient) Delete(ctx context.Context, userToken, filename string) (*DeleteResponse, error)

func (*CloudfsClient) DownloadObject

func (b *CloudfsClient) DownloadObject(ctx context.Context, userToken, filename string) (*GetObjectResult, error)

func (*CloudfsClient) DownloadWithToken

func (b *CloudfsClient) DownloadWithToken(ctx context.Context, shareToken string) (*GetObjectResult, error)

func (*CloudfsClient) Objects

func (b *CloudfsClient) Objects(ctx context.Context, userToken, lastFilename string, limit int) (<-chan *Object, error)

func (*CloudfsClient) Register

func (b *CloudfsClient) Register(ctx context.Context, param RegisterParam) (*RegisterResult, error)

func (*CloudfsClient) ShareObject

func (b *CloudfsClient) ShareObject(ctx context.Context, userToken, filename string) (*SharedObject, error)

func (*CloudfsClient) UploadObject

func (b *CloudfsClient) UploadObject(ctx context.Context, userToken, filename, contentType string, size int64, body io.Reader) (*UploadResult, error)

type DeleteResponse

type DeleteResponse struct {
	DeletedAt time.Time
}

type GetObjectResult

type GetObjectResult struct {
	Filename    string
	ContentType string
	Size        int64
	Reader      io.ReadCloser
}

type GrpcServer

type GrpcServer struct {
	apipb.UnimplementedStorageServiceServer
	// contains filtered or unexported fields
}

func NewGrpcServer

func NewGrpcServer(objects *blob.Storage, accounts *user.Users) *GrpcServer

func (*GrpcServer) BasicAuth

func (g *GrpcServer) BasicAuth(ctx context.Context, req *apipb.BasicAuthRequest) (*apipb.BasicAuthResponse, error)

func (*GrpcServer) DeleteObject

func (g *GrpcServer) DeleteObject(ctx context.Context, req *apipb.DeleteRequest) (*apipb.DeleteResponse, error)

func (*GrpcServer) DownloadObject

func (g *GrpcServer) DownloadObject(req *apipb.DownloadRequest, stream grpc.ServerStreamingServer[apipb.DownloadResponse]) error

Download implements apipb.StorageServiceServer.

func (*GrpcServer) DownloadSharedObject

func (g *GrpcServer) DownloadSharedObject(req *apipb.DownloadSharedRequest, stream grpc.ServerStreamingServer[apipb.DownloadResponse]) error

func (*GrpcServer) ListObject

func (g *GrpcServer) ListObject(req *apipb.ListObjectRequest, stream grpc.ServerStreamingServer[apipb.ListObjectResponse]) error

func (*GrpcServer) Register

func (g *GrpcServer) Register(ctx context.Context, req *apipb.RegisterRequest) (*apipb.RegisterResponse, error)

func (*GrpcServer) ShareObject

func (g *GrpcServer) ShareObject(ctx context.Context, req *apipb.ShareObjectRequest) (*apipb.ShareObjectResponse, error)

func (*GrpcServer) TokenAuth

func (g *GrpcServer) TokenAuth(ctx context.Context, req *apipb.TokenAuthRequest) (*apipb.TokenAuthResponse, error)

func (*GrpcServer) UploadObject

func (g *GrpcServer) UploadObject(stream grpc.ClientStreamingServer[apipb.UploadRequest, apipb.UploadResponse]) error

Upload implements apipb.StorageServiceServer.

type Object

type Object struct {
	UserID       string
	Filename     string
	Sum          string
	Size         int64
	LastModified time.Time
	ContentType  string
	// contains filtered or unexported fields
}

func (*Object) Err

func (o *Object) Err() error

type RegisterParam

type RegisterParam struct {
	Username string
	Password string
}

type RegisterResult

type RegisterResult struct {
	UserID string
}

type SharedObject

type SharedObject struct {
	ShareToken string
	ValidUntil time.Time
}

type UploadResult

type UploadResult struct {
	Sum string
}