test

package
v0.0.0-...-c2c101f Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 30, 2022 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateFs 

func CreateFs(req *types.CreateFsReq) (resp *types.CreateFsResp, err error)

func CreateFsSecret 

func CreateFsSecret(req *types.CreateSecretReq) (resp *types.CreateSecretResp, err error)

func DeleteFs 

func DeleteFs(req *types.DeleteFsReq) (resp *types.DeleteFsResp, err error)

func DeleteFsSecret 

func DeleteFsSecret(req *types.DeleteSecretReq) (resp *types.DeleteSecretResp, err error)

func DownloadFsSecret 

func DownloadFsSecret(req *types.DownloadSecretReq) (resp *types.DownloadSecretResp, err error)

func ListFs 

func ListFs(req *types.ListFsReq) (resp *types.ListFsResp, err error)

func ListFsSecret 

func ListFsSecret(req *types.ListSecretReq) (resp *types.ListSecretResp, err error)

func UpdateFsStatus 

func UpdateFsStatus(req *types.UpdateFsStatusReq) (resp *types.UpdateFsStatusResp, err error)

Types

type MetaClient 

type MetaClient struct {
	Client      pb.MetaServiceClient
	TokenClient pb.AuthTokenServiceClient
}

func NewMetaClient 

func NewMetaClient() (*MetaClient, error)

func (*MetaClient) CloseFile 

func (mc *MetaClient) CloseFile(ctx context.Context, in *pb.CloseFileMsg) (out *pb.CloseFileRet, err error)

func (*MetaClient) CreateFile 

func (mc *MetaClient) CreateFile(ctx context.Context, createFile *pb.CreateFileMsg) (createFileRet *pb.CreateFileRet, err error)

func (*MetaClient) CreateNewFile 

func (mc *MetaClient) CreateNewFile(ctx context.Context, in *pb.CreateNewFileMsg) (out *pb.CreateNewFileRet, err error)

func (*MetaClient) CreateSegment 

func (mc *MetaClient) CreateSegment(ctx context.Context, in *pb.CreateSegmentMsg) (out *pb.CreateSegmentRet, err error)

func (*MetaClient) DeleteDir 

func (mc *MetaClient) DeleteDir(ctx context.Context, deleteDir *pb.DeleteDirMsg) (deleteDirRet *pb.DeleteDirRet, err error)

func (*MetaClient) DeleteFile 

func (mc *MetaClient) DeleteFile(ctx context.Context, in *pb.DeleteFileMsg) (out *pb.DeleteFileRet, err error)

func (*MetaClient) GetDirFileAttr 

func (mc *MetaClient) GetDirFileAttr(ctx context.Context, dirFileAttr *pb.GetDirFileAttrMsg) (dirFileAttrRet *pb.GetDirFileAttrRet, err error)

func (*MetaClient) GetDirFiles 

func (mc *MetaClient) GetDirFiles(ctx context.Context, getDirFiles *pb.GetDirFilesMsg) (dirFilesRet *pb.GetDirFilesRet, err error)

func (*MetaClient) GetFileAttr 

func (mc *MetaClient) GetFileAttr(ctx context.Context, getFileAttr *pb.GetFileAttrMsg) (getFileAttrRet *pb.GetFileAttrRet, err error)

func (*MetaClient) GetFileLeader 

func (mc *MetaClient) GetFileLeader(ctx context.Context, getFileLeader *pb.GetFileLeaderMsg) (getFileLeaderRet *pb.GetFileLeaderRet, err error)

func (*MetaClient) GetLock 

func (mc *MetaClient) GetLock(ctx context.Context, in *pb.GetLockMsg) (out *pb.GetLockRet, err error)

func (*MetaClient) GetSegments 

func (mc *MetaClient) GetSegments(ctx context.Context, in *pb.GetSegmentsMsg) (out *pb.GetSegmentsRet, err error)

func (*MetaClient) HeartBeat 

func (mc *MetaClient) HeartBeat(ctx context.Context, in *pb.HeartBeatMsg) (out *pb.HeartBeatRet, err error)

func (*MetaClient) Init 

func (mc *MetaClient) Init(ctx context.Context, init *pb.InitMsg) (initRet *pb.InitRet, err error)

func (*MetaClient) Mount 

func (mc *MetaClient) Mount(ctx context.Context, mount *pb.MountMsg) (mountRet *pb.MountRet, err error)

func (*MetaClient) RefreshToken 

func (mc *MetaClient) RefreshToken(ctx context.Context, in *pb.RefreshTokenMsg) (out *pb.RefreshTokenRet, err error)

func (*MetaClient) ReleaseLock 

func (mc *MetaClient) ReleaseLock(ctx context.Context, in *pb.ReleaseLockMsg) (out *pb.ReleaseLockRet, err error)

func (*MetaClient) RenameFile 

func (mc *MetaClient) RenameFile(ctx context.Context, in *pb.RenameFileMsg) (out *pb.RenameFileRet, err error)

func (*MetaClient) SetFileAttr 

func (mc *MetaClient) SetFileAttr(ctx context.Context, in *pb.SetFileAttrMsg) (out *pb.SetFileAttrRet, err error)

func (*MetaClient) UpdateSegBlockInfo 

func (mc *MetaClient) UpdateSegBlockInfo(ctx context.Context, in *pb.UpdateSegBlockInfoMsg) (out *pb.UpdateSegBlockInfoRet, err error)

func (*MetaClient) UpdateSegments 

func (mc *MetaClient) UpdateSegments(ctx context.Context, in *pb.UpdateSegmentsMsg) (out *pb.UpdateSegmentsRet, err error)

type S3Client 

type S3Client struct {
	Client *s3.S3
}

func NewS3 

func NewS3() *S3Client

func (*S3Client) MakeBucket 

func (s *S3Client) MakeBucket(bucket string) (err error)

func (*S3Client) PutObject 

func (s *S3Client) PutObject(bucketName, objectName string, value []byte) (err error)

type SegmentId 

type SegmentId struct {
	SegId0  uint64
	SegId1  uint64
	SegSize uint64
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.