proto

package
v0.0.2 Latest Latest
Warning

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

Go to latest
Published: Sep 1, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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)

View Source
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)

View Source
var File_dagpool_proto protoreflect.FileDescriptor
View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use AddReply.ProtoReflect.Descriptor instead.

func (*AddReply) GetCid

func (x *AddReply) GetCid() string

func (*AddReply) ProtoMessage

func (*AddReply) ProtoMessage()

func (*AddReply) ProtoReflect

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

func (*AddReply) Reset

func (x *AddReply) Reset()

func (*AddReply) String

func (x *AddReply) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use AddReq.ProtoReflect.Descriptor instead.

func (*AddReq) GetBlock

func (x *AddReq) GetBlock() []byte

func (*AddReq) GetUser

func (x *AddReq) GetUser() *PoolUser

func (*AddReq) ProtoMessage

func (*AddReq) ProtoMessage()

func (*AddReq) ProtoReflect

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

func (*AddReq) Reset

func (x *AddReq) Reset()

func (*AddReq) String

func (x *AddReq) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use GetReply.ProtoReflect.Descriptor instead.

func (*GetReply) GetBlock

func (x *GetReply) GetBlock() []byte

func (*GetReply) ProtoMessage

func (*GetReply) ProtoMessage()

func (*GetReply) ProtoReflect

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

func (*GetReply) Reset

func (x *GetReply) Reset()

func (*GetReply) String

func (x *GetReply) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use GetReq.ProtoReflect.Descriptor instead.

func (*GetReq) GetCid

func (x *GetReq) GetCid() string

func (*GetReq) GetUser

func (x *GetReq) GetUser() *PoolUser

func (*GetReq) ProtoMessage

func (*GetReq) ProtoMessage()

func (*GetReq) ProtoReflect

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

func (*GetReq) Reset

func (x *GetReq) Reset()

func (*GetReq) String

func (x *GetReq) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use PoolUser.ProtoReflect.Descriptor instead.

func (*PoolUser) GetPassword

func (x *PoolUser) GetPassword() string

func (*PoolUser) GetUser

func (x *PoolUser) GetUser() string

func (*PoolUser) ProtoMessage

func (*PoolUser) ProtoMessage()

func (*PoolUser) ProtoReflect

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

func (*PoolUser) Reset

func (x *PoolUser) Reset()

func (*PoolUser) String

func (x *PoolUser) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use RemoveReq.ProtoReflect.Descriptor instead.

func (*RemoveReq) GetCid

func (x *RemoveReq) GetCid() string

func (*RemoveReq) GetUser

func (x *RemoveReq) GetUser() *PoolUser

func (*RemoveReq) ProtoMessage

func (*RemoveReq) ProtoMessage()

func (*RemoveReq) ProtoReflect

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

func (*RemoveReq) Reset

func (x *RemoveReq) Reset()

func (*RemoveReq) String

func (x *RemoveReq) String() string

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) Add

func (UnimplementedDagPoolServer) AddUser

func (UnimplementedDagPoolServer) Get

func (UnimplementedDagPoolServer) GetSize

func (UnimplementedDagPoolServer) QueryUser

func (UnimplementedDagPoolServer) Remove

func (UnimplementedDagPoolServer) RemoveUser

func (UnimplementedDagPoolServer) UpdateUser

type UnimplementedDataNodeServer

type UnimplementedDataNodeServer struct {
}

UnimplementedDataNodeServer must be embedded to have forward compatible implementations.

func (UnimplementedDataNodeServer) Delete

func (UnimplementedDataNodeServer) Get

func (UnimplementedDataNodeServer) Put

func (UnimplementedDataNodeServer) Size

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

Jump to

Keyboard shortcuts

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