fileproto

package
v0.2.14-1 Latest Latest
Warning

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

 Go to latest Published: Aug 8, 2023 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthFile        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFile          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupFile = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var AvailabilityStatus_name = map[int32]string{
	0: "NotExists",
	1: "Exists",
	2: "ExistsInSpace",
}
View Source 
var AvailabilityStatus_value = map[string]int32{
	"NotExists":     0,
	"Exists":        1,
	"ExistsInSpace": 2,
}
View Source 
var ErrCodes_name = map[int32]string{
	0:   "Unexpected",
	1:   "CIDNotFound",
	2:   "Forbidden",
	3:   "SpaceLimitExceeded",
	4:   "QuerySizeExceeded",
	5:   "WrongHash",
	200: "ErrorOffset",
}
View Source 
var ErrCodes_value = map[string]int32{
	"Unexpected":         0,
	"CIDNotFound":        1,
	"Forbidden":          2,
	"SpaceLimitExceeded": 3,
	"QuerySizeExceeded":  4,
	"WrongHash":          5,
	"ErrorOffset":        200,
}

Functions

func DRPCRegisterFile 

func DRPCRegisterFile(mux drpc.Mux, impl DRPCFileServer) error

Types

type AvailabilityStatus 

type AvailabilityStatus int32
const (
	AvailabilityStatus_NotExists     AvailabilityStatus = 0
	AvailabilityStatus_Exists        AvailabilityStatus = 1
	AvailabilityStatus_ExistsInSpace AvailabilityStatus = 2
)

func (AvailabilityStatus) EnumDescriptor 

func (AvailabilityStatus) EnumDescriptor() ([]byte, []int)

func (AvailabilityStatus) String 

func (x AvailabilityStatus) String() string

type BlockAvailability 

type BlockAvailability struct {
	Cid    []byte             `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	Status AvailabilityStatus `protobuf:"varint,2,opt,name=status,proto3,enum=filesync.AvailabilityStatus" json:"status,omitempty"`
}

func (*BlockAvailability) Descriptor 

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

func (*BlockAvailability) GetCid 

func (m *BlockAvailability) GetCid() []byte

func (*BlockAvailability) GetStatus 

func (m *BlockAvailability) GetStatus() AvailabilityStatus

func (*BlockAvailability) Marshal 

func (m *BlockAvailability) Marshal() (dAtA []byte, err error)

func (*BlockAvailability) MarshalTo 

func (m *BlockAvailability) MarshalTo(dAtA []byte) (int, error)

func (*BlockAvailability) MarshalToSizedBuffer 

func (m *BlockAvailability) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlockAvailability) ProtoMessage 

func (*BlockAvailability) ProtoMessage()

func (*BlockAvailability) Reset 

func (m *BlockAvailability) Reset()

func (*BlockAvailability) Size 

func (m *BlockAvailability) Size() (n int)

func (*BlockAvailability) String 

func (m *BlockAvailability) String() string

func (*BlockAvailability) Unmarshal 

func (m *BlockAvailability) Unmarshal(dAtA []byte) error

func (*BlockAvailability) XXX_DiscardUnknown 

func (m *BlockAvailability) XXX_DiscardUnknown()

func (*BlockAvailability) XXX_Marshal 

func (m *BlockAvailability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlockAvailability) XXX_Merge 

func (m *BlockAvailability) XXX_Merge(src proto.Message)

func (*BlockAvailability) XXX_Size 

func (m *BlockAvailability) XXX_Size() int

func (*BlockAvailability) XXX_Unmarshal 

func (m *BlockAvailability) XXX_Unmarshal(b []byte) error

type BlockGetRequest 

type BlockGetRequest struct {
	SpaceId string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	Cid     []byte `protobuf:"bytes,2,opt,name=cid,proto3" json:"cid,omitempty"`
}

func (*BlockGetRequest) Descriptor 

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

func (*BlockGetRequest) GetCid 

func (m *BlockGetRequest) GetCid() []byte

func (*BlockGetRequest) GetSpaceId 

func (m *BlockGetRequest) GetSpaceId() string

func (*BlockGetRequest) Marshal 

func (m *BlockGetRequest) Marshal() (dAtA []byte, err error)

func (*BlockGetRequest) MarshalTo 

func (m *BlockGetRequest) MarshalTo(dAtA []byte) (int, error)

func (*BlockGetRequest) MarshalToSizedBuffer 

func (m *BlockGetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlockGetRequest) ProtoMessage 

func (*BlockGetRequest) ProtoMessage()

func (*BlockGetRequest) Reset 

func (m *BlockGetRequest) Reset()

func (*BlockGetRequest) Size 

func (m *BlockGetRequest) Size() (n int)

func (*BlockGetRequest) String 

func (m *BlockGetRequest) String() string

func (*BlockGetRequest) Unmarshal 

func (m *BlockGetRequest) Unmarshal(dAtA []byte) error

func (*BlockGetRequest) XXX_DiscardUnknown 

func (m *BlockGetRequest) XXX_DiscardUnknown()

func (*BlockGetRequest) XXX_Marshal 

func (m *BlockGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlockGetRequest) XXX_Merge 

func (m *BlockGetRequest) XXX_Merge(src proto.Message)

func (*BlockGetRequest) XXX_Size 

func (m *BlockGetRequest) XXX_Size() int

func (*BlockGetRequest) XXX_Unmarshal 

func (m *BlockGetRequest) XXX_Unmarshal(b []byte) error

type BlockGetResponse 

type BlockGetResponse struct {
	Cid  []byte `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*BlockGetResponse) Descriptor 

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

func (*BlockGetResponse) GetCid 

func (m *BlockGetResponse) GetCid() []byte

func (*BlockGetResponse) GetData 

func (m *BlockGetResponse) GetData() []byte

func (*BlockGetResponse) Marshal 

func (m *BlockGetResponse) Marshal() (dAtA []byte, err error)

func (*BlockGetResponse) MarshalTo 

func (m *BlockGetResponse) MarshalTo(dAtA []byte) (int, error)

func (*BlockGetResponse) MarshalToSizedBuffer 

func (m *BlockGetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlockGetResponse) ProtoMessage 

func (*BlockGetResponse) ProtoMessage()

func (*BlockGetResponse) Reset 

func (m *BlockGetResponse) Reset()

func (*BlockGetResponse) Size 

func (m *BlockGetResponse) Size() (n int)

func (*BlockGetResponse) String 

func (m *BlockGetResponse) String() string

func (*BlockGetResponse) Unmarshal 

func (m *BlockGetResponse) Unmarshal(dAtA []byte) error

func (*BlockGetResponse) XXX_DiscardUnknown 

func (m *BlockGetResponse) XXX_DiscardUnknown()

func (*BlockGetResponse) XXX_Marshal 

func (m *BlockGetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlockGetResponse) XXX_Merge 

func (m *BlockGetResponse) XXX_Merge(src proto.Message)

func (*BlockGetResponse) XXX_Size 

func (m *BlockGetResponse) XXX_Size() int

func (*BlockGetResponse) XXX_Unmarshal 

func (m *BlockGetResponse) XXX_Unmarshal(b []byte) error

type BlockPushRequest 

type BlockPushRequest struct {
	SpaceId string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	FileId  string `protobuf:"bytes,2,opt,name=fileId,proto3" json:"fileId,omitempty"`
	Cid     []byte `protobuf:"bytes,3,opt,name=cid,proto3" json:"cid,omitempty"`
	Data    []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
}

func (*BlockPushRequest) Descriptor 

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

func (*BlockPushRequest) GetCid 

func (m *BlockPushRequest) GetCid() []byte

func (*BlockPushRequest) GetData 

func (m *BlockPushRequest) GetData() []byte

func (*BlockPushRequest) GetFileId 

func (m *BlockPushRequest) GetFileId() string

func (*BlockPushRequest) GetSpaceId 

func (m *BlockPushRequest) GetSpaceId() string

func (*BlockPushRequest) Marshal 

func (m *BlockPushRequest) Marshal() (dAtA []byte, err error)

func (*BlockPushRequest) MarshalTo 

func (m *BlockPushRequest) MarshalTo(dAtA []byte) (int, error)

func (*BlockPushRequest) MarshalToSizedBuffer 

func (m *BlockPushRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlockPushRequest) ProtoMessage 

func (*BlockPushRequest) ProtoMessage()

func (*BlockPushRequest) Reset 

func (m *BlockPushRequest) Reset()

func (*BlockPushRequest) Size 

func (m *BlockPushRequest) Size() (n int)

func (*BlockPushRequest) String 

func (m *BlockPushRequest) String() string

func (*BlockPushRequest) Unmarshal 

func (m *BlockPushRequest) Unmarshal(dAtA []byte) error

func (*BlockPushRequest) XXX_DiscardUnknown 

func (m *BlockPushRequest) XXX_DiscardUnknown()

func (*BlockPushRequest) XXX_Marshal 

func (m *BlockPushRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlockPushRequest) XXX_Merge 

func (m *BlockPushRequest) XXX_Merge(src proto.Message)

func (*BlockPushRequest) XXX_Size 

func (m *BlockPushRequest) XXX_Size() int

func (*BlockPushRequest) XXX_Unmarshal 

func (m *BlockPushRequest) XXX_Unmarshal(b []byte) error

type BlockPushResponse 

type BlockPushResponse struct {
}

func (*BlockPushResponse) Descriptor 

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

func (*BlockPushResponse) Marshal 

func (m *BlockPushResponse) Marshal() (dAtA []byte, err error)

func (*BlockPushResponse) MarshalTo 

func (m *BlockPushResponse) MarshalTo(dAtA []byte) (int, error)

func (*BlockPushResponse) MarshalToSizedBuffer 

func (m *BlockPushResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlockPushResponse) ProtoMessage 

func (*BlockPushResponse) ProtoMessage()

func (*BlockPushResponse) Reset 

func (m *BlockPushResponse) Reset()

func (*BlockPushResponse) Size 

func (m *BlockPushResponse) Size() (n int)

func (*BlockPushResponse) String 

func (m *BlockPushResponse) String() string

func (*BlockPushResponse) Unmarshal 

func (m *BlockPushResponse) Unmarshal(dAtA []byte) error

func (*BlockPushResponse) XXX_DiscardUnknown 

func (m *BlockPushResponse) XXX_DiscardUnknown()

func (*BlockPushResponse) XXX_Marshal 

func (m *BlockPushResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlockPushResponse) XXX_Merge 

func (m *BlockPushResponse) XXX_Merge(src proto.Message)

func (*BlockPushResponse) XXX_Size 

func (m *BlockPushResponse) XXX_Size() int

func (*BlockPushResponse) XXX_Unmarshal 

func (m *BlockPushResponse) XXX_Unmarshal(b []byte) error

type BlocksBindRequest 

type BlocksBindRequest struct {
	SpaceId string   `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	FileId  string   `protobuf:"bytes,2,opt,name=fileId,proto3" json:"fileId,omitempty"`
	Cids    [][]byte `protobuf:"bytes,3,rep,name=cids,proto3" json:"cids,omitempty"`
}

func (*BlocksBindRequest) Descriptor 

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

func (*BlocksBindRequest) GetCids 

func (m *BlocksBindRequest) GetCids() [][]byte

func (*BlocksBindRequest) GetFileId 

func (m *BlocksBindRequest) GetFileId() string

func (*BlocksBindRequest) GetSpaceId 

func (m *BlocksBindRequest) GetSpaceId() string

func (*BlocksBindRequest) Marshal 

func (m *BlocksBindRequest) Marshal() (dAtA []byte, err error)

func (*BlocksBindRequest) MarshalTo 

func (m *BlocksBindRequest) MarshalTo(dAtA []byte) (int, error)

func (*BlocksBindRequest) MarshalToSizedBuffer 

func (m *BlocksBindRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlocksBindRequest) ProtoMessage 

func (*BlocksBindRequest) ProtoMessage()

func (*BlocksBindRequest) Reset 

func (m *BlocksBindRequest) Reset()

func (*BlocksBindRequest) Size 

func (m *BlocksBindRequest) Size() (n int)

func (*BlocksBindRequest) String 

func (m *BlocksBindRequest) String() string

func (*BlocksBindRequest) Unmarshal 

func (m *BlocksBindRequest) Unmarshal(dAtA []byte) error

func (*BlocksBindRequest) XXX_DiscardUnknown 

func (m *BlocksBindRequest) XXX_DiscardUnknown()

func (*BlocksBindRequest) XXX_Marshal 

func (m *BlocksBindRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlocksBindRequest) XXX_Merge 

func (m *BlocksBindRequest) XXX_Merge(src proto.Message)

func (*BlocksBindRequest) XXX_Size 

func (m *BlocksBindRequest) XXX_Size() int

func (*BlocksBindRequest) XXX_Unmarshal 

func (m *BlocksBindRequest) XXX_Unmarshal(b []byte) error

type BlocksBindResponse 

type BlocksBindResponse struct {
}

func (*BlocksBindResponse) Descriptor 

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

func (*BlocksBindResponse) Marshal 

func (m *BlocksBindResponse) Marshal() (dAtA []byte, err error)

func (*BlocksBindResponse) MarshalTo 

func (m *BlocksBindResponse) MarshalTo(dAtA []byte) (int, error)

func (*BlocksBindResponse) MarshalToSizedBuffer 

func (m *BlocksBindResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlocksBindResponse) ProtoMessage 

func (*BlocksBindResponse) ProtoMessage()

func (*BlocksBindResponse) Reset 

func (m *BlocksBindResponse) Reset()

func (*BlocksBindResponse) Size 

func (m *BlocksBindResponse) Size() (n int)

func (*BlocksBindResponse) String 

func (m *BlocksBindResponse) String() string

func (*BlocksBindResponse) Unmarshal 

func (m *BlocksBindResponse) Unmarshal(dAtA []byte) error

func (*BlocksBindResponse) XXX_DiscardUnknown 

func (m *BlocksBindResponse) XXX_DiscardUnknown()

func (*BlocksBindResponse) XXX_Marshal 

func (m *BlocksBindResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlocksBindResponse) XXX_Merge 

func (m *BlocksBindResponse) XXX_Merge(src proto.Message)

func (*BlocksBindResponse) XXX_Size 

func (m *BlocksBindResponse) XXX_Size() int

func (*BlocksBindResponse) XXX_Unmarshal 

func (m *BlocksBindResponse) XXX_Unmarshal(b []byte) error

type BlocksCheckRequest 

type BlocksCheckRequest struct {
	SpaceId string   `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	Cids    [][]byte `protobuf:"bytes,2,rep,name=cids,proto3" json:"cids,omitempty"`
}

func (*BlocksCheckRequest) Descriptor 

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

func (*BlocksCheckRequest) GetCids 

func (m *BlocksCheckRequest) GetCids() [][]byte

func (*BlocksCheckRequest) GetSpaceId 

func (m *BlocksCheckRequest) GetSpaceId() string

func (*BlocksCheckRequest) Marshal 

func (m *BlocksCheckRequest) Marshal() (dAtA []byte, err error)

func (*BlocksCheckRequest) MarshalTo 

func (m *BlocksCheckRequest) MarshalTo(dAtA []byte) (int, error)

func (*BlocksCheckRequest) MarshalToSizedBuffer 

func (m *BlocksCheckRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlocksCheckRequest) ProtoMessage 

func (*BlocksCheckRequest) ProtoMessage()

func (*BlocksCheckRequest) Reset 

func (m *BlocksCheckRequest) Reset()

func (*BlocksCheckRequest) Size 

func (m *BlocksCheckRequest) Size() (n int)

func (*BlocksCheckRequest) String 

func (m *BlocksCheckRequest) String() string

func (*BlocksCheckRequest) Unmarshal 

func (m *BlocksCheckRequest) Unmarshal(dAtA []byte) error

func (*BlocksCheckRequest) XXX_DiscardUnknown 

func (m *BlocksCheckRequest) XXX_DiscardUnknown()

func (*BlocksCheckRequest) XXX_Marshal 

func (m *BlocksCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlocksCheckRequest) XXX_Merge 

func (m *BlocksCheckRequest) XXX_Merge(src proto.Message)

func (*BlocksCheckRequest) XXX_Size 

func (m *BlocksCheckRequest) XXX_Size() int

func (*BlocksCheckRequest) XXX_Unmarshal 

func (m *BlocksCheckRequest) XXX_Unmarshal(b []byte) error

type BlocksCheckResponse 

type BlocksCheckResponse struct {
	BlocksAvailability []*BlockAvailability `protobuf:"bytes,1,rep,name=blocksAvailability,proto3" json:"blocksAvailability,omitempty"`
}

func (*BlocksCheckResponse) Descriptor 

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

func (*BlocksCheckResponse) GetBlocksAvailability 

func (m *BlocksCheckResponse) GetBlocksAvailability() []*BlockAvailability

func (*BlocksCheckResponse) Marshal 

func (m *BlocksCheckResponse) Marshal() (dAtA []byte, err error)

func (*BlocksCheckResponse) MarshalTo 

func (m *BlocksCheckResponse) MarshalTo(dAtA []byte) (int, error)

func (*BlocksCheckResponse) MarshalToSizedBuffer 

func (m *BlocksCheckResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlocksCheckResponse) ProtoMessage 

func (*BlocksCheckResponse) ProtoMessage()

func (*BlocksCheckResponse) Reset 

func (m *BlocksCheckResponse) Reset()

func (*BlocksCheckResponse) Size 

func (m *BlocksCheckResponse) Size() (n int)

func (*BlocksCheckResponse) String 

func (m *BlocksCheckResponse) String() string

func (*BlocksCheckResponse) Unmarshal 

func (m *BlocksCheckResponse) Unmarshal(dAtA []byte) error

func (*BlocksCheckResponse) XXX_DiscardUnknown 

func (m *BlocksCheckResponse) XXX_DiscardUnknown()

func (*BlocksCheckResponse) XXX_Marshal 

func (m *BlocksCheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlocksCheckResponse) XXX_Merge 

func (m *BlocksCheckResponse) XXX_Merge(src proto.Message)

func (*BlocksCheckResponse) XXX_Size 

func (m *BlocksCheckResponse) XXX_Size() int

func (*BlocksCheckResponse) XXX_Unmarshal 

func (m *BlocksCheckResponse) XXX_Unmarshal(b []byte) error

type CheckRequest 

type CheckRequest struct {
}

func (*CheckRequest) Descriptor 

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

func (*CheckRequest) Marshal 

func (m *CheckRequest) Marshal() (dAtA []byte, err error)

func (*CheckRequest) MarshalTo 

func (m *CheckRequest) MarshalTo(dAtA []byte) (int, error)

func (*CheckRequest) MarshalToSizedBuffer 

func (m *CheckRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckRequest) ProtoMessage 

func (*CheckRequest) ProtoMessage()

func (*CheckRequest) Reset 

func (m *CheckRequest) Reset()

func (*CheckRequest) Size 

func (m *CheckRequest) Size() (n int)

func (*CheckRequest) String 

func (m *CheckRequest) String() string

func (*CheckRequest) Unmarshal 

func (m *CheckRequest) Unmarshal(dAtA []byte) error

func (*CheckRequest) XXX_DiscardUnknown 

func (m *CheckRequest) XXX_DiscardUnknown()

func (*CheckRequest) XXX_Marshal 

func (m *CheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckRequest) XXX_Merge 

func (m *CheckRequest) XXX_Merge(src proto.Message)

func (*CheckRequest) XXX_Size 

func (m *CheckRequest) XXX_Size() int

func (*CheckRequest) XXX_Unmarshal 

func (m *CheckRequest) XXX_Unmarshal(b []byte) error

type CheckResponse 

type CheckResponse struct {
	SpaceIds   []string `protobuf:"bytes,1,rep,name=spaceIds,proto3" json:"spaceIds,omitempty"`
	AllowWrite bool     `protobuf:"varint,2,opt,name=allowWrite,proto3" json:"allowWrite,omitempty"`
}

func (*CheckResponse) Descriptor 

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

func (*CheckResponse) GetAllowWrite 

func (m *CheckResponse) GetAllowWrite() bool

func (*CheckResponse) GetSpaceIds 

func (m *CheckResponse) GetSpaceIds() []string

func (*CheckResponse) Marshal 

func (m *CheckResponse) Marshal() (dAtA []byte, err error)

func (*CheckResponse) MarshalTo 

func (m *CheckResponse) MarshalTo(dAtA []byte) (int, error)

func (*CheckResponse) MarshalToSizedBuffer 

func (m *CheckResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckResponse) ProtoMessage 

func (*CheckResponse) ProtoMessage()

func (*CheckResponse) Reset 

func (m *CheckResponse) Reset()

func (*CheckResponse) Size 

func (m *CheckResponse) Size() (n int)

func (*CheckResponse) String 

func (m *CheckResponse) String() string

func (*CheckResponse) Unmarshal 

func (m *CheckResponse) Unmarshal(dAtA []byte) error

func (*CheckResponse) XXX_DiscardUnknown 

func (m *CheckResponse) XXX_DiscardUnknown()

func (*CheckResponse) XXX_Marshal 

func (m *CheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckResponse) XXX_Merge 

func (m *CheckResponse) XXX_Merge(src proto.Message)

func (*CheckResponse) XXX_Size 

func (m *CheckResponse) XXX_Size() int

func (*CheckResponse) XXX_Unmarshal 

func (m *CheckResponse) XXX_Unmarshal(b []byte) error

type DRPCFileClient 

type DRPCFileClient interface {
	DRPCConn() drpc.Conn

	BlockGet(ctx context.Context, in *BlockGetRequest) (*BlockGetResponse, error)
	BlockPush(ctx context.Context, in *BlockPushRequest) (*BlockPushResponse, error)
	BlocksCheck(ctx context.Context, in *BlocksCheckRequest) (*BlocksCheckResponse, error)
	BlocksBind(ctx context.Context, in *BlocksBindRequest) (*BlocksBindResponse, error)
	FilesDelete(ctx context.Context, in *FilesDeleteRequest) (*FilesDeleteResponse, error)
	FilesInfo(ctx context.Context, in *FilesInfoRequest) (*FilesInfoResponse, error)
	Check(ctx context.Context, in *CheckRequest) (*CheckResponse, error)
	SpaceInfo(ctx context.Context, in *SpaceInfoRequest) (*SpaceInfoResponse, error)
}

func NewDRPCFileClient 

func NewDRPCFileClient(cc drpc.Conn) DRPCFileClient

type DRPCFileDescription 

type DRPCFileDescription struct{}

func (DRPCFileDescription) Method 

func (DRPCFileDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCFileDescription) NumMethods 

func (DRPCFileDescription) NumMethods() int

type DRPCFileServer 

type DRPCFileServer interface {
	BlockGet(context.Context, *BlockGetRequest) (*BlockGetResponse, error)
	BlockPush(context.Context, *BlockPushRequest) (*BlockPushResponse, error)
	BlocksCheck(context.Context, *BlocksCheckRequest) (*BlocksCheckResponse, error)
	BlocksBind(context.Context, *BlocksBindRequest) (*BlocksBindResponse, error)
	FilesDelete(context.Context, *FilesDeleteRequest) (*FilesDeleteResponse, error)
	FilesInfo(context.Context, *FilesInfoRequest) (*FilesInfoResponse, error)
	Check(context.Context, *CheckRequest) (*CheckResponse, error)
	SpaceInfo(context.Context, *SpaceInfoRequest) (*SpaceInfoResponse, error)
}

type DRPCFileUnimplementedServer 

type DRPCFileUnimplementedServer struct{}

func (*DRPCFileUnimplementedServer) BlockGet 

func (s *DRPCFileUnimplementedServer) BlockGet(context.Context, *BlockGetRequest) (*BlockGetResponse, error)

func (*DRPCFileUnimplementedServer) BlockPush 

func (s *DRPCFileUnimplementedServer) BlockPush(context.Context, *BlockPushRequest) (*BlockPushResponse, error)

func (*DRPCFileUnimplementedServer) BlocksBind 

func (s *DRPCFileUnimplementedServer) BlocksBind(context.Context, *BlocksBindRequest) (*BlocksBindResponse, error)

func (*DRPCFileUnimplementedServer) BlocksCheck 

func (s *DRPCFileUnimplementedServer) BlocksCheck(context.Context, *BlocksCheckRequest) (*BlocksCheckResponse, error)

func (*DRPCFileUnimplementedServer) Check 

func (s *DRPCFileUnimplementedServer) Check(context.Context, *CheckRequest) (*CheckResponse, error)

func (*DRPCFileUnimplementedServer) FilesDelete 

func (s *DRPCFileUnimplementedServer) FilesDelete(context.Context, *FilesDeleteRequest) (*FilesDeleteResponse, error)

func (*DRPCFileUnimplementedServer) FilesInfo 

func (s *DRPCFileUnimplementedServer) FilesInfo(context.Context, *FilesInfoRequest) (*FilesInfoResponse, error)

func (*DRPCFileUnimplementedServer) SpaceInfo 

func (s *DRPCFileUnimplementedServer) SpaceInfo(context.Context, *SpaceInfoRequest) (*SpaceInfoResponse, error)

type DRPCFile_BlockGetStream 

type DRPCFile_BlockGetStream interface {
	drpc.Stream
	SendAndClose(*BlockGetResponse) error
}

type DRPCFile_BlockPushStream 

type DRPCFile_BlockPushStream interface {
	drpc.Stream
	SendAndClose(*BlockPushResponse) error
}

type DRPCFile_BlocksBindStream 

type DRPCFile_BlocksBindStream interface {
	drpc.Stream
	SendAndClose(*BlocksBindResponse) error
}

type DRPCFile_BlocksCheckStream 

type DRPCFile_BlocksCheckStream interface {
	drpc.Stream
	SendAndClose(*BlocksCheckResponse) error
}

type DRPCFile_CheckStream 

type DRPCFile_CheckStream interface {
	drpc.Stream
	SendAndClose(*CheckResponse) error
}

type DRPCFile_FilesDeleteStream 

type DRPCFile_FilesDeleteStream interface {
	drpc.Stream
	SendAndClose(*FilesDeleteResponse) error
}

type DRPCFile_FilesInfoStream 

type DRPCFile_FilesInfoStream interface {
	drpc.Stream
	SendAndClose(*FilesInfoResponse) error
}

type DRPCFile_SpaceInfoStream 

type DRPCFile_SpaceInfoStream interface {
	drpc.Stream
	SendAndClose(*SpaceInfoResponse) error
}

type ErrCodes 

type ErrCodes int32
const (
	ErrCodes_Unexpected         ErrCodes = 0
	ErrCodes_CIDNotFound        ErrCodes = 1
	ErrCodes_Forbidden          ErrCodes = 2
	ErrCodes_SpaceLimitExceeded ErrCodes = 3
	ErrCodes_QuerySizeExceeded  ErrCodes = 4
	ErrCodes_WrongHash          ErrCodes = 5
	ErrCodes_ErrorOffset        ErrCodes = 200
)

func (ErrCodes) EnumDescriptor 

func (ErrCodes) EnumDescriptor() ([]byte, []int)

func (ErrCodes) String 

func (x ErrCodes) String() string

type FileInfo 

type FileInfo struct {
	FileId     string `protobuf:"bytes,1,opt,name=fileId,proto3" json:"fileId,omitempty"`
	UsageBytes uint64 `protobuf:"varint,2,opt,name=usageBytes,proto3" json:"usageBytes,omitempty"`
	CidsCount  uint32 `protobuf:"varint,3,opt,name=cidsCount,proto3" json:"cidsCount,omitempty"`
}

func (*FileInfo) Descriptor 

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

func (*FileInfo) GetCidsCount 

func (m *FileInfo) GetCidsCount() uint32

func (*FileInfo) GetFileId 

func (m *FileInfo) GetFileId() string

func (*FileInfo) GetUsageBytes 

func (m *FileInfo) GetUsageBytes() uint64

func (*FileInfo) Marshal 

func (m *FileInfo) Marshal() (dAtA []byte, err error)

func (*FileInfo) MarshalTo 

func (m *FileInfo) MarshalTo(dAtA []byte) (int, error)

func (*FileInfo) MarshalToSizedBuffer 

func (m *FileInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FileInfo) ProtoMessage 

func (*FileInfo) ProtoMessage()

func (*FileInfo) Reset 

func (m *FileInfo) Reset()

func (*FileInfo) Size 

func (m *FileInfo) Size() (n int)

func (*FileInfo) String 

func (m *FileInfo) String() string

func (*FileInfo) Unmarshal 

func (m *FileInfo) Unmarshal(dAtA []byte) error

func (*FileInfo) XXX_DiscardUnknown 

func (m *FileInfo) XXX_DiscardUnknown()

func (*FileInfo) XXX_Marshal 

func (m *FileInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileInfo) XXX_Merge 

func (m *FileInfo) XXX_Merge(src proto.Message)

func (*FileInfo) XXX_Size 

func (m *FileInfo) XXX_Size() int

func (*FileInfo) XXX_Unmarshal 

func (m *FileInfo) XXX_Unmarshal(b []byte) error

type FilesDeleteRequest 

type FilesDeleteRequest struct {
	SpaceId string   `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	FileIds []string `protobuf:"bytes,2,rep,name=fileIds,proto3" json:"fileIds,omitempty"`
}

func (*FilesDeleteRequest) Descriptor 

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

func (*FilesDeleteRequest) GetFileIds 

func (m *FilesDeleteRequest) GetFileIds() []string

func (*FilesDeleteRequest) GetSpaceId 

func (m *FilesDeleteRequest) GetSpaceId() string

func (*FilesDeleteRequest) Marshal 

func (m *FilesDeleteRequest) Marshal() (dAtA []byte, err error)

func (*FilesDeleteRequest) MarshalTo 

func (m *FilesDeleteRequest) MarshalTo(dAtA []byte) (int, error)

func (*FilesDeleteRequest) MarshalToSizedBuffer 

func (m *FilesDeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FilesDeleteRequest) ProtoMessage 

func (*FilesDeleteRequest) ProtoMessage()

func (*FilesDeleteRequest) Reset 

func (m *FilesDeleteRequest) Reset()

func (*FilesDeleteRequest) Size 

func (m *FilesDeleteRequest) Size() (n int)

func (*FilesDeleteRequest) String 

func (m *FilesDeleteRequest) String() string

func (*FilesDeleteRequest) Unmarshal 

func (m *FilesDeleteRequest) Unmarshal(dAtA []byte) error

func (*FilesDeleteRequest) XXX_DiscardUnknown 

func (m *FilesDeleteRequest) XXX_DiscardUnknown()

func (*FilesDeleteRequest) XXX_Marshal 

func (m *FilesDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FilesDeleteRequest) XXX_Merge 

func (m *FilesDeleteRequest) XXX_Merge(src proto.Message)

func (*FilesDeleteRequest) XXX_Size 

func (m *FilesDeleteRequest) XXX_Size() int

func (*FilesDeleteRequest) XXX_Unmarshal 

func (m *FilesDeleteRequest) XXX_Unmarshal(b []byte) error

type FilesDeleteResponse 

type FilesDeleteResponse struct {
}

func (*FilesDeleteResponse) Descriptor 

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

func (*FilesDeleteResponse) Marshal 

func (m *FilesDeleteResponse) Marshal() (dAtA []byte, err error)

func (*FilesDeleteResponse) MarshalTo 

func (m *FilesDeleteResponse) MarshalTo(dAtA []byte) (int, error)

func (*FilesDeleteResponse) MarshalToSizedBuffer 

func (m *FilesDeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FilesDeleteResponse) ProtoMessage 

func (*FilesDeleteResponse) ProtoMessage()

func (*FilesDeleteResponse) Reset 

func (m *FilesDeleteResponse) Reset()

func (*FilesDeleteResponse) Size 

func (m *FilesDeleteResponse) Size() (n int)

func (*FilesDeleteResponse) String 

func (m *FilesDeleteResponse) String() string

func (*FilesDeleteResponse) Unmarshal 

func (m *FilesDeleteResponse) Unmarshal(dAtA []byte) error

func (*FilesDeleteResponse) XXX_DiscardUnknown 

func (m *FilesDeleteResponse) XXX_DiscardUnknown()

func (*FilesDeleteResponse) XXX_Marshal 

func (m *FilesDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FilesDeleteResponse) XXX_Merge 

func (m *FilesDeleteResponse) XXX_Merge(src proto.Message)

func (*FilesDeleteResponse) XXX_Size 

func (m *FilesDeleteResponse) XXX_Size() int

func (*FilesDeleteResponse) XXX_Unmarshal 

func (m *FilesDeleteResponse) XXX_Unmarshal(b []byte) error

type FilesInfoRequest 

type FilesInfoRequest struct {
	SpaceId string   `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	FileIds []string `protobuf:"bytes,2,rep,name=fileIds,proto3" json:"fileIds,omitempty"`
}

func (*FilesInfoRequest) Descriptor 

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

func (*FilesInfoRequest) GetFileIds 

func (m *FilesInfoRequest) GetFileIds() []string

func (*FilesInfoRequest) GetSpaceId 

func (m *FilesInfoRequest) GetSpaceId() string

func (*FilesInfoRequest) Marshal 

func (m *FilesInfoRequest) Marshal() (dAtA []byte, err error)

func (*FilesInfoRequest) MarshalTo 

func (m *FilesInfoRequest) MarshalTo(dAtA []byte) (int, error)

func (*FilesInfoRequest) MarshalToSizedBuffer 

func (m *FilesInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FilesInfoRequest) ProtoMessage 

func (*FilesInfoRequest) ProtoMessage()

func (*FilesInfoRequest) Reset 

func (m *FilesInfoRequest) Reset()

func (*FilesInfoRequest) Size 

func (m *FilesInfoRequest) Size() (n int)

func (*FilesInfoRequest) String 

func (m *FilesInfoRequest) String() string

func (*FilesInfoRequest) Unmarshal 

func (m *FilesInfoRequest) Unmarshal(dAtA []byte) error

func (*FilesInfoRequest) XXX_DiscardUnknown 

func (m *FilesInfoRequest) XXX_DiscardUnknown()

func (*FilesInfoRequest) XXX_Marshal 

func (m *FilesInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FilesInfoRequest) XXX_Merge 

func (m *FilesInfoRequest) XXX_Merge(src proto.Message)

func (*FilesInfoRequest) XXX_Size 

func (m *FilesInfoRequest) XXX_Size() int

func (*FilesInfoRequest) XXX_Unmarshal 

func (m *FilesInfoRequest) XXX_Unmarshal(b []byte) error

type FilesInfoResponse 

type FilesInfoResponse struct {
	FilesInfo []*FileInfo `protobuf:"bytes,1,rep,name=filesInfo,proto3" json:"filesInfo,omitempty"`
}

func (*FilesInfoResponse) Descriptor 

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

func (*FilesInfoResponse) GetFilesInfo 

func (m *FilesInfoResponse) GetFilesInfo() []*FileInfo

func (*FilesInfoResponse) Marshal 

func (m *FilesInfoResponse) Marshal() (dAtA []byte, err error)

func (*FilesInfoResponse) MarshalTo 

func (m *FilesInfoResponse) MarshalTo(dAtA []byte) (int, error)

func (*FilesInfoResponse) MarshalToSizedBuffer 

func (m *FilesInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FilesInfoResponse) ProtoMessage 

func (*FilesInfoResponse) ProtoMessage()

func (*FilesInfoResponse) Reset 

func (m *FilesInfoResponse) Reset()

func (*FilesInfoResponse) Size 

func (m *FilesInfoResponse) Size() (n int)

func (*FilesInfoResponse) String 

func (m *FilesInfoResponse) String() string

func (*FilesInfoResponse) Unmarshal 

func (m *FilesInfoResponse) Unmarshal(dAtA []byte) error

func (*FilesInfoResponse) XXX_DiscardUnknown 

func (m *FilesInfoResponse) XXX_DiscardUnknown()

func (*FilesInfoResponse) XXX_Marshal 

func (m *FilesInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FilesInfoResponse) XXX_Merge 

func (m *FilesInfoResponse) XXX_Merge(src proto.Message)

func (*FilesInfoResponse) XXX_Size 

func (m *FilesInfoResponse) XXX_Size() int

func (*FilesInfoResponse) XXX_Unmarshal 

func (m *FilesInfoResponse) XXX_Unmarshal(b []byte) error

type SpaceInfoRequest 

type SpaceInfoRequest struct {
	SpaceId string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
}

func (*SpaceInfoRequest) Descriptor 

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

func (*SpaceInfoRequest) GetSpaceId 

func (m *SpaceInfoRequest) GetSpaceId() string

func (*SpaceInfoRequest) Marshal 

func (m *SpaceInfoRequest) Marshal() (dAtA []byte, err error)

func (*SpaceInfoRequest) MarshalTo 

func (m *SpaceInfoRequest) MarshalTo(dAtA []byte) (int, error)

func (*SpaceInfoRequest) MarshalToSizedBuffer 

func (m *SpaceInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SpaceInfoRequest) ProtoMessage 

func (*SpaceInfoRequest) ProtoMessage()

func (*SpaceInfoRequest) Reset 

func (m *SpaceInfoRequest) Reset()

func (*SpaceInfoRequest) Size 

func (m *SpaceInfoRequest) Size() (n int)

func (*SpaceInfoRequest) String 

func (m *SpaceInfoRequest) String() string

func (*SpaceInfoRequest) Unmarshal 

func (m *SpaceInfoRequest) Unmarshal(dAtA []byte) error

func (*SpaceInfoRequest) XXX_DiscardUnknown 

func (m *SpaceInfoRequest) XXX_DiscardUnknown()

func (*SpaceInfoRequest) XXX_Marshal 

func (m *SpaceInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SpaceInfoRequest) XXX_Merge 

func (m *SpaceInfoRequest) XXX_Merge(src proto.Message)

func (*SpaceInfoRequest) XXX_Size 

func (m *SpaceInfoRequest) XXX_Size() int

func (*SpaceInfoRequest) XXX_Unmarshal 

func (m *SpaceInfoRequest) XXX_Unmarshal(b []byte) error

type SpaceInfoResponse 

type SpaceInfoResponse struct {
	LimitBytes uint64 `protobuf:"varint,1,opt,name=limitBytes,proto3" json:"limitBytes,omitempty"`
	UsageBytes uint64 `protobuf:"varint,2,opt,name=usageBytes,proto3" json:"usageBytes,omitempty"`
	CidsCount  uint64 `protobuf:"varint,3,opt,name=cidsCount,proto3" json:"cidsCount,omitempty"`
	FilesCount uint64 `protobuf:"varint,4,opt,name=filesCount,proto3" json:"filesCount,omitempty"`
}

func (*SpaceInfoResponse) Descriptor 

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

func (*SpaceInfoResponse) GetCidsCount 

func (m *SpaceInfoResponse) GetCidsCount() uint64

func (*SpaceInfoResponse) GetFilesCount 

func (m *SpaceInfoResponse) GetFilesCount() uint64

func (*SpaceInfoResponse) GetLimitBytes 

func (m *SpaceInfoResponse) GetLimitBytes() uint64

func (*SpaceInfoResponse) GetUsageBytes 

func (m *SpaceInfoResponse) GetUsageBytes() uint64

func (*SpaceInfoResponse) Marshal 

func (m *SpaceInfoResponse) Marshal() (dAtA []byte, err error)

func (*SpaceInfoResponse) MarshalTo 

func (m *SpaceInfoResponse) MarshalTo(dAtA []byte) (int, error)

func (*SpaceInfoResponse) MarshalToSizedBuffer 

func (m *SpaceInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SpaceInfoResponse) ProtoMessage 

func (*SpaceInfoResponse) ProtoMessage()

func (*SpaceInfoResponse) Reset 

func (m *SpaceInfoResponse) Reset()

func (*SpaceInfoResponse) Size 

func (m *SpaceInfoResponse) Size() (n int)

func (*SpaceInfoResponse) String 

func (m *SpaceInfoResponse) String() string

func (*SpaceInfoResponse) Unmarshal 

func (m *SpaceInfoResponse) Unmarshal(dAtA []byte) error

func (*SpaceInfoResponse) XXX_DiscardUnknown 

func (m *SpaceInfoResponse) XXX_DiscardUnknown()

func (*SpaceInfoResponse) XXX_Marshal 

func (m *SpaceInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SpaceInfoResponse) XXX_Merge 

func (m *SpaceInfoResponse) XXX_Merge(src proto.Message)

func (*SpaceInfoResponse) XXX_Size 

func (m *SpaceInfoResponse) XXX_Size() int

func (*SpaceInfoResponse) XXX_Unmarshal 

func (m *SpaceInfoResponse) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Directories

Path Synopsis

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.