meta_server

package
v0.0.0-...-7ce57cb Latest Latest
Warning

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

Go to latest
Published: Aug 24, 2022 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_meta_server_proto protoreflect.FileDescriptor
View Source
var MetaServer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "meta_server.MetaServer",
	HandlerType: (*MetaServerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateFile",
			Handler:    _MetaServer_CreateFile_Handler,
		},
		{
			MethodName: "AppendFile",
			Handler:    _MetaServer_AppendFile_Handler,
		},
		{
			MethodName: "GetFile",
			Handler:    _MetaServer_GetFile_Handler,
		},
		{
			MethodName: "Stat",
			Handler:    _MetaServer_Stat_Handler,
		},
		{
			MethodName: "Remove",
			Handler:    _MetaServer_Remove_Handler,
		},
		{
			MethodName: "Move",
			Handler:    _MetaServer_Move_Handler,
		},
		{
			MethodName: "Mkdir",
			Handler:    _MetaServer_Mkdir_Handler,
		},
		{
			MethodName: "List",
			Handler:    _MetaServer_List_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _MetaServer_Ping_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "meta_server.proto",
}

MetaServer_ServiceDesc is the grpc.ServiceDesc for MetaServer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMetaServerServer

func RegisterMetaServerServer(s grpc.ServiceRegistrar, srv MetaServerServer)

Types

type AppendFileRequest

type AppendFileRequest struct {
	ClientId string       `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	Dir      string       `protobuf:"bytes,2,opt,name=dir,proto3" json:"dir,omitempty"`
	Entry    []*rfs.Entry `protobuf:"bytes,3,rep,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendFileRequest) Descriptor deprecated

func (*AppendFileRequest) Descriptor() ([]byte, []int)

Deprecated: Use AppendFileRequest.ProtoReflect.Descriptor instead.

func (*AppendFileRequest) GetClientId

func (x *AppendFileRequest) GetClientId() string

func (*AppendFileRequest) GetDir

func (x *AppendFileRequest) GetDir() string

func (*AppendFileRequest) GetEntry

func (x *AppendFileRequest) GetEntry() []*rfs.Entry

func (*AppendFileRequest) ProtoMessage

func (*AppendFileRequest) ProtoMessage()

func (*AppendFileRequest) ProtoReflect

func (x *AppendFileRequest) ProtoReflect() protoreflect.Message

func (*AppendFileRequest) Reset

func (x *AppendFileRequest) Reset()

func (*AppendFileRequest) String

func (x *AppendFileRequest) String() string

type AppendFileResponse

type AppendFileResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendFileResponse) Descriptor deprecated

func (*AppendFileResponse) Descriptor() ([]byte, []int)

Deprecated: Use AppendFileResponse.ProtoReflect.Descriptor instead.

func (*AppendFileResponse) GetError

func (x *AppendFileResponse) GetError() string

func (*AppendFileResponse) ProtoMessage

func (*AppendFileResponse) ProtoMessage()

func (*AppendFileResponse) ProtoReflect

func (x *AppendFileResponse) ProtoReflect() protoreflect.Message

func (*AppendFileResponse) Reset

func (x *AppendFileResponse) Reset()

func (*AppendFileResponse) String

func (x *AppendFileResponse) String() string

type CreateFileRequest

type CreateFileRequest struct {
	ClientId                 string     `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	Dir                      string     `protobuf:"bytes,2,opt,name=dir,proto3" json:"dir,omitempty"`
	OExcl                    bool       `protobuf:"varint,3,opt,name=o_excl,json=oExcl,proto3" json:"o_excl,omitempty"`
	SkipCheckParentDirectory bool       `` /* 138-byte string literal not displayed */
	Entry                    *rfs.Entry `protobuf:"bytes,5,opt,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFileRequest) Descriptor deprecated

func (*CreateFileRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateFileRequest.ProtoReflect.Descriptor instead.

func (*CreateFileRequest) GetClientId

func (x *CreateFileRequest) GetClientId() string

func (*CreateFileRequest) GetDir

func (x *CreateFileRequest) GetDir() string

func (*CreateFileRequest) GetEntry

func (x *CreateFileRequest) GetEntry() *rfs.Entry

func (*CreateFileRequest) GetOExcl

func (x *CreateFileRequest) GetOExcl() bool

func (*CreateFileRequest) GetSkipCheckParentDirectory

func (x *CreateFileRequest) GetSkipCheckParentDirectory() bool

func (*CreateFileRequest) ProtoMessage

func (*CreateFileRequest) ProtoMessage()

func (*CreateFileRequest) ProtoReflect

func (x *CreateFileRequest) ProtoReflect() protoreflect.Message

func (*CreateFileRequest) Reset

func (x *CreateFileRequest) Reset()

func (*CreateFileRequest) String

func (x *CreateFileRequest) String() string

type CreateFileResponse

type CreateFileResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFileResponse) Descriptor deprecated

func (*CreateFileResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateFileResponse.ProtoReflect.Descriptor instead.

func (*CreateFileResponse) GetError

func (x *CreateFileResponse) GetError() string

func (*CreateFileResponse) ProtoMessage

func (*CreateFileResponse) ProtoMessage()

func (*CreateFileResponse) ProtoReflect

func (x *CreateFileResponse) ProtoReflect() protoreflect.Message

func (*CreateFileResponse) Reset

func (x *CreateFileResponse) Reset()

func (*CreateFileResponse) String

func (x *CreateFileResponse) String() string

type GetFileRequest

type GetFileRequest struct {
	ClientId string `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	Path     string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFileRequest) Descriptor deprecated

func (*GetFileRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetFileRequest.ProtoReflect.Descriptor instead.

func (*GetFileRequest) GetClientId

func (x *GetFileRequest) GetClientId() string

func (*GetFileRequest) GetPath

func (x *GetFileRequest) GetPath() string

func (*GetFileRequest) ProtoMessage

func (*GetFileRequest) ProtoMessage()

func (*GetFileRequest) ProtoReflect

func (x *GetFileRequest) ProtoReflect() protoreflect.Message

func (*GetFileRequest) Reset

func (x *GetFileRequest) Reset()

func (*GetFileRequest) String

func (x *GetFileRequest) String() string

type GetFileResponse

type GetFileResponse struct {
	Error string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Entry *rfs.Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFileResponse) Descriptor deprecated

func (*GetFileResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetFileResponse.ProtoReflect.Descriptor instead.

func (*GetFileResponse) GetEntry

func (x *GetFileResponse) GetEntry() *rfs.Entry

func (*GetFileResponse) GetError

func (x *GetFileResponse) GetError() string

func (*GetFileResponse) ProtoMessage

func (*GetFileResponse) ProtoMessage()

func (*GetFileResponse) ProtoReflect

func (x *GetFileResponse) ProtoReflect() protoreflect.Message

func (*GetFileResponse) Reset

func (x *GetFileResponse) Reset()

func (*GetFileResponse) String

func (x *GetFileResponse) String() string

type ListRequest

type ListRequest struct {
	ClientId string `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	Dir      string `protobuf:"bytes,2,opt,name=dir,proto3" json:"dir,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated

func (*ListRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetClientId

func (x *ListRequest) GetClientId() string

func (*ListRequest) GetDir

func (x *ListRequest) GetDir() string

func (*ListRequest) ProtoMessage

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect

func (x *ListRequest) ProtoReflect() protoreflect.Message

func (*ListRequest) Reset

func (x *ListRequest) Reset()

func (*ListRequest) String

func (x *ListRequest) String() string

type ListResponse

type ListResponse struct {
	Error   string       `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Entries []*rfs.Entry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated

func (*ListResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetEntries

func (x *ListResponse) GetEntries() []*rfs.Entry

func (*ListResponse) GetError

func (x *ListResponse) GetError() string

func (*ListResponse) ProtoMessage

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect

func (x *ListResponse) ProtoReflect() protoreflect.Message

func (*ListResponse) Reset

func (x *ListResponse) Reset()

func (*ListResponse) String

func (x *ListResponse) String() string

type MetaServerClient

type MetaServerClient interface {
	CreateFile(ctx context.Context, in *CreateFileRequest, opts ...grpc.CallOption) (*CreateFileResponse, error)
	AppendFile(ctx context.Context, in *AppendFileRequest, opts ...grpc.CallOption) (*AppendFileResponse, error)
	GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (*GetFileResponse, error)
	Stat(ctx context.Context, in *StatRequest, opts ...grpc.CallOption) (*StatResponse, error)
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error)
	Move(ctx context.Context, in *MoveRequest, opts ...grpc.CallOption) (*MoveResponse, error)
	Mkdir(ctx context.Context, in *MkdirRequest, opts ...grpc.CallOption) (*MkdirResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
}

MetaServerClient is the client API for MetaServer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMetaServerClient

func NewMetaServerClient(cc grpc.ClientConnInterface) MetaServerClient

type MetaServerServer

MetaServerServer is the server API for MetaServer service. All implementations must embed UnimplementedMetaServerServer for forward compatibility

type MkdirRequest

type MkdirRequest struct {
	ClientId  string `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	Directory string `protobuf:"bytes,2,opt,name=directory,proto3" json:"directory,omitempty"`
	// contains filtered or unexported fields
}

func (*MkdirRequest) Descriptor deprecated

func (*MkdirRequest) Descriptor() ([]byte, []int)

Deprecated: Use MkdirRequest.ProtoReflect.Descriptor instead.

func (*MkdirRequest) GetClientId

func (x *MkdirRequest) GetClientId() string

func (*MkdirRequest) GetDirectory

func (x *MkdirRequest) GetDirectory() string

func (*MkdirRequest) ProtoMessage

func (*MkdirRequest) ProtoMessage()

func (*MkdirRequest) ProtoReflect

func (x *MkdirRequest) ProtoReflect() protoreflect.Message

func (*MkdirRequest) Reset

func (x *MkdirRequest) Reset()

func (*MkdirRequest) String

func (x *MkdirRequest) String() string

type MkdirResponse

type MkdirResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*MkdirResponse) Descriptor deprecated

func (*MkdirResponse) Descriptor() ([]byte, []int)

Deprecated: Use MkdirResponse.ProtoReflect.Descriptor instead.

func (*MkdirResponse) GetError

func (x *MkdirResponse) GetError() string

func (*MkdirResponse) ProtoMessage

func (*MkdirResponse) ProtoMessage()

func (*MkdirResponse) ProtoReflect

func (x *MkdirResponse) ProtoReflect() protoreflect.Message

func (*MkdirResponse) Reset

func (x *MkdirResponse) Reset()

func (*MkdirResponse) String

func (x *MkdirResponse) String() string

type MoveRequest

type MoveRequest struct {
	ClientId string `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	SrcPath  string `protobuf:"bytes,2,opt,name=src_path,json=srcPath,proto3" json:"src_path,omitempty"`
	DstPath  string `protobuf:"bytes,3,opt,name=dst_path,json=dstPath,proto3" json:"dst_path,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveRequest) Descriptor deprecated

func (*MoveRequest) Descriptor() ([]byte, []int)

Deprecated: Use MoveRequest.ProtoReflect.Descriptor instead.

func (*MoveRequest) GetClientId

func (x *MoveRequest) GetClientId() string

func (*MoveRequest) GetDstPath

func (x *MoveRequest) GetDstPath() string

func (*MoveRequest) GetSrcPath

func (x *MoveRequest) GetSrcPath() string

func (*MoveRequest) ProtoMessage

func (*MoveRequest) ProtoMessage()

func (*MoveRequest) ProtoReflect

func (x *MoveRequest) ProtoReflect() protoreflect.Message

func (*MoveRequest) Reset

func (x *MoveRequest) Reset()

func (*MoveRequest) String

func (x *MoveRequest) String() string

type MoveResponse

type MoveResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveResponse) Descriptor deprecated

func (*MoveResponse) Descriptor() ([]byte, []int)

Deprecated: Use MoveResponse.ProtoReflect.Descriptor instead.

func (*MoveResponse) GetError

func (x *MoveResponse) GetError() string

func (*MoveResponse) ProtoMessage

func (*MoveResponse) ProtoMessage()

func (*MoveResponse) ProtoReflect

func (x *MoveResponse) ProtoReflect() protoreflect.Message

func (*MoveResponse) Reset

func (x *MoveResponse) Reset()

func (*MoveResponse) String

func (x *MoveResponse) String() string

type PingRequest

type PingRequest struct {
	Target     string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	TargetType string `protobuf:"bytes,2,opt,name=target_type,json=targetType,proto3" json:"target_type,omitempty"`
	// contains filtered or unexported fields
}

func (*PingRequest) Descriptor deprecated

func (*PingRequest) Descriptor() ([]byte, []int)

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) GetTarget

func (x *PingRequest) GetTarget() string

func (*PingRequest) GetTargetType

func (x *PingRequest) GetTargetType() string

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect

func (x *PingRequest) ProtoReflect() protoreflect.Message

func (*PingRequest) Reset

func (x *PingRequest) Reset()

func (*PingRequest) String

func (x *PingRequest) String() string

type PingResponse

type PingResponse struct {
	StartTimeNs  int64 `protobuf:"varint,1,opt,name=start_time_ns,json=startTimeNs,proto3" json:"start_time_ns,omitempty"`
	RemoteTimeNs int64 `protobuf:"varint,2,opt,name=remote_time_ns,json=remoteTimeNs,proto3" json:"remote_time_ns,omitempty"`
	StopTimeNs   int64 `protobuf:"varint,3,opt,name=stop_time_ns,json=stopTimeNs,proto3" json:"stop_time_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*PingResponse) Descriptor deprecated

func (*PingResponse) Descriptor() ([]byte, []int)

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetRemoteTimeNs

func (x *PingResponse) GetRemoteTimeNs() int64

func (*PingResponse) GetStartTimeNs

func (x *PingResponse) GetStartTimeNs() int64

func (*PingResponse) GetStopTimeNs

func (x *PingResponse) GetStopTimeNs() int64

func (*PingResponse) ProtoMessage

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect

func (x *PingResponse) ProtoReflect() protoreflect.Message

func (*PingResponse) Reset

func (x *PingResponse) Reset()

func (*PingResponse) String

func (x *PingResponse) String() string

type RemoveRequest

type RemoveRequest struct {
	ClientId  string `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	Path      string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Recursive bool   `protobuf:"varint,3,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveRequest) Descriptor deprecated

func (*RemoveRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.

func (*RemoveRequest) GetClientId

func (x *RemoveRequest) GetClientId() string

func (*RemoveRequest) GetPath

func (x *RemoveRequest) GetPath() string

func (*RemoveRequest) GetRecursive

func (x *RemoveRequest) GetRecursive() bool

func (*RemoveRequest) ProtoMessage

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) ProtoReflect

func (x *RemoveRequest) ProtoReflect() protoreflect.Message

func (*RemoveRequest) Reset

func (x *RemoveRequest) Reset()

func (*RemoveRequest) String

func (x *RemoveRequest) String() string

type RemoveResponse

type RemoveResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveResponse) Descriptor deprecated

func (*RemoveResponse) Descriptor() ([]byte, []int)

Deprecated: Use RemoveResponse.ProtoReflect.Descriptor instead.

func (*RemoveResponse) GetError

func (x *RemoveResponse) GetError() string

func (*RemoveResponse) ProtoMessage

func (*RemoveResponse) ProtoMessage()

func (*RemoveResponse) ProtoReflect

func (x *RemoveResponse) ProtoReflect() protoreflect.Message

func (*RemoveResponse) Reset

func (x *RemoveResponse) Reset()

func (*RemoveResponse) String

func (x *RemoveResponse) String() string

type StatRequest

type StatRequest struct {
	ClientId string `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	Path     string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*StatRequest) Descriptor deprecated

func (*StatRequest) Descriptor() ([]byte, []int)

Deprecated: Use StatRequest.ProtoReflect.Descriptor instead.

func (*StatRequest) GetClientId

func (x *StatRequest) GetClientId() string

func (*StatRequest) GetPath

func (x *StatRequest) GetPath() string

func (*StatRequest) ProtoMessage

func (*StatRequest) ProtoMessage()

func (*StatRequest) ProtoReflect

func (x *StatRequest) ProtoReflect() protoreflect.Message

func (*StatRequest) Reset

func (x *StatRequest) Reset()

func (*StatRequest) String

func (x *StatRequest) String() string

type StatResponse

type StatResponse struct {
	Error string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Entry *rfs.Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

func (*StatResponse) Descriptor deprecated

func (*StatResponse) Descriptor() ([]byte, []int)

Deprecated: Use StatResponse.ProtoReflect.Descriptor instead.

func (*StatResponse) GetEntry

func (x *StatResponse) GetEntry() *rfs.Entry

func (*StatResponse) GetError

func (x *StatResponse) GetError() string

func (*StatResponse) ProtoMessage

func (*StatResponse) ProtoMessage()

func (*StatResponse) ProtoReflect

func (x *StatResponse) ProtoReflect() protoreflect.Message

func (*StatResponse) Reset

func (x *StatResponse) Reset()

func (*StatResponse) String

func (x *StatResponse) String() string

type UnimplementedMetaServerServer

type UnimplementedMetaServerServer struct {
}

UnimplementedMetaServerServer must be embedded to have forward compatible implementations.

func (UnimplementedMetaServerServer) AppendFile

func (UnimplementedMetaServerServer) CreateFile

func (UnimplementedMetaServerServer) GetFile

func (UnimplementedMetaServerServer) List

func (UnimplementedMetaServerServer) Mkdir

func (UnimplementedMetaServerServer) Move

func (UnimplementedMetaServerServer) Ping

func (UnimplementedMetaServerServer) Remove

func (UnimplementedMetaServerServer) Stat

type UnsafeMetaServerServer

type UnsafeMetaServerServer interface {
	// contains filtered or unexported methods
}

UnsafeMetaServerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetaServerServer will result in compilation errors.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL