cdnsystem

Jul 20, 2023

Changes in this version

+ var File_pkg_apis_cdnsystem_v1_cdnsystem_proto protoreflect.FileDescriptor

+ var Seeder_ServiceDesc = grpc.ServiceDesc

+ func RegisterSeederServer(s grpc.ServiceRegistrar, srv SeederServer)

+ type PieceSeed struct

+ BeginTime uint64

+ ContentLength int64

+ Done bool

+ EndTime uint64

+ ExtendAttribute *v1.ExtendAttribute

+ HostId string

+ PeerId string

+ PieceInfo *v1.PieceInfo

+ Reuse bool

+ TotalPieceCount int32

+ func (*PieceSeed) Descriptor() ([]byte, []int)

+ func (*PieceSeed) ProtoMessage()

+ func (m *PieceSeed) Validate() error

+ func (m *PieceSeed) ValidateAll() error

+ func (x *PieceSeed) GetBeginTime() uint64

+ func (x *PieceSeed) GetContentLength() int64

+ func (x *PieceSeed) GetDone() bool

+ func (x *PieceSeed) GetEndTime() uint64

+ func (x *PieceSeed) GetExtendAttribute() *v1.ExtendAttribute

+ func (x *PieceSeed) GetHostId() string

+ func (x *PieceSeed) GetPeerId() string

+ func (x *PieceSeed) GetPieceInfo() *v1.PieceInfo

+ func (x *PieceSeed) GetReuse() bool

+ func (x *PieceSeed) GetTotalPieceCount() int32

+ func (x *PieceSeed) ProtoReflect() protoreflect.Message

+ func (x *PieceSeed) Reset()

+ func (x *PieceSeed) String() string

+ type PieceSeedMultiError []error

+ func (m PieceSeedMultiError) AllErrors() []error

+ func (m PieceSeedMultiError) Error() string

+ type PieceSeedValidationError struct

+ func (e PieceSeedValidationError) Cause() error

+ func (e PieceSeedValidationError) Error() string

+ func (e PieceSeedValidationError) ErrorName() string

+ func (e PieceSeedValidationError) Field() string

+ func (e PieceSeedValidationError) Key() bool

+ func (e PieceSeedValidationError) Reason() string

+ type SeedRequest struct

+ TaskId string

+ Url string

+ UrlMeta *v1.UrlMeta

+ func (*SeedRequest) Descriptor() ([]byte, []int)

+ func (*SeedRequest) ProtoMessage()

+ func (m *SeedRequest) Validate() error

+ func (m *SeedRequest) ValidateAll() error

+ func (x *SeedRequest) GetTaskId() string

+ func (x *SeedRequest) GetUrl() string

+ func (x *SeedRequest) GetUrlMeta() *v1.UrlMeta

+ func (x *SeedRequest) ProtoReflect() protoreflect.Message

+ func (x *SeedRequest) Reset()

+ func (x *SeedRequest) String() string

+ type SeedRequestMultiError []error

+ func (m SeedRequestMultiError) AllErrors() []error

+ func (m SeedRequestMultiError) Error() string

+ type SeedRequestValidationError struct

+ func (e SeedRequestValidationError) Cause() error

+ func (e SeedRequestValidationError) Error() string

+ func (e SeedRequestValidationError) ErrorName() string

+ func (e SeedRequestValidationError) Field() string

+ func (e SeedRequestValidationError) Key() bool

+ func (e SeedRequestValidationError) Reason() string

+ type SeederClient interface

+ GetPieceTasks func(ctx context.Context, in *v1.PieceTaskRequest, opts ...grpc.CallOption) (*v1.PiecePacket, error)

+ ObtainSeeds func(ctx context.Context, in *SeedRequest, opts ...grpc.CallOption) (Seeder_ObtainSeedsClient, error)

+ SyncPieceTasks func(ctx context.Context, opts ...grpc.CallOption) (Seeder_SyncPieceTasksClient, error)

+ func NewSeederClient(cc grpc.ClientConnInterface) SeederClient

+ type SeederServer interface

+ GetPieceTasks func(context.Context, *v1.PieceTaskRequest) (*v1.PiecePacket, error)

+ ObtainSeeds func(*SeedRequest, Seeder_ObtainSeedsServer) error

+ SyncPieceTasks func(Seeder_SyncPieceTasksServer) error

+ type Seeder_ObtainSeedsClient interface

+ Recv func() (*PieceSeed, error)

+ type Seeder_ObtainSeedsServer interface

+ Send func(*PieceSeed) error

+ type Seeder_SyncPieceTasksClient interface

+ Recv func() (*v1.PiecePacket, error)

+ Send func(*v1.PieceTaskRequest) error

+ type Seeder_SyncPieceTasksServer interface

+ Recv func() (*v1.PieceTaskRequest, error)

+ Send func(*v1.PiecePacket) error

+ type UnimplementedSeederServer struct

+ func (UnimplementedSeederServer) GetPieceTasks(context.Context, *v1.PieceTaskRequest) (*v1.PiecePacket, error)

+ func (UnimplementedSeederServer) ObtainSeeds(*SeedRequest, Seeder_ObtainSeedsServer) error

+ func (UnimplementedSeederServer) SyncPieceTasks(Seeder_SyncPieceTasksServer) error

+ type UnsafeSeederServer interface