Documentation
¶
Index ¶
- Variables
- func RegisterDagPoolServer(s grpc.ServiceRegistrar, srv DagPoolServer)
- func RegisterDataNodeServer(s grpc.ServiceRegistrar, srv DataNodeServer)
- type AddReply
- type AddReq
- type AddRequest
- type AddResponse
- type AddUserReply
- type AddUserReq
- func (*AddUserReq) Descriptor() ([]byte, []int)deprecated
- func (x *AddUserReq) GetCapacity() uint64
- func (x *AddUserReq) GetPassword() string
- func (x *AddUserReq) GetPolicy() string
- func (x *AddUserReq) GetUser() *PoolUser
- func (x *AddUserReq) GetUsername() string
- func (*AddUserReq) ProtoMessage()
- func (x *AddUserReq) ProtoReflect() protoreflect.Message
- func (x *AddUserReq) Reset()
- func (x *AddUserReq) String() string
- type DagPoolClient
- type DagPoolServer
- type DataNodeClient
- type DataNodeServer
- type DeleteRequest
- type DeleteResponse
- type GetReply
- type GetReq
- type GetRequest
- type GetResponse
- type GetSizeReply
- type GetSizeReq
- type PoolUser
- type QueryUserReply
- func (*QueryUserReply) Descriptor() ([]byte, []int)deprecated
- func (x *QueryUserReply) GetCapacity() uint64
- func (x *QueryUserReply) GetPolicy() string
- func (x *QueryUserReply) GetUsername() string
- func (*QueryUserReply) ProtoMessage()
- func (x *QueryUserReply) ProtoReflect() protoreflect.Message
- func (x *QueryUserReply) Reset()
- func (x *QueryUserReply) String() string
- type QueryUserReq
- func (*QueryUserReq) Descriptor() ([]byte, []int)deprecated
- func (x *QueryUserReq) GetUser() *PoolUser
- func (x *QueryUserReq) GetUsername() string
- func (*QueryUserReq) ProtoMessage()
- func (x *QueryUserReq) ProtoReflect() protoreflect.Message
- func (x *QueryUserReq) Reset()
- func (x *QueryUserReq) String() string
- type RemoveReply
- type RemoveReq
- type RemoveUserReply
- type RemoveUserReq
- func (*RemoveUserReq) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveUserReq) GetUser() *PoolUser
- func (x *RemoveUserReq) GetUsername() string
- func (*RemoveUserReq) ProtoMessage()
- func (x *RemoveUserReq) ProtoReflect() protoreflect.Message
- func (x *RemoveUserReq) Reset()
- func (x *RemoveUserReq) String() string
- type SizeRequest
- type SizeResponse
- type UnimplementedDagPoolServer
- func (UnimplementedDagPoolServer) Add(context.Context, *AddReq) (*AddReply, error)
- func (UnimplementedDagPoolServer) AddUser(context.Context, *AddUserReq) (*AddUserReply, error)
- func (UnimplementedDagPoolServer) Get(context.Context, *GetReq) (*GetReply, error)
- func (UnimplementedDagPoolServer) GetSize(context.Context, *GetSizeReq) (*GetSizeReply, error)
- func (UnimplementedDagPoolServer) QueryUser(context.Context, *QueryUserReq) (*QueryUserReply, error)
- func (UnimplementedDagPoolServer) Remove(context.Context, *RemoveReq) (*RemoveReply, error)
- func (UnimplementedDagPoolServer) RemoveUser(context.Context, *RemoveUserReq) (*RemoveUserReply, error)
- func (UnimplementedDagPoolServer) UpdateUser(context.Context, *UpdateUserReq) (*UpdateUserReply, error)
- type UnimplementedDataNodeServer
- func (UnimplementedDataNodeServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
- func (UnimplementedDataNodeServer) Get(context.Context, *GetRequest) (*GetResponse, error)
- func (UnimplementedDataNodeServer) Put(context.Context, *AddRequest) (*AddResponse, error)
- func (UnimplementedDataNodeServer) Size(context.Context, *SizeRequest) (*SizeResponse, error)
- type UnsafeDagPoolServer
- type UnsafeDataNodeServer
- type UpdateUserReply
- type UpdateUserReq
- func (*UpdateUserReq) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateUserReq) GetNewCapacity() uint64
- func (x *UpdateUserReq) GetNewPassword() string
- func (x *UpdateUserReq) GetNewPolicy() string
- func (x *UpdateUserReq) GetUser() *PoolUser
- func (x *UpdateUserReq) GetUsername() string
- func (*UpdateUserReq) ProtoMessage()
- func (x *UpdateUserReq) ProtoReflect() protoreflect.Message
- func (x *UpdateUserReq) Reset()
- func (x *UpdateUserReq) String() string
Constants ¶
This section is empty.
Variables ¶
var DagPool_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.DagPool", HandlerType: (*DagPoolServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Add", Handler: _DagPool_Add_Handler, }, { MethodName: "Get", Handler: _DagPool_Get_Handler, }, { MethodName: "Remove", Handler: _DagPool_Remove_Handler, }, { MethodName: "GetSize", Handler: _DagPool_GetSize_Handler, }, { MethodName: "AddUser", Handler: _DagPool_AddUser_Handler, }, { MethodName: "RemoveUser", Handler: _DagPool_RemoveUser_Handler, }, { MethodName: "QueryUser", Handler: _DagPool_QueryUser_Handler, }, { MethodName: "UpdateUser", Handler: _DagPool_UpdateUser_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "dagpool.proto", }
DagPool_ServiceDesc is the grpc.ServiceDesc for DagPool service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var DataNode_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.DataNode", HandlerType: (*DataNodeServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Put", Handler: _DataNode_Put_Handler, }, { MethodName: "Get", Handler: _DataNode_Get_Handler, }, { MethodName: "Delete", Handler: _DataNode_Delete_Handler, }, { MethodName: "Size", Handler: _DataNode_Size_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "datanode.proto", }
DataNode_ServiceDesc is the grpc.ServiceDesc for DataNode service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_dagpool_proto protoreflect.FileDescriptor
var File_datanode_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDagPoolServer ¶
func RegisterDagPoolServer(s grpc.ServiceRegistrar, srv DagPoolServer)
func RegisterDataNodeServer ¶
func RegisterDataNodeServer(s grpc.ServiceRegistrar, srv DataNodeServer)
Types ¶
type AddReply ¶
type AddReply struct {
Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
// contains filtered or unexported fields
}
func (*AddReply) Descriptor
deprecated
func (*AddReply) ProtoMessage ¶
func (*AddReply) ProtoMessage()
func (*AddReply) ProtoReflect ¶
func (x *AddReply) ProtoReflect() protoreflect.Message
type AddReq ¶
type AddReq struct {
Block []byte `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"`
User *PoolUser `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
// contains filtered or unexported fields
}
func (*AddReq) Descriptor
deprecated
func (*AddReq) ProtoMessage ¶
func (*AddReq) ProtoMessage()
func (*AddReq) ProtoReflect ¶
func (x *AddReq) ProtoReflect() protoreflect.Message
type AddRequest ¶
type AddRequest struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
DataBlock []byte `protobuf:"bytes,2,opt,name=dataBlock,proto3" json:"dataBlock,omitempty"`
// contains filtered or unexported fields
}
func (*AddRequest) Descriptor
deprecated
func (*AddRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddRequest.ProtoReflect.Descriptor instead.
func (*AddRequest) GetDataBlock ¶
func (x *AddRequest) GetDataBlock() []byte
func (*AddRequest) GetKey ¶
func (x *AddRequest) GetKey() string
func (*AddRequest) ProtoMessage ¶
func (*AddRequest) ProtoMessage()
func (*AddRequest) ProtoReflect ¶
func (x *AddRequest) ProtoReflect() protoreflect.Message
func (*AddRequest) Reset ¶
func (x *AddRequest) Reset()
func (*AddRequest) String ¶
func (x *AddRequest) String() string
type AddResponse ¶
type AddResponse struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*AddResponse) Descriptor
deprecated
func (*AddResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddResponse.ProtoReflect.Descriptor instead.
func (*AddResponse) GetMessage ¶
func (x *AddResponse) GetMessage() string
func (*AddResponse) ProtoMessage ¶
func (*AddResponse) ProtoMessage()
func (*AddResponse) ProtoReflect ¶
func (x *AddResponse) ProtoReflect() protoreflect.Message
func (*AddResponse) Reset ¶
func (x *AddResponse) Reset()
func (*AddResponse) String ¶
func (x *AddResponse) String() string
type AddUserReply ¶
type AddUserReply struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*AddUserReply) Descriptor
deprecated
func (*AddUserReply) Descriptor() ([]byte, []int)
Deprecated: Use AddUserReply.ProtoReflect.Descriptor instead.
func (*AddUserReply) GetMessage ¶
func (x *AddUserReply) GetMessage() string
func (*AddUserReply) ProtoMessage ¶
func (*AddUserReply) ProtoMessage()
func (*AddUserReply) ProtoReflect ¶
func (x *AddUserReply) ProtoReflect() protoreflect.Message
func (*AddUserReply) Reset ¶
func (x *AddUserReply) Reset()
func (*AddUserReply) String ¶
func (x *AddUserReply) String() string
type AddUserReq ¶
type AddUserReq struct {
User *PoolUser `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
Policy string `protobuf:"bytes,5,opt,name=policy,proto3" json:"policy,omitempty"`
Capacity uint64 `protobuf:"varint,6,opt,name=capacity,proto3" json:"capacity,omitempty"`
// contains filtered or unexported fields
}
func (*AddUserReq) Descriptor
deprecated
func (*AddUserReq) Descriptor() ([]byte, []int)
Deprecated: Use AddUserReq.ProtoReflect.Descriptor instead.
func (*AddUserReq) GetCapacity ¶
func (x *AddUserReq) GetCapacity() uint64
func (*AddUserReq) GetPassword ¶
func (x *AddUserReq) GetPassword() string
func (*AddUserReq) GetPolicy ¶
func (x *AddUserReq) GetPolicy() string
func (*AddUserReq) GetUser ¶
func (x *AddUserReq) GetUser() *PoolUser
func (*AddUserReq) GetUsername ¶
func (x *AddUserReq) GetUsername() string
func (*AddUserReq) ProtoMessage ¶
func (*AddUserReq) ProtoMessage()
func (*AddUserReq) ProtoReflect ¶
func (x *AddUserReq) ProtoReflect() protoreflect.Message
func (*AddUserReq) Reset ¶
func (x *AddUserReq) Reset()
func (*AddUserReq) String ¶
func (x *AddUserReq) String() string
type DagPoolClient ¶
type DagPoolClient interface {
Add(ctx context.Context, in *AddReq, opts ...grpc.CallOption) (*AddReply, error)
Get(ctx context.Context, in *GetReq, opts ...grpc.CallOption) (*GetReply, error)
Remove(ctx context.Context, in *RemoveReq, opts ...grpc.CallOption) (*RemoveReply, error)
GetSize(ctx context.Context, in *GetSizeReq, opts ...grpc.CallOption) (*GetSizeReply, error)
AddUser(ctx context.Context, in *AddUserReq, opts ...grpc.CallOption) (*AddUserReply, error)
RemoveUser(ctx context.Context, in *RemoveUserReq, opts ...grpc.CallOption) (*RemoveUserReply, error)
QueryUser(ctx context.Context, in *QueryUserReq, opts ...grpc.CallOption) (*QueryUserReply, error)
UpdateUser(ctx context.Context, in *UpdateUserReq, opts ...grpc.CallOption) (*UpdateUserReply, error)
}
DagPoolClient is the client API for DagPool 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 NewDagPoolClient ¶
func NewDagPoolClient(cc grpc.ClientConnInterface) DagPoolClient
type DagPoolServer ¶
type DagPoolServer interface {
Add(context.Context, *AddReq) (*AddReply, error)
Get(context.Context, *GetReq) (*GetReply, error)
Remove(context.Context, *RemoveReq) (*RemoveReply, error)
GetSize(context.Context, *GetSizeReq) (*GetSizeReply, error)
AddUser(context.Context, *AddUserReq) (*AddUserReply, error)
RemoveUser(context.Context, *RemoveUserReq) (*RemoveUserReply, error)
QueryUser(context.Context, *QueryUserReq) (*QueryUserReply, error)
UpdateUser(context.Context, *UpdateUserReq) (*UpdateUserReply, error)
// contains filtered or unexported methods
}
DagPoolServer is the server API for DagPool service. All implementations must embed UnimplementedDagPoolServer for forward compatibility
type DataNodeClient ¶
type DataNodeClient interface {
Put(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error)
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
Size(ctx context.Context, in *SizeRequest, opts ...grpc.CallOption) (*SizeResponse, error)
}
DataNodeClient is the client API for DataNode 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 NewDataNodeClient ¶
func NewDataNodeClient(cc grpc.ClientConnInterface) DataNodeClient
type DataNodeServer ¶
type DataNodeServer interface {
Put(context.Context, *AddRequest) (*AddResponse, error)
Get(context.Context, *GetRequest) (*GetResponse, error)
Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
Size(context.Context, *SizeRequest) (*SizeResponse, error)
// contains filtered or unexported methods
}
DataNodeServer is the server API for DataNode service. All implementations must embed UnimplementedDataNodeServer for forward compatibility
type DeleteRequest ¶
type DeleteRequest struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteRequest) Descriptor
deprecated
func (*DeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRequest) GetKey ¶
func (x *DeleteRequest) GetKey() string
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) ProtoReflect ¶
func (x *DeleteRequest) ProtoReflect() protoreflect.Message
func (*DeleteRequest) Reset ¶
func (x *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (x *DeleteRequest) String() string
type DeleteResponse ¶
type DeleteResponse struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteResponse) Descriptor
deprecated
func (*DeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.
func (*DeleteResponse) GetMessage ¶
func (x *DeleteResponse) GetMessage() string
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) ProtoReflect ¶
func (x *DeleteResponse) ProtoReflect() protoreflect.Message
func (*DeleteResponse) Reset ¶
func (x *DeleteResponse) Reset()
func (*DeleteResponse) String ¶
func (x *DeleteResponse) String() string
type GetReply ¶
type GetReply struct {
Block []byte `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"`
// contains filtered or unexported fields
}
func (*GetReply) Descriptor
deprecated
func (*GetReply) ProtoMessage ¶
func (*GetReply) ProtoMessage()
func (*GetReply) ProtoReflect ¶
func (x *GetReply) ProtoReflect() protoreflect.Message
type GetReq ¶
type GetReq struct {
Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
User *PoolUser `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
// contains filtered or unexported fields
}
func (*GetReq) Descriptor
deprecated
func (*GetReq) ProtoMessage ¶
func (*GetReq) ProtoMessage()
func (*GetReq) ProtoReflect ¶
func (x *GetReq) ProtoReflect() protoreflect.Message
type GetRequest ¶
type GetRequest struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
// contains filtered or unexported fields
}
func (*GetRequest) Descriptor
deprecated
func (*GetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.
func (*GetRequest) GetKey ¶
func (x *GetRequest) GetKey() string
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) ProtoReflect ¶
func (x *GetRequest) ProtoReflect() protoreflect.Message
func (*GetRequest) Reset ¶
func (x *GetRequest) Reset()
func (*GetRequest) String ¶
func (x *GetRequest) String() string
type GetResponse ¶
type GetResponse struct {
DataBlock []byte `protobuf:"bytes,1,opt,name=dataBlock,proto3" json:"dataBlock,omitempty"`
// contains filtered or unexported fields
}
func (*GetResponse) Descriptor
deprecated
func (*GetResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.
func (*GetResponse) GetDataBlock ¶
func (x *GetResponse) GetDataBlock() []byte
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) ProtoReflect ¶
func (x *GetResponse) ProtoReflect() protoreflect.Message
func (*GetResponse) Reset ¶
func (x *GetResponse) Reset()
func (*GetResponse) String ¶
func (x *GetResponse) String() string
type GetSizeReply ¶
type GetSizeReply struct {
Size int32 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
// contains filtered or unexported fields
}
func (*GetSizeReply) Descriptor
deprecated
func (*GetSizeReply) Descriptor() ([]byte, []int)
Deprecated: Use GetSizeReply.ProtoReflect.Descriptor instead.
func (*GetSizeReply) GetSize ¶
func (x *GetSizeReply) GetSize() int32
func (*GetSizeReply) ProtoMessage ¶
func (*GetSizeReply) ProtoMessage()
func (*GetSizeReply) ProtoReflect ¶
func (x *GetSizeReply) ProtoReflect() protoreflect.Message
func (*GetSizeReply) Reset ¶
func (x *GetSizeReply) Reset()
func (*GetSizeReply) String ¶
func (x *GetSizeReply) String() string
type GetSizeReq ¶
type GetSizeReq struct {
Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
User *PoolUser `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
// contains filtered or unexported fields
}
func (*GetSizeReq) Descriptor
deprecated
func (*GetSizeReq) Descriptor() ([]byte, []int)
Deprecated: Use GetSizeReq.ProtoReflect.Descriptor instead.
func (*GetSizeReq) GetCid ¶
func (x *GetSizeReq) GetCid() string
func (*GetSizeReq) GetUser ¶
func (x *GetSizeReq) GetUser() *PoolUser
func (*GetSizeReq) ProtoMessage ¶
func (*GetSizeReq) ProtoMessage()
func (*GetSizeReq) ProtoReflect ¶
func (x *GetSizeReq) ProtoReflect() protoreflect.Message
func (*GetSizeReq) Reset ¶
func (x *GetSizeReq) Reset()
func (*GetSizeReq) String ¶
func (x *GetSizeReq) String() string
type PoolUser ¶
type PoolUser struct {
User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
// contains filtered or unexported fields
}
func (*PoolUser) Descriptor
deprecated
func (*PoolUser) GetPassword ¶
func (*PoolUser) ProtoMessage ¶
func (*PoolUser) ProtoMessage()
func (*PoolUser) ProtoReflect ¶
func (x *PoolUser) ProtoReflect() protoreflect.Message
type QueryUserReply ¶
type QueryUserReply struct {
Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
Policy string `protobuf:"bytes,3,opt,name=policy,proto3" json:"policy,omitempty"`
Capacity uint64 `protobuf:"varint,4,opt,name=capacity,proto3" json:"capacity,omitempty"`
// contains filtered or unexported fields
}
func (*QueryUserReply) Descriptor
deprecated
func (*QueryUserReply) Descriptor() ([]byte, []int)
Deprecated: Use QueryUserReply.ProtoReflect.Descriptor instead.
func (*QueryUserReply) GetCapacity ¶
func (x *QueryUserReply) GetCapacity() uint64
func (*QueryUserReply) GetPolicy ¶
func (x *QueryUserReply) GetPolicy() string
func (*QueryUserReply) GetUsername ¶
func (x *QueryUserReply) GetUsername() string
func (*QueryUserReply) ProtoMessage ¶
func (*QueryUserReply) ProtoMessage()
func (*QueryUserReply) ProtoReflect ¶
func (x *QueryUserReply) ProtoReflect() protoreflect.Message
func (*QueryUserReply) Reset ¶
func (x *QueryUserReply) Reset()
func (*QueryUserReply) String ¶
func (x *QueryUserReply) String() string
type QueryUserReq ¶
type QueryUserReq struct {
User *PoolUser `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
// contains filtered or unexported fields
}
func (*QueryUserReq) Descriptor
deprecated
func (*QueryUserReq) Descriptor() ([]byte, []int)
Deprecated: Use QueryUserReq.ProtoReflect.Descriptor instead.
func (*QueryUserReq) GetUser ¶
func (x *QueryUserReq) GetUser() *PoolUser
func (*QueryUserReq) GetUsername ¶
func (x *QueryUserReq) GetUsername() string
func (*QueryUserReq) ProtoMessage ¶
func (*QueryUserReq) ProtoMessage()
func (*QueryUserReq) ProtoReflect ¶
func (x *QueryUserReq) ProtoReflect() protoreflect.Message
func (*QueryUserReq) Reset ¶
func (x *QueryUserReq) Reset()
func (*QueryUserReq) String ¶
func (x *QueryUserReq) String() string
type RemoveReply ¶
type RemoveReply struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*RemoveReply) Descriptor
deprecated
func (*RemoveReply) Descriptor() ([]byte, []int)
Deprecated: Use RemoveReply.ProtoReflect.Descriptor instead.
func (*RemoveReply) GetMessage ¶
func (x *RemoveReply) GetMessage() string
func (*RemoveReply) ProtoMessage ¶
func (*RemoveReply) ProtoMessage()
func (*RemoveReply) ProtoReflect ¶
func (x *RemoveReply) ProtoReflect() protoreflect.Message
func (*RemoveReply) Reset ¶
func (x *RemoveReply) Reset()
func (*RemoveReply) String ¶
func (x *RemoveReply) String() string
type RemoveReq ¶
type RemoveReq struct {
Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
User *PoolUser `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
// contains filtered or unexported fields
}
func (*RemoveReq) Descriptor
deprecated
func (*RemoveReq) ProtoMessage ¶
func (*RemoveReq) ProtoMessage()
func (*RemoveReq) ProtoReflect ¶
func (x *RemoveReq) ProtoReflect() protoreflect.Message
type RemoveUserReply ¶
type RemoveUserReply struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*RemoveUserReply) Descriptor
deprecated
func (*RemoveUserReply) Descriptor() ([]byte, []int)
Deprecated: Use RemoveUserReply.ProtoReflect.Descriptor instead.
func (*RemoveUserReply) GetMessage ¶
func (x *RemoveUserReply) GetMessage() string
func (*RemoveUserReply) ProtoMessage ¶
func (*RemoveUserReply) ProtoMessage()
func (*RemoveUserReply) ProtoReflect ¶
func (x *RemoveUserReply) ProtoReflect() protoreflect.Message
func (*RemoveUserReply) Reset ¶
func (x *RemoveUserReply) Reset()
func (*RemoveUserReply) String ¶
func (x *RemoveUserReply) String() string
type RemoveUserReq ¶
type RemoveUserReq struct {
User *PoolUser `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
// contains filtered or unexported fields
}
func (*RemoveUserReq) Descriptor
deprecated
func (*RemoveUserReq) Descriptor() ([]byte, []int)
Deprecated: Use RemoveUserReq.ProtoReflect.Descriptor instead.
func (*RemoveUserReq) GetUser ¶
func (x *RemoveUserReq) GetUser() *PoolUser
func (*RemoveUserReq) GetUsername ¶
func (x *RemoveUserReq) GetUsername() string
func (*RemoveUserReq) ProtoMessage ¶
func (*RemoveUserReq) ProtoMessage()
func (*RemoveUserReq) ProtoReflect ¶
func (x *RemoveUserReq) ProtoReflect() protoreflect.Message
func (*RemoveUserReq) Reset ¶
func (x *RemoveUserReq) Reset()
func (*RemoveUserReq) String ¶
func (x *RemoveUserReq) String() string
type SizeRequest ¶
type SizeRequest struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
// contains filtered or unexported fields
}
func (*SizeRequest) Descriptor
deprecated
func (*SizeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SizeRequest.ProtoReflect.Descriptor instead.
func (*SizeRequest) GetKey ¶
func (x *SizeRequest) GetKey() string
func (*SizeRequest) ProtoMessage ¶
func (*SizeRequest) ProtoMessage()
func (*SizeRequest) ProtoReflect ¶
func (x *SizeRequest) ProtoReflect() protoreflect.Message
func (*SizeRequest) Reset ¶
func (x *SizeRequest) Reset()
func (*SizeRequest) String ¶
func (x *SizeRequest) String() string
type SizeResponse ¶
type SizeResponse struct {
Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
// contains filtered or unexported fields
}
func (*SizeResponse) Descriptor
deprecated
func (*SizeResponse) Descriptor() ([]byte, []int)
Deprecated: Use SizeResponse.ProtoReflect.Descriptor instead.
func (*SizeResponse) GetSize ¶
func (x *SizeResponse) GetSize() int64
func (*SizeResponse) ProtoMessage ¶
func (*SizeResponse) ProtoMessage()
func (*SizeResponse) ProtoReflect ¶
func (x *SizeResponse) ProtoReflect() protoreflect.Message
func (*SizeResponse) Reset ¶
func (x *SizeResponse) Reset()
func (*SizeResponse) String ¶
func (x *SizeResponse) String() string
type UnimplementedDagPoolServer ¶
type UnimplementedDagPoolServer struct {
}
UnimplementedDagPoolServer must be embedded to have forward compatible implementations.
func (UnimplementedDagPoolServer) AddUser ¶
func (UnimplementedDagPoolServer) AddUser(context.Context, *AddUserReq) (*AddUserReply, error)
func (UnimplementedDagPoolServer) GetSize ¶
func (UnimplementedDagPoolServer) GetSize(context.Context, *GetSizeReq) (*GetSizeReply, error)
func (UnimplementedDagPoolServer) QueryUser ¶
func (UnimplementedDagPoolServer) QueryUser(context.Context, *QueryUserReq) (*QueryUserReply, error)
func (UnimplementedDagPoolServer) Remove ¶
func (UnimplementedDagPoolServer) Remove(context.Context, *RemoveReq) (*RemoveReply, error)
func (UnimplementedDagPoolServer) RemoveUser ¶
func (UnimplementedDagPoolServer) RemoveUser(context.Context, *RemoveUserReq) (*RemoveUserReply, error)
func (UnimplementedDagPoolServer) UpdateUser ¶
func (UnimplementedDagPoolServer) UpdateUser(context.Context, *UpdateUserReq) (*UpdateUserReply, error)
type UnimplementedDataNodeServer ¶
type UnimplementedDataNodeServer struct {
}
UnimplementedDataNodeServer must be embedded to have forward compatible implementations.
func (UnimplementedDataNodeServer) Delete ¶
func (UnimplementedDataNodeServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
func (UnimplementedDataNodeServer) Get ¶
func (UnimplementedDataNodeServer) Get(context.Context, *GetRequest) (*GetResponse, error)
func (UnimplementedDataNodeServer) Put ¶
func (UnimplementedDataNodeServer) Put(context.Context, *AddRequest) (*AddResponse, error)
func (UnimplementedDataNodeServer) Size ¶
func (UnimplementedDataNodeServer) Size(context.Context, *SizeRequest) (*SizeResponse, error)
type UnsafeDagPoolServer ¶
type UnsafeDagPoolServer interface {
// contains filtered or unexported methods
}
UnsafeDagPoolServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DagPoolServer will result in compilation errors.
type UnsafeDataNodeServer ¶
type UnsafeDataNodeServer interface {
// contains filtered or unexported methods
}
UnsafeDataNodeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DataNodeServer will result in compilation errors.
type UpdateUserReply ¶
type UpdateUserReply struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateUserReply) Descriptor
deprecated
func (*UpdateUserReply) Descriptor() ([]byte, []int)
Deprecated: Use UpdateUserReply.ProtoReflect.Descriptor instead.
func (*UpdateUserReply) GetMessage ¶
func (x *UpdateUserReply) GetMessage() string
func (*UpdateUserReply) ProtoMessage ¶
func (*UpdateUserReply) ProtoMessage()
func (*UpdateUserReply) ProtoReflect ¶
func (x *UpdateUserReply) ProtoReflect() protoreflect.Message
func (*UpdateUserReply) Reset ¶
func (x *UpdateUserReply) Reset()
func (*UpdateUserReply) String ¶
func (x *UpdateUserReply) String() string
type UpdateUserReq ¶
type UpdateUserReq struct {
User *PoolUser `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
NewPassword string `protobuf:"bytes,4,opt,name=newPassword,proto3" json:"newPassword,omitempty"`
NewPolicy string `protobuf:"bytes,5,opt,name=newPolicy,proto3" json:"newPolicy,omitempty"`
NewCapacity uint64 `protobuf:"varint,6,opt,name=newCapacity,proto3" json:"newCapacity,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateUserReq) Descriptor
deprecated
func (*UpdateUserReq) Descriptor() ([]byte, []int)
Deprecated: Use UpdateUserReq.ProtoReflect.Descriptor instead.
func (*UpdateUserReq) GetNewCapacity ¶
func (x *UpdateUserReq) GetNewCapacity() uint64
func (*UpdateUserReq) GetNewPassword ¶
func (x *UpdateUserReq) GetNewPassword() string
func (*UpdateUserReq) GetNewPolicy ¶
func (x *UpdateUserReq) GetNewPolicy() string
func (*UpdateUserReq) GetUser ¶
func (x *UpdateUserReq) GetUser() *PoolUser
func (*UpdateUserReq) GetUsername ¶
func (x *UpdateUserReq) GetUsername() string
func (*UpdateUserReq) ProtoMessage ¶
func (*UpdateUserReq) ProtoMessage()
func (*UpdateUserReq) ProtoReflect ¶
func (x *UpdateUserReq) ProtoReflect() protoreflect.Message
func (*UpdateUserReq) Reset ¶
func (x *UpdateUserReq) Reset()
func (*UpdateUserReq) String ¶
func (x *UpdateUserReq) String() string