v1

package
v0.0.0-...-2004213 Latest Latest
Warning

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

 Go to latest Published: Jul 8, 2023 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Downloadmanager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.downloadmanager.v1.Downloadmanager",
	HandlerType: (*DownloadmanagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ScanTaskAndDownload",
			Handler:    _Downloadmanager_ScanTaskAndDownload_Handler,
		},
		{
			MethodName: "ScanTask",
			Handler:    _Downloadmanager_ScanTask_Handler,
		},
		{
			MethodName: "AddTask",
			Handler:    _Downloadmanager_AddTask_Handler,
		},
		{
			MethodName: "UpdateTask",
			Handler:    _Downloadmanager_UpdateTask_Handler,
		},
		{
			MethodName: "DeleteTask",
			Handler:    _Downloadmanager_DeleteTask_Handler,
		},
		{
			MethodName: "ListTask",
			Handler:    _Downloadmanager_ListTask_Handler,
		},
		{
			MethodName: "GetTask",
			Handler:    _Downloadmanager_GetTask_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/downloadmanager/v1/downloadmanager.proto",
}

Downloadmanager_ServiceDesc is the grpc.ServiceDesc for Downloadmanager 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_api_downloadmanager_v1_downloadmanager_proto protoreflect.FileDescriptor

Functions

func RegisterDownloadmanagerHTTPServer 

func RegisterDownloadmanagerHTTPServer(s *http.Server, srv DownloadmanagerHTTPServer)

func RegisterDownloadmanagerServer 

func RegisterDownloadmanagerServer(s grpc.ServiceRegistrar, srv DownloadmanagerServer)

Types

type AddTaskRequest 

type AddTaskRequest struct {
	Name          string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Regexp        string `protobuf:"bytes,2,opt,name=regexp,proto3" json:"regexp,omitempty"`
	LatestChapter int32  `protobuf:"varint,3,opt,name=latest_chapter,json=latestChapter,proto3" json:"latest_chapter,omitempty"`
	StorePath     string `protobuf:"bytes,4,opt,name=store_path,json=storePath,proto3" json:"store_path,omitempty"`
	AnimeId       string `protobuf:"bytes,5,opt,name=anime_id,json=animeId,proto3" json:"anime_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTaskRequest) Descriptor deprecated 

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

Deprecated: Use AddTaskRequest.ProtoReflect.Descriptor instead.

func (*AddTaskRequest) GetAnimeId 

func (x *AddTaskRequest) GetAnimeId() string

func (*AddTaskRequest) GetLatestChapter 

func (x *AddTaskRequest) GetLatestChapter() int32

func (*AddTaskRequest) GetName 

func (x *AddTaskRequest) GetName() string

func (*AddTaskRequest) GetRegexp 

func (x *AddTaskRequest) GetRegexp() string

func (*AddTaskRequest) GetStorePath 

func (x *AddTaskRequest) GetStorePath() string

func (*AddTaskRequest) ProtoMessage 

func (*AddTaskRequest) ProtoMessage()

func (*AddTaskRequest) ProtoReflect 

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

func (*AddTaskRequest) Reset 

func (x *AddTaskRequest) Reset()

func (*AddTaskRequest) String 

func (x *AddTaskRequest) String() string

type DeleteTaskRequest 

type DeleteTaskRequest struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTaskRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskRequest) GetId 

func (x *DeleteTaskRequest) GetId() int32

func (*DeleteTaskRequest) ProtoMessage 

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) ProtoReflect 

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

func (*DeleteTaskRequest) Reset 

func (x *DeleteTaskRequest) Reset()

func (*DeleteTaskRequest) String 

func (x *DeleteTaskRequest) String() string

type DownloadTask 

type DownloadTask struct {
	Name         string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ChapterStart int32  `protobuf:"varint,2,opt,name=chapter_start,json=chapterStart,proto3" json:"chapter_start,omitempty"`
	ChapterEnd   int32  `protobuf:"varint,3,opt,name=chapter_end,json=chapterEnd,proto3" json:"chapter_end,omitempty"`
	MagnetLink   string `protobuf:"bytes,4,opt,name=magnet_link,json=magnetLink,proto3" json:"magnet_link,omitempty"`
	AnimeId      string `protobuf:"bytes,5,opt,name=anime_id,json=animeId,proto3" json:"anime_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadTask) Descriptor deprecated 

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

Deprecated: Use DownloadTask.ProtoReflect.Descriptor instead.

func (*DownloadTask) GetAnimeId 

func (x *DownloadTask) GetAnimeId() string

func (*DownloadTask) GetChapterEnd 

func (x *DownloadTask) GetChapterEnd() int32

func (*DownloadTask) GetChapterStart 

func (x *DownloadTask) GetChapterStart() int32
func (x *DownloadTask) GetMagnetLink() string

func (*DownloadTask) GetName 

func (x *DownloadTask) GetName() string

func (*DownloadTask) ProtoMessage 

func (*DownloadTask) ProtoMessage()

func (*DownloadTask) ProtoReflect 

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

func (*DownloadTask) Reset 

func (x *DownloadTask) Reset()

func (*DownloadTask) String 

func (x *DownloadTask) String() string

type DownloadTaskInfo 

type DownloadTaskInfo struct {
	Id            int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name          string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Regexp        string `protobuf:"bytes,3,opt,name=regexp,proto3" json:"regexp,omitempty"`
	LatestChapter int32  `protobuf:"varint,4,opt,name=latest_chapter,json=latestChapter,proto3" json:"latest_chapter,omitempty"`
	StorePath     string `protobuf:"bytes,5,opt,name=store_path,json=storePath,proto3" json:"store_path,omitempty"`
	UpdateTime    string `protobuf:"bytes,6,opt,name=updateTime,proto3" json:"updateTime,omitempty"`
	AnimeId       string `protobuf:"bytes,7,opt,name=anime_id,json=animeId,proto3" json:"anime_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadTaskInfo) Descriptor deprecated 

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

Deprecated: Use DownloadTaskInfo.ProtoReflect.Descriptor instead.

func (*DownloadTaskInfo) GetAnimeId 

func (x *DownloadTaskInfo) GetAnimeId() string

func (*DownloadTaskInfo) GetId 

func (x *DownloadTaskInfo) GetId() int32

func (*DownloadTaskInfo) GetLatestChapter 

func (x *DownloadTaskInfo) GetLatestChapter() int32

func (*DownloadTaskInfo) GetName 

func (x *DownloadTaskInfo) GetName() string

func (*DownloadTaskInfo) GetRegexp 

func (x *DownloadTaskInfo) GetRegexp() string

func (*DownloadTaskInfo) GetStorePath 

func (x *DownloadTaskInfo) GetStorePath() string

func (*DownloadTaskInfo) GetUpdateTime 

func (x *DownloadTaskInfo) GetUpdateTime() string

func (*DownloadTaskInfo) ProtoMessage 

func (*DownloadTaskInfo) ProtoMessage()

func (*DownloadTaskInfo) ProtoReflect 

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

func (*DownloadTaskInfo) Reset 

func (x *DownloadTaskInfo) Reset()

func (*DownloadTaskInfo) String 

func (x *DownloadTaskInfo) String() string

type DownloadmanagerClient 

type DownloadmanagerClient interface {
	ScanTaskAndDownload(ctx context.Context, in *common.Empty, opts ...grpc.CallOption) (*ScanTaskAndDownloadReply, error)
	ScanTask(ctx context.Context, in *common.Empty, opts ...grpc.CallOption) (*ScanTaskReply, error)
	AddTask(ctx context.Context, in *AddTaskRequest, opts ...grpc.CallOption) (*common.Empty, error)
	UpdateTask(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*common.Empty, error)
	DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*common.Empty, error)
	ListTask(ctx context.Context, in *common.Empty, opts ...grpc.CallOption) (*ListTaskReply, error)
	GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*GetTaskReply, error)
}

DownloadmanagerClient is the client API for Downloadmanager 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 NewDownloadmanagerClient 

func NewDownloadmanagerClient(cc grpc.ClientConnInterface) DownloadmanagerClient

type DownloadmanagerHTTPClient 

type DownloadmanagerHTTPClient interface {
	AddTask(ctx context.Context, req *AddTaskRequest, opts ...http.CallOption) (rsp *common.Empty, err error)
	DeleteTask(ctx context.Context, req *DeleteTaskRequest, opts ...http.CallOption) (rsp *common.Empty, err error)
	GetTask(ctx context.Context, req *GetTaskRequest, opts ...http.CallOption) (rsp *GetTaskReply, err error)
	ListTask(ctx context.Context, req *common.Empty, opts ...http.CallOption) (rsp *ListTaskReply, err error)
	ScanTask(ctx context.Context, req *common.Empty, opts ...http.CallOption) (rsp *ScanTaskReply, err error)
	ScanTaskAndDownload(ctx context.Context, req *common.Empty, opts ...http.CallOption) (rsp *ScanTaskAndDownloadReply, err error)
	UpdateTask(ctx context.Context, req *UpdateTaskRequest, opts ...http.CallOption) (rsp *common.Empty, err error)
}

func NewDownloadmanagerHTTPClient 

func NewDownloadmanagerHTTPClient(client *http.Client) DownloadmanagerHTTPClient

type DownloadmanagerHTTPClientImpl 

type DownloadmanagerHTTPClientImpl struct {
	// contains filtered or unexported fields
}

func (*DownloadmanagerHTTPClientImpl) AddTask 

func (c *DownloadmanagerHTTPClientImpl) AddTask(ctx context.Context, in *AddTaskRequest, opts ...http.CallOption) (*common.Empty, error)

func (*DownloadmanagerHTTPClientImpl) DeleteTask 

func (c *DownloadmanagerHTTPClientImpl) DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...http.CallOption) (*common.Empty, error)

func (*DownloadmanagerHTTPClientImpl) GetTask 

func (c *DownloadmanagerHTTPClientImpl) GetTask(ctx context.Context, in *GetTaskRequest, opts ...http.CallOption) (*GetTaskReply, error)

func (*DownloadmanagerHTTPClientImpl) ListTask 

func (c *DownloadmanagerHTTPClientImpl) ListTask(ctx context.Context, in *common.Empty, opts ...http.CallOption) (*ListTaskReply, error)

func (*DownloadmanagerHTTPClientImpl) ScanTask 

func (c *DownloadmanagerHTTPClientImpl) ScanTask(ctx context.Context, in *common.Empty, opts ...http.CallOption) (*ScanTaskReply, error)

func (*DownloadmanagerHTTPClientImpl) ScanTaskAndDownload 

func (c *DownloadmanagerHTTPClientImpl) ScanTaskAndDownload(ctx context.Context, in *common.Empty, opts ...http.CallOption) (*ScanTaskAndDownloadReply, error)

func (*DownloadmanagerHTTPClientImpl) UpdateTask 

func (c *DownloadmanagerHTTPClientImpl) UpdateTask(ctx context.Context, in *UpdateTaskRequest, opts ...http.CallOption) (*common.Empty, error)

type DownloadmanagerHTTPServer 

type DownloadmanagerHTTPServer interface {
	AddTask(context.Context, *AddTaskRequest) (*common.Empty, error)
	DeleteTask(context.Context, *DeleteTaskRequest) (*common.Empty, error)
	GetTask(context.Context, *GetTaskRequest) (*GetTaskReply, error)
	ListTask(context.Context, *common.Empty) (*ListTaskReply, error)
	ScanTask(context.Context, *common.Empty) (*ScanTaskReply, error)
	ScanTaskAndDownload(context.Context, *common.Empty) (*ScanTaskAndDownloadReply, error)
	UpdateTask(context.Context, *UpdateTaskRequest) (*common.Empty, error)
}

type DownloadmanagerServer 

type DownloadmanagerServer interface {
	ScanTaskAndDownload(context.Context, *common.Empty) (*ScanTaskAndDownloadReply, error)
	ScanTask(context.Context, *common.Empty) (*ScanTaskReply, error)
	AddTask(context.Context, *AddTaskRequest) (*common.Empty, error)
	UpdateTask(context.Context, *UpdateTaskRequest) (*common.Empty, error)
	DeleteTask(context.Context, *DeleteTaskRequest) (*common.Empty, error)
	ListTask(context.Context, *common.Empty) (*ListTaskReply, error)
	GetTask(context.Context, *GetTaskRequest) (*GetTaskReply, error)
	// contains filtered or unexported methods
}

DownloadmanagerServer is the server API for Downloadmanager service. All implementations must embed UnimplementedDownloadmanagerServer for forward compatibility

type GetTaskReply 

type GetTaskReply struct {
	Task *DownloadTaskInfo `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTaskReply) Descriptor deprecated 

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

Deprecated: Use GetTaskReply.ProtoReflect.Descriptor instead.

func (*GetTaskReply) GetTask 

func (x *GetTaskReply) GetTask() *DownloadTaskInfo

func (*GetTaskReply) ProtoMessage 

func (*GetTaskReply) ProtoMessage()

func (*GetTaskReply) ProtoReflect 

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

func (*GetTaskReply) Reset 

func (x *GetTaskReply) Reset()

func (*GetTaskReply) String 

func (x *GetTaskReply) String() string

type GetTaskRequest 

type GetTaskRequest struct {
	Id      int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	AnimeId string `protobuf:"bytes,2,opt,name=anime_id,json=animeId,proto3" json:"anime_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTaskRequest) Descriptor deprecated 

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

Deprecated: Use GetTaskRequest.ProtoReflect.Descriptor instead.

func (*GetTaskRequest) GetAnimeId 

func (x *GetTaskRequest) GetAnimeId() string

func (*GetTaskRequest) GetId 

func (x *GetTaskRequest) GetId() int32

func (*GetTaskRequest) ProtoMessage 

func (*GetTaskRequest) ProtoMessage()

func (*GetTaskRequest) ProtoReflect 

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

func (*GetTaskRequest) Reset 

func (x *GetTaskRequest) Reset()

func (*GetTaskRequest) String 

func (x *GetTaskRequest) String() string

type ListTaskReply 

type ListTaskReply struct {
	Tasks []*DownloadTaskInfo `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTaskReply) Descriptor deprecated 

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

Deprecated: Use ListTaskReply.ProtoReflect.Descriptor instead.

func (*ListTaskReply) GetTasks 

func (x *ListTaskReply) GetTasks() []*DownloadTaskInfo

func (*ListTaskReply) ProtoMessage 

func (*ListTaskReply) ProtoMessage()

func (*ListTaskReply) ProtoReflect 

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

func (*ListTaskReply) Reset 

func (x *ListTaskReply) Reset()

func (*ListTaskReply) String 

func (x *ListTaskReply) String() string

type ScanTaskAndDownloadReply 

type ScanTaskAndDownloadReply struct {
	CreatedTasks []*DownloadTask `protobuf:"bytes,1,rep,name=created_tasks,json=createdTasks,proto3" json:"created_tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*ScanTaskAndDownloadReply) Descriptor deprecated 

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

Deprecated: Use ScanTaskAndDownloadReply.ProtoReflect.Descriptor instead.

func (*ScanTaskAndDownloadReply) GetCreatedTasks 

func (x *ScanTaskAndDownloadReply) GetCreatedTasks() []*DownloadTask

func (*ScanTaskAndDownloadReply) ProtoMessage 

func (*ScanTaskAndDownloadReply) ProtoMessage()

func (*ScanTaskAndDownloadReply) ProtoReflect 

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

func (*ScanTaskAndDownloadReply) Reset 

func (x *ScanTaskAndDownloadReply) Reset()

func (*ScanTaskAndDownloadReply) String 

func (x *ScanTaskAndDownloadReply) String() string

type ScanTaskReply 

type ScanTaskReply struct {
	MatchedTasks []*DownloadTask `protobuf:"bytes,1,rep,name=matched_tasks,json=matchedTasks,proto3" json:"matched_tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*ScanTaskReply) Descriptor deprecated 

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

Deprecated: Use ScanTaskReply.ProtoReflect.Descriptor instead.

func (*ScanTaskReply) GetMatchedTasks 

func (x *ScanTaskReply) GetMatchedTasks() []*DownloadTask

func (*ScanTaskReply) ProtoMessage 

func (*ScanTaskReply) ProtoMessage()

func (*ScanTaskReply) ProtoReflect 

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

func (*ScanTaskReply) Reset 

func (x *ScanTaskReply) Reset()

func (*ScanTaskReply) String 

func (x *ScanTaskReply) String() string

type UnimplementedDownloadmanagerServer 

type UnimplementedDownloadmanagerServer struct {
}

UnimplementedDownloadmanagerServer must be embedded to have forward compatible implementations.

func (UnimplementedDownloadmanagerServer) AddTask 

func (UnimplementedDownloadmanagerServer) AddTask(context.Context, *AddTaskRequest) (*common.Empty, error)

func (UnimplementedDownloadmanagerServer) DeleteTask 

func (UnimplementedDownloadmanagerServer) DeleteTask(context.Context, *DeleteTaskRequest) (*common.Empty, error)

func (UnimplementedDownloadmanagerServer) GetTask 

func (UnimplementedDownloadmanagerServer) GetTask(context.Context, *GetTaskRequest) (*GetTaskReply, error)

func (UnimplementedDownloadmanagerServer) ListTask 

func (UnimplementedDownloadmanagerServer) ListTask(context.Context, *common.Empty) (*ListTaskReply, error)

func (UnimplementedDownloadmanagerServer) ScanTask 

func (UnimplementedDownloadmanagerServer) ScanTask(context.Context, *common.Empty) (*ScanTaskReply, error)

func (UnimplementedDownloadmanagerServer) ScanTaskAndDownload 

func (UnimplementedDownloadmanagerServer) ScanTaskAndDownload(context.Context, *common.Empty) (*ScanTaskAndDownloadReply, error)

func (UnimplementedDownloadmanagerServer) UpdateTask 

func (UnimplementedDownloadmanagerServer) UpdateTask(context.Context, *UpdateTaskRequest) (*common.Empty, error)

type UnsafeDownloadmanagerServer 

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

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

type UpdateTaskRequest 

type UpdateTaskRequest struct {
	Id            int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name          string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Regexp        string `protobuf:"bytes,3,opt,name=regexp,proto3" json:"regexp,omitempty"`
	LatestChapter int32  `protobuf:"varint,4,opt,name=latest_chapter,json=latestChapter,proto3" json:"latest_chapter,omitempty"`
	StorePath     string `protobuf:"bytes,5,opt,name=store_path,json=storePath,proto3" json:"store_path,omitempty"`
	AnimeId       string `protobuf:"bytes,6,opt,name=anime_id,json=animeId,proto3" json:"anime_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTaskRequest) Descriptor deprecated 

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

Deprecated: Use UpdateTaskRequest.ProtoReflect.Descriptor instead.

func (*UpdateTaskRequest) GetAnimeId 

func (x *UpdateTaskRequest) GetAnimeId() string

func (*UpdateTaskRequest) GetId 

func (x *UpdateTaskRequest) GetId() int32

func (*UpdateTaskRequest) GetLatestChapter 

func (x *UpdateTaskRequest) GetLatestChapter() int32

func (*UpdateTaskRequest) GetName 

func (x *UpdateTaskRequest) GetName() string

func (*UpdateTaskRequest) GetRegexp 

func (x *UpdateTaskRequest) GetRegexp() string

func (*UpdateTaskRequest) GetStorePath 

func (x *UpdateTaskRequest) GetStorePath() string

func (*UpdateTaskRequest) ProtoMessage 

func (*UpdateTaskRequest) ProtoMessage()

func (*UpdateTaskRequest) ProtoReflect 

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

func (*UpdateTaskRequest) Reset 

func (x *UpdateTaskRequest) Reset()

func (*UpdateTaskRequest) String 

func (x *UpdateTaskRequest) 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.