service

Documentation

Index

• type VerifiableRemoteFileStorageServer
  • func New(l *logger.Logger, cfg *config.Config) (*VerifiableRemoteFileStorageServer, error)
  • func (g *VerifiableRemoteFileStorageServer) ContextError(ctx context.Context) error
  • func (g *VerifiableRemoteFileStorageServer) DownloadFileInfo(ctx context.Context, in *pb.DownloadFileInfoRequest) (*pb.DownloadFileInfoResponse, error)
  • func (g *VerifiableRemoteFileStorageServer) LogError(err error) error
  • func (g *VerifiableRemoteFileStorageServer) Ping(ctx context.Context, in *pb.PingRequest) (*pb.PingReply, error)
  • func (g *VerifiableRemoteFileStorageServer) UploadBucket(ctx context.Context, in *pb.UploadBucketRequest) (*pb.UploadBucketResponse, error)
  • func (g *VerifiableRemoteFileStorageServer) UploadDone(ctx context.Context, in *pb.UploadDoneRequest) (*pb.UploadDoneResponse, error)

Types

type VerifiableRemoteFileStorageServer

type VerifiableRemoteFileStorageServer struct {
	pb.UnimplementedVerifiableRemoteFileStorageServer
	// contains filtered or unexported fields
}

Service execution context

func New

func New(l *logger.Logger, cfg *config.Config) (*VerifiableRemoteFileStorageServer, error)

Init the service execution context

func (*VerifiableRemoteFileStorageServer) ContextError

func (g *VerifiableRemoteFileStorageServer) ContextError(ctx context.Context) error

func (*VerifiableRemoteFileStorageServer) DownloadFileInfo

func (g *VerifiableRemoteFileStorageServer) DownloadFileInfo(ctx context.Context, in *pb.DownloadFileInfoRequest) (*pb.DownloadFileInfoResponse, error)

Get the download info to retrieve a file from the files storage server as well as the MerkleTree proofs to confirm it has not been tampered while being stored or transfered

func (*VerifiableRemoteFileStorageServer) LogError

func (g *VerifiableRemoteFileStorageServer) LogError(err error) error

func (*VerifiableRemoteFileStorageServer) Ping

func (g *VerifiableRemoteFileStorageServer) Ping(ctx context.Context, in *pb.PingRequest) (*pb.PingReply, error)

Handle the requests for ping requests

func (*VerifiableRemoteFileStorageServer) UploadBucket

func (g *VerifiableRemoteFileStorageServer) UploadBucket(ctx context.Context, in *pb.UploadBucketRequest) (*pb.UploadBucketResponse, error)

Handle the requests for file bucket where files can be uploaded on the Remote File Storage server

func (*VerifiableRemoteFileStorageServer) UploadDone

func (g *VerifiableRemoteFileStorageServer) UploadDone(ctx context.Context, in *pb.UploadDoneRequest) (*pb.UploadDoneResponse, error)

Handle the requests for notifying that a fileset has been uploaded, its consistency verified and confirmed to the client