plugin

type BridgeStorageProviderServer struct {
	Storage storage.StorageProvider
	// contains filtered or unexported fields
}

type CloseFileQuery struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type ConfigData struct {
	Yaml []byte `protobuf:"bytes,1,opt,name=yaml,proto3" json:"yaml,omitempty"`
	// contains filtered or unexported fields
}

type DeleteQuery struct {
	User     *User  `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	FullPath string `protobuf:"bytes,2,opt,name=fullPath,proto3" json:"fullPath,omitempty"`
	// contains filtered or unexported fields
}

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

type File struct {
	Storage *GrpcStorage
	Id      int32
	// contains filtered or unexported fields
}

type FileInfo struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	FullPath  string `protobuf:"bytes,2,opt,name=fullPath,proto3" json:"fullPath,omitempty"`
	CreatedAt uint64 `protobuf:"varint,3,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	UpdatedAt uint64 `protobuf:"varint,4,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	Size      uint64 `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"`
	Directory bool   `protobuf:"varint,6,opt,name=directory,proto3" json:"directory,omitempty"`
	// contains filtered or unexported fields
}

type GrpcStorage struct {
	Conn   *grpc.ClientConn
	Client StorageProviderClient
	// contains filtered or unexported fields
}

type ListDirectoryQuery struct {
	User *User  `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

type MkdirQuery struct {
	User *User  `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

type MoveQuery struct {
	User *User  `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Src  string `protobuf:"bytes,2,opt,name=src,proto3" json:"src,omitempty"`
	Dst  string `protobuf:"bytes,3,opt,name=dst,proto3" json:"dst,omitempty"`
	// contains filtered or unexported fields
}

type OpenFileQuery struct {
	User     *User  `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	FullPath string `protobuf:"bytes,2,opt,name=fullPath,proto3" json:"fullPath,omitempty"`
	// contains filtered or unexported fields
}

type OpenFileReply struct {
	Id    int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type ReadFileQuery struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type ReadFileReply struct {
	Data  []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	EOF   bool   `protobuf:"varint,2,opt,name=EOF,proto3" json:"EOF,omitempty"`
	Error *Error `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type StorageProviderClient interface {
	Configure(ctx context.Context, in *ConfigData, opts ...grpc.CallOption) (*Error, error)
	InitUser(ctx context.Context, in *User, opts ...grpc.CallOption) (*Error, error)
	MkDir(ctx context.Context, in *MkdirQuery, opts ...grpc.CallOption) (*Error, error)
	Move(ctx context.Context, in *MoveQuery, opts ...grpc.CallOption) (*Error, error)
	ListDirectory(ctx context.Context, in *ListDirectoryQuery, opts ...grpc.CallOption) (StorageProvider_ListDirectoryClient, error)
	OpenFile(ctx context.Context, in *OpenFileQuery, opts ...grpc.CallOption) (*OpenFileReply, error)
	CloseFile(ctx context.Context, in *CloseFileQuery, opts ...grpc.CallOption) (*Error, error)
	WriteFile(ctx context.Context, in *WriteFileQuery, opts ...grpc.CallOption) (*WriteFileReply, error)
	ReadFile(ctx context.Context, in *ReadFileQuery, opts ...grpc.CallOption) (StorageProvider_ReadFileClient, error)
	Delete(ctx context.Context, in *DeleteQuery, opts ...grpc.CallOption) (*Error, error)
}

type StorageProviderServer interface {
	Configure(context.Context, *ConfigData) (*Error, error)
	InitUser(context.Context, *User) (*Error, error)
	MkDir(context.Context, *MkdirQuery) (*Error, error)
	Move(context.Context, *MoveQuery) (*Error, error)
	ListDirectory(*ListDirectoryQuery, StorageProvider_ListDirectoryServer) error
	OpenFile(context.Context, *OpenFileQuery) (*OpenFileReply, error)
	CloseFile(context.Context, *CloseFileQuery) (*Error, error)
	WriteFile(context.Context, *WriteFileQuery) (*WriteFileReply, error)
	ReadFile(*ReadFileQuery, StorageProvider_ReadFileServer) error
	Delete(context.Context, *DeleteQuery) (*Error, error)
	// contains filtered or unexported methods
}

type StorageProvider_ListDirectoryClient interface {
	Recv() (*FileInfo, error)
	grpc.ClientStream
}

type StorageProvider_ListDirectoryServer interface {
	Send(*FileInfo) error
	grpc.ServerStream
}

type StorageProvider_ReadFileClient interface {
	Recv() (*ReadFileReply, error)
	grpc.ClientStream
}

type StorageProvider_ReadFileServer interface {
	Send(*ReadFileReply) error
	grpc.ServerStream
}

type UnimplementedStorageProviderServer struct {
}

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

type User struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type WriteFileQuery struct {
	Id   int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type WriteFileReply struct {
	SizeWritten int32  `protobuf:"varint,1,opt,name=size_written,json=sizeWritten,proto3" json:"size_written,omitempty"`
	Error       *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}