proto

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Feb 1, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DagPoolCluster_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.DagPoolCluster",
	HandlerType: (*DagPoolClusterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddDagNode",
			Handler:    _DagPoolCluster_AddDagNode_Handler,
		},
		{
			MethodName: "GetDagNode",
			Handler:    _DagPoolCluster_GetDagNode_Handler,
		},
		{
			MethodName: "RemoveDagNode",
			Handler:    _DagPoolCluster_RemoveDagNode_Handler,
		},
		{
			MethodName: "MigrateSlots",
			Handler:    _DagPoolCluster_MigrateSlots_Handler,
		},
		{
			MethodName: "BalanceSlots",
			Handler:    _DagPoolCluster_BalanceSlots_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _DagPoolCluster_Status_Handler,
		},
		{
			MethodName: "RepairDataNode",
			Handler:    _DagPoolCluster_RepairDataNode_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dagpool.proto",
}

DagPoolCluster_ServiceDesc is the grpc.ServiceDesc for DagPoolCluster 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 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: "GetMeta",
			Handler:    _DataNode_GetMeta_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _DataNode_Delete_Handler,
		},
		{
			MethodName: "Size",
			Handler:    _DataNode_Size_Handler,
		},
		{
			MethodName: "DeleteMany",
			Handler:    _DataNode_DeleteMany_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "AllKeysChan",
			Handler:       _DataNode_AllKeysChan_Handler,
			ServerStreams: true,
		},
	},
	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 RegisterDagPoolClusterServer added in v0.4.0 

func RegisterDagPoolClusterServer(s grpc.ServiceRegistrar, srv DagPoolClusterServer)

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"`
	Pin   bool      `protobuf:"varint,3,opt,name=pin,proto3" json:"pin,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) GetPin added in v0.2.0 

func (x *AddReq) GetPin() bool

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"`
	Meta []byte `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*AddRequest) Descriptor deprecated 

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

Deprecated: Use AddRequest.ProtoReflect.Descriptor instead.

func (*AddRequest) GetData added in v0.2.0 

func (x *AddRequest) GetData() []byte

func (*AddRequest) GetKey 

func (x *AddRequest) GetKey() string

func (*AddRequest) GetMeta added in v0.2.0 

func (x *AddRequest) GetMeta() []byte

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 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 AllKeysChanResponse added in v0.2.0 

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

func (*AllKeysChanResponse) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use AllKeysChanResponse.ProtoReflect.Descriptor instead.

func (*AllKeysChanResponse) GetKey added in v0.2.0 

func (x *AllKeysChanResponse) GetKey() string

func (*AllKeysChanResponse) ProtoMessage added in v0.2.0 

func (*AllKeysChanResponse) ProtoMessage()

func (*AllKeysChanResponse) ProtoReflect added in v0.2.0 

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

func (*AllKeysChanResponse) Reset added in v0.2.0 

func (x *AllKeysChanResponse) Reset()

func (*AllKeysChanResponse) String added in v0.2.0 

func (x *AllKeysChanResponse) String() string

type DagNodeInfo added in v0.4.0 

type DagNodeInfo struct {
	Name         string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Nodes        []*DataNodeInfo `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	DataBlocks   int32           `protobuf:"varint,3,opt,name=dataBlocks,proto3" json:"dataBlocks,omitempty"`
	ParityBlocks int32           `protobuf:"varint,4,opt,name=parityBlocks,proto3" json:"parityBlocks,omitempty"`
	// contains filtered or unexported fields
}

func (*DagNodeInfo) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use DagNodeInfo.ProtoReflect.Descriptor instead.

func (*DagNodeInfo) GetDataBlocks added in v0.4.0 

func (x *DagNodeInfo) GetDataBlocks() int32

func (*DagNodeInfo) GetName added in v0.4.0 

func (x *DagNodeInfo) GetName() string

func (*DagNodeInfo) GetNodes added in v0.4.0 

func (x *DagNodeInfo) GetNodes() []*DataNodeInfo

func (*DagNodeInfo) GetParityBlocks added in v0.4.0 

func (x *DagNodeInfo) GetParityBlocks() int32

func (*DagNodeInfo) ProtoMessage added in v0.4.0 

func (*DagNodeInfo) ProtoMessage()

func (*DagNodeInfo) ProtoReflect added in v0.4.0 

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

func (*DagNodeInfo) Reset added in v0.4.0 

func (x *DagNodeInfo) Reset()

func (*DagNodeInfo) String added in v0.4.0 

func (x *DagNodeInfo) String() string

type DagNodeStatus added in v0.4.0 

type DagNodeStatus struct {
	Node  *DagNodeInfo `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Pairs []*SlotPair  `protobuf:"bytes,2,rep,name=pairs,proto3" json:"pairs,omitempty"`
	// contains filtered or unexported fields
}

func (*DagNodeStatus) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use DagNodeStatus.ProtoReflect.Descriptor instead.

func (*DagNodeStatus) GetNode added in v0.4.0 

func (x *DagNodeStatus) GetNode() *DagNodeInfo

func (*DagNodeStatus) GetPairs added in v0.4.0 

func (x *DagNodeStatus) GetPairs() []*SlotPair

func (*DagNodeStatus) ProtoMessage added in v0.4.0 

func (*DagNodeStatus) ProtoMessage()

func (*DagNodeStatus) ProtoReflect added in v0.4.0 

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

func (*DagNodeStatus) Reset added in v0.4.0 

func (x *DagNodeStatus) Reset()

func (*DagNodeStatus) String added in v0.4.0 

func (x *DagNodeStatus) 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 DagPoolClusterClient added in v0.4.0 

type DagPoolClusterClient interface {
	AddDagNode(ctx context.Context, in *DagNodeInfo, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetDagNode(ctx context.Context, in *GetDagNodeReq, opts ...grpc.CallOption) (*DagNodeInfo, error)
	RemoveDagNode(ctx context.Context, in *RemoveDagNodeReq, opts ...grpc.CallOption) (*DagNodeInfo, error)
	MigrateSlots(ctx context.Context, in *MigrateSlotsReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	BalanceSlots(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Status(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*StatusReply, error)
	RepairDataNode(ctx context.Context, in *RepairDataNodeReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DagPoolClusterClient is the client API for DagPoolCluster 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 NewDagPoolClusterClient added in v0.4.0 

func NewDagPoolClusterClient(cc grpc.ClientConnInterface) DagPoolClusterClient

type DagPoolClusterServer added in v0.4.0 

type DagPoolClusterServer interface {
	AddDagNode(context.Context, *DagNodeInfo) (*emptypb.Empty, error)
	GetDagNode(context.Context, *GetDagNodeReq) (*DagNodeInfo, error)
	RemoveDagNode(context.Context, *RemoveDagNodeReq) (*DagNodeInfo, error)
	MigrateSlots(context.Context, *MigrateSlotsReq) (*emptypb.Empty, error)
	BalanceSlots(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	Status(context.Context, *emptypb.Empty) (*StatusReply, error)
	RepairDataNode(context.Context, *RepairDataNodeReq) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

DagPoolClusterServer is the server API for DagPoolCluster service. All implementations must embed UnimplementedDagPoolClusterServer for forward compatibility

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) (*emptypb.Empty, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	GetMeta(ctx context.Context, in *GetMetaRequest, opts ...grpc.CallOption) (*GetMetaResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Size(ctx context.Context, in *SizeRequest, opts ...grpc.CallOption) (*SizeResponse, error)
	DeleteMany(ctx context.Context, in *DeleteManyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	AllKeysChan(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (DataNode_AllKeysChanClient, 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 DataNodeInfo added in v0.4.0 

type DataNodeInfo struct {
	RpcAddress string `protobuf:"bytes,1,opt,name=rpcAddress,proto3" json:"rpcAddress,omitempty"`
	State      *bool  `protobuf:"varint,2,opt,name=state,proto3,oneof" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*DataNodeInfo) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use DataNodeInfo.ProtoReflect.Descriptor instead.

func (*DataNodeInfo) GetRpcAddress added in v0.4.0 

func (x *DataNodeInfo) GetRpcAddress() string

func (*DataNodeInfo) GetState added in v0.4.0 

func (x *DataNodeInfo) GetState() bool

func (*DataNodeInfo) ProtoMessage added in v0.4.0 

func (*DataNodeInfo) ProtoMessage()

func (*DataNodeInfo) ProtoReflect added in v0.4.0 

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

func (*DataNodeInfo) Reset added in v0.4.0 

func (x *DataNodeInfo) Reset()

func (*DataNodeInfo) String added in v0.4.0 

func (x *DataNodeInfo) String() string

type DataNodeServer 

type DataNodeServer interface {
	Put(context.Context, *AddRequest) (*emptypb.Empty, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	GetMeta(context.Context, *GetMetaRequest) (*GetMetaResponse, error)
	Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)
	Size(context.Context, *SizeRequest) (*SizeResponse, error)
	DeleteMany(context.Context, *DeleteManyRequest) (*emptypb.Empty, error)
	AllKeysChan(*emptypb.Empty, DataNode_AllKeysChanServer) error
	// contains filtered or unexported methods
}

DataNodeServer is the server API for DataNode service. All implementations must embed UnimplementedDataNodeServer for forward compatibility

type DataNode_AllKeysChanClient added in v0.2.0 

type DataNode_AllKeysChanClient interface {
	Recv() (*AllKeysChanResponse, error)
	grpc.ClientStream
}

type DataNode_AllKeysChanServer added in v0.2.0 

type DataNode_AllKeysChanServer interface {
	Send(*AllKeysChanResponse) error
	grpc.ServerStream
}

type DeleteManyRequest added in v0.2.0 

type DeleteManyRequest struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteManyRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use DeleteManyRequest.ProtoReflect.Descriptor instead.

func (*DeleteManyRequest) GetKeys added in v0.2.0 

func (x *DeleteManyRequest) GetKeys() []string

func (*DeleteManyRequest) ProtoMessage added in v0.2.0 

func (*DeleteManyRequest) ProtoMessage()

func (*DeleteManyRequest) ProtoReflect added in v0.2.0 

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

func (*DeleteManyRequest) Reset added in v0.2.0 

func (x *DeleteManyRequest) Reset()

func (*DeleteManyRequest) String added in v0.2.0 

func (x *DeleteManyRequest) String() string

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 GetDagNodeReq added in v0.4.0 

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

func (*GetDagNodeReq) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use GetDagNodeReq.ProtoReflect.Descriptor instead.

func (*GetDagNodeReq) GetName added in v0.4.0 

func (x *GetDagNodeReq) GetName() string

func (*GetDagNodeReq) ProtoMessage added in v0.4.0 

func (*GetDagNodeReq) ProtoMessage()

func (*GetDagNodeReq) ProtoReflect added in v0.4.0 

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

func (*GetDagNodeReq) Reset added in v0.4.0 

func (x *GetDagNodeReq) Reset()

func (*GetDagNodeReq) String added in v0.4.0 

func (x *GetDagNodeReq) String() string

type GetMetaRequest added in v0.2.0 

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

func (*GetMetaRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use GetMetaRequest.ProtoReflect.Descriptor instead.

func (*GetMetaRequest) GetKey added in v0.2.0 

func (x *GetMetaRequest) GetKey() string

func (*GetMetaRequest) ProtoMessage added in v0.2.0 

func (*GetMetaRequest) ProtoMessage()

func (*GetMetaRequest) ProtoReflect added in v0.2.0 

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

func (*GetMetaRequest) Reset added in v0.2.0 

func (x *GetMetaRequest) Reset()

func (*GetMetaRequest) String added in v0.2.0 

func (x *GetMetaRequest) String() string

type GetMetaResponse added in v0.2.0 

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

func (*GetMetaResponse) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use GetMetaResponse.ProtoReflect.Descriptor instead.

func (*GetMetaResponse) GetMeta added in v0.2.0 

func (x *GetMetaResponse) GetMeta() []byte

func (*GetMetaResponse) ProtoMessage added in v0.2.0 

func (*GetMetaResponse) ProtoMessage()

func (*GetMetaResponse) ProtoReflect added in v0.2.0 

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

func (*GetMetaResponse) Reset added in v0.2.0 

func (x *GetMetaResponse) Reset()

func (*GetMetaResponse) String added in v0.2.0 

func (x *GetMetaResponse) 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 {
	Meta []byte `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetData added in v0.2.0 

func (x *GetResponse) GetData() []byte

func (*GetResponse) GetMeta added in v0.2.0 

func (x *GetResponse) GetMeta() []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 MigrateSlotsReq added in v0.4.0 

type MigrateSlotsReq struct {
	FromDagNodeName string      `protobuf:"bytes,1,opt,name=fromDagNodeName,proto3" json:"fromDagNodeName,omitempty"`
	ToDagNodeName   string      `protobuf:"bytes,2,opt,name=toDagNodeName,proto3" json:"toDagNodeName,omitempty"`
	Pairs           []*SlotPair `protobuf:"bytes,3,rep,name=pairs,proto3" json:"pairs,omitempty"`
	// contains filtered or unexported fields
}

func (*MigrateSlotsReq) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use MigrateSlotsReq.ProtoReflect.Descriptor instead.

func (*MigrateSlotsReq) GetFromDagNodeName added in v0.4.0 

func (x *MigrateSlotsReq) GetFromDagNodeName() string

func (*MigrateSlotsReq) GetPairs added in v0.4.0 

func (x *MigrateSlotsReq) GetPairs() []*SlotPair

func (*MigrateSlotsReq) GetToDagNodeName added in v0.4.0 

func (x *MigrateSlotsReq) GetToDagNodeName() string

func (*MigrateSlotsReq) ProtoMessage added in v0.4.0 

func (*MigrateSlotsReq) ProtoMessage()

func (*MigrateSlotsReq) ProtoReflect added in v0.4.0 

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

func (*MigrateSlotsReq) Reset added in v0.4.0 

func (x *MigrateSlotsReq) Reset()

func (*MigrateSlotsReq) String added in v0.4.0 

func (x *MigrateSlotsReq) 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 RemoveDagNodeReq added in v0.4.0 

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

func (*RemoveDagNodeReq) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use RemoveDagNodeReq.ProtoReflect.Descriptor instead.

func (*RemoveDagNodeReq) GetName added in v0.4.0 

func (x *RemoveDagNodeReq) GetName() string

func (*RemoveDagNodeReq) ProtoMessage added in v0.4.0 

func (*RemoveDagNodeReq) ProtoMessage()

func (*RemoveDagNodeReq) ProtoReflect added in v0.4.0 

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

func (*RemoveDagNodeReq) Reset added in v0.4.0 

func (x *RemoveDagNodeReq) Reset()

func (*RemoveDagNodeReq) String added in v0.4.0 

func (x *RemoveDagNodeReq) 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"`
	Unpin bool      `protobuf:"varint,3,opt,name=unpin,proto3" json:"unpin,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) GetUnpin added in v0.2.0 

func (x *RemoveReq) GetUnpin() bool

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 RepairDataNodeReq added in v0.4.0 

type RepairDataNodeReq struct {
	DagNodeName     string `protobuf:"bytes,1,opt,name=dagNodeName,proto3" json:"dagNodeName,omitempty"`
	FromNodeIndex   int32  `protobuf:"varint,2,opt,name=fromNodeIndex,proto3" json:"fromNodeIndex,omitempty"`
	RepairNodeIndex int32  `protobuf:"varint,3,opt,name=repairNodeIndex,proto3" json:"repairNodeIndex,omitempty"`
	// contains filtered or unexported fields
}

func (*RepairDataNodeReq) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use RepairDataNodeReq.ProtoReflect.Descriptor instead.

func (*RepairDataNodeReq) GetDagNodeName added in v0.4.0 

func (x *RepairDataNodeReq) GetDagNodeName() string

func (*RepairDataNodeReq) GetFromNodeIndex added in v0.4.0 

func (x *RepairDataNodeReq) GetFromNodeIndex() int32

func (*RepairDataNodeReq) GetRepairNodeIndex added in v0.4.0 

func (x *RepairDataNodeReq) GetRepairNodeIndex() int32

func (*RepairDataNodeReq) ProtoMessage added in v0.4.0 

func (*RepairDataNodeReq) ProtoMessage()

func (*RepairDataNodeReq) ProtoReflect added in v0.4.0 

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

func (*RepairDataNodeReq) Reset added in v0.4.0 

func (x *RepairDataNodeReq) Reset()

func (*RepairDataNodeReq) String added in v0.4.0 

func (x *RepairDataNodeReq) 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 SlotPair added in v0.4.0 

type SlotPair struct {
	Start uint32 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	End   uint32 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*SlotPair) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use SlotPair.ProtoReflect.Descriptor instead.

func (*SlotPair) GetEnd added in v0.4.0 

func (x *SlotPair) GetEnd() uint32

func (*SlotPair) GetStart added in v0.4.0 

func (x *SlotPair) GetStart() uint32

func (*SlotPair) ProtoMessage added in v0.4.0 

func (*SlotPair) ProtoMessage()

func (*SlotPair) ProtoReflect added in v0.4.0 

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

func (*SlotPair) Reset added in v0.4.0 

func (x *SlotPair) Reset()

func (*SlotPair) String added in v0.4.0 

func (x *SlotPair) String() string

type StatusReply added in v0.4.0 

type StatusReply struct {
	State    string           `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	Statuses []*DagNodeStatus `protobuf:"bytes,2,rep,name=statuses,proto3" json:"statuses,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusReply) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use StatusReply.ProtoReflect.Descriptor instead.

func (*StatusReply) GetState added in v0.4.0 

func (x *StatusReply) GetState() string

func (*StatusReply) GetStatuses added in v0.4.0 

func (x *StatusReply) GetStatuses() []*DagNodeStatus

func (*StatusReply) ProtoMessage added in v0.4.0 

func (*StatusReply) ProtoMessage()

func (*StatusReply) ProtoReflect added in v0.4.0 

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

func (*StatusReply) Reset added in v0.4.0 

func (x *StatusReply) Reset()

func (*StatusReply) String added in v0.4.0 

func (x *StatusReply) String() string

type UnimplementedDagPoolClusterServer added in v0.4.0 

type UnimplementedDagPoolClusterServer struct {
}

UnimplementedDagPoolClusterServer must be embedded to have forward compatible implementations.

func (UnimplementedDagPoolClusterServer) AddDagNode added in v0.4.0 

func (UnimplementedDagPoolClusterServer) AddDagNode(context.Context, *DagNodeInfo) (*emptypb.Empty, error)

func (UnimplementedDagPoolClusterServer) BalanceSlots added in v0.4.0 

func (UnimplementedDagPoolClusterServer) BalanceSlots(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedDagPoolClusterServer) GetDagNode added in v0.4.0 

func (UnimplementedDagPoolClusterServer) GetDagNode(context.Context, *GetDagNodeReq) (*DagNodeInfo, error)

func (UnimplementedDagPoolClusterServer) MigrateSlots added in v0.4.0 

func (UnimplementedDagPoolClusterServer) MigrateSlots(context.Context, *MigrateSlotsReq) (*emptypb.Empty, error)

func (UnimplementedDagPoolClusterServer) RemoveDagNode added in v0.4.0 

func (UnimplementedDagPoolClusterServer) RemoveDagNode(context.Context, *RemoveDagNodeReq) (*DagNodeInfo, error)

func (UnimplementedDagPoolClusterServer) RepairDataNode added in v0.4.0 

func (UnimplementedDagPoolClusterServer) RepairDataNode(context.Context, *RepairDataNodeReq) (*emptypb.Empty, error)

func (UnimplementedDagPoolClusterServer) Status added in v0.4.0 

func (UnimplementedDagPoolClusterServer) Status(context.Context, *emptypb.Empty) (*StatusReply, error)

type UnimplementedDagPoolServer 

type UnimplementedDagPoolServer struct {
}

UnimplementedDagPoolServer must be embedded to have forward compatible implementations.

func (UnimplementedDagPoolServer) Add 

func (UnimplementedDagPoolServer) Add(context.Context, *AddReq) (*AddReply, error)

func (UnimplementedDagPoolServer) AddUser 

func (UnimplementedDagPoolServer) AddUser(context.Context, *AddUserReq) (*AddUserReply, error)

func (UnimplementedDagPoolServer) Get 

func (UnimplementedDagPoolServer) Get(context.Context, *GetReq) (*GetReply, 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) AllKeysChan added in v0.2.0 

func (UnimplementedDataNodeServer) AllKeysChan(*emptypb.Empty, DataNode_AllKeysChanServer) error

func (UnimplementedDataNodeServer) Delete 

func (UnimplementedDataNodeServer) Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)

func (UnimplementedDataNodeServer) DeleteMany added in v0.2.0 

func (UnimplementedDataNodeServer) DeleteMany(context.Context, *DeleteManyRequest) (*emptypb.Empty, error)

func (UnimplementedDataNodeServer) Get 

func (UnimplementedDataNodeServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedDataNodeServer) GetMeta added in v0.2.0 

func (UnimplementedDataNodeServer) GetMeta(context.Context, *GetMetaRequest) (*GetMetaResponse, error)

func (UnimplementedDataNodeServer) Put 

func (UnimplementedDataNodeServer) Put(context.Context, *AddRequest) (*emptypb.Empty, error)

func (UnimplementedDataNodeServer) Size 

func (UnimplementedDataNodeServer) Size(context.Context, *SizeRequest) (*SizeResponse, error)

type UnsafeDagPoolClusterServer added in v0.4.0 

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

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

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

Source Files

View all Source files

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.