tasks

package
v0.0.6 Latest Latest
Warning

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

 Go to latest Published: Jun 23, 2022 License: BSD-3-Clause Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_tasks_proto protoreflect.FileDescriptor
View Source 
var TasksService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "krang.TasksService",
	HandlerType: (*TasksServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CompleteTask",
			Handler:    _TasksService_CompleteTask_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "tasks.proto",
}

TasksService_ServiceDesc is the grpc.ServiceDesc for TasksService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTasksServiceServer 

func RegisterTasksServiceServer(s grpc.ServiceRegistrar, srv TasksServiceServer)

Types

type CompleteRequest 

type CompleteRequest struct {
	Id         string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ScrapeId   string  `protobuf:"bytes,2,opt,name=scrape_id,json=scrapeId,proto3" json:"scrape_id,omitempty"`
	Url        string  `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	GroupSlug  string  `protobuf:"bytes,4,opt,name=group_slug,json=groupSlug,proto3" json:"group_slug,omitempty"`
	TaskId     int64   `protobuf:"varint,5,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	SearchTerm string  `protobuf:"bytes,6,opt,name=search_term,json=searchTerm,proto3" json:"search_term,omitempty"`
	Scrape     *Scrape `protobuf:"bytes,7,opt,name=scrape,proto3" json:"scrape,omitempty"`
	// contains filtered or unexported fields
}

func (*CompleteRequest) Descriptor deprecated 

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

Deprecated: Use CompleteRequest.ProtoReflect.Descriptor instead.

func (*CompleteRequest) GetGroupSlug 

func (x *CompleteRequest) GetGroupSlug() string

func (*CompleteRequest) GetId 

func (x *CompleteRequest) GetId() string

func (*CompleteRequest) GetScrape 

func (x *CompleteRequest) GetScrape() *Scrape

func (*CompleteRequest) GetScrapeId 

func (x *CompleteRequest) GetScrapeId() string

func (*CompleteRequest) GetSearchTerm 

func (x *CompleteRequest) GetSearchTerm() string

func (*CompleteRequest) GetTaskId 

func (x *CompleteRequest) GetTaskId() int64

func (*CompleteRequest) GetUrl 

func (x *CompleteRequest) GetUrl() string

func (*CompleteRequest) ProtoMessage 

func (*CompleteRequest) ProtoMessage()

func (*CompleteRequest) ProtoReflect 

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

func (*CompleteRequest) Reset 

func (x *CompleteRequest) Reset()

func (*CompleteRequest) String 

func (x *CompleteRequest) String() string

type Content 

type Content struct {
	H1            string `protobuf:"bytes,1,opt,name=h1,proto3" json:"h1,omitempty"`
	H2            string `protobuf:"bytes,2,opt,name=h2,proto3" json:"h2,omitempty"`
	Title         string `protobuf:"bytes,3,opt,name=title,proto3" json:"title,omitempty"`
	ExternalLinks string `protobuf:"bytes,4,opt,name=external_links,json=externalLinks,proto3" json:"external_links,omitempty"`
	Body          string `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*Content) Descriptor deprecated 

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

Deprecated: Use Content.ProtoReflect.Descriptor instead.

func (*Content) GetBody 

func (x *Content) GetBody() string
func (x *Content) GetExternalLinks() string

func (*Content) GetH1 

func (x *Content) GetH1() string

func (*Content) GetH2 

func (x *Content) GetH2() string

func (*Content) GetTitle 

func (x *Content) GetTitle() string

func (*Content) ProtoMessage 

func (*Content) ProtoMessage()

func (*Content) ProtoReflect 

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

func (*Content) Reset 

func (x *Content) Reset()

func (*Content) String 

func (x *Content) String() string

type Metrics 

type Metrics struct {
	Backlinks    string `protobuf:"bytes,1,opt,name=backlinks,proto3" json:"backlinks,omitempty"`
	LoadingTime  string `protobuf:"bytes,2,opt,name=loading_time,json=loadingTime,proto3" json:"loading_time,omitempty"`
	AhrefsDa     int64  `protobuf:"varint,3,opt,name=ahrefs_da,json=ahrefsDa,proto3" json:"ahrefs_da,omitempty"`
	MozPa        int64  `protobuf:"varint,4,opt,name=moz_pa,json=mozPa,proto3" json:"moz_pa,omitempty"`
	MozDa        int64  `protobuf:"varint,5,opt,name=moz_da,json=mozDa,proto3" json:"moz_da,omitempty"`
	MozSpamScore int64  `protobuf:"varint,6,opt,name=moz_spam_score,json=mozSpamScore,proto3" json:"moz_spam_score,omitempty"`
	MajesticCf   int64  `protobuf:"varint,7,opt,name=majestic_cf,json=majesticCf,proto3" json:"majestic_cf,omitempty"`
	MajesticTf   int64  `protobuf:"varint,8,opt,name=majestic_tf,json=majesticTf,proto3" json:"majestic_tf,omitempty"`
	// contains filtered or unexported fields
}

func (*Metrics) Descriptor deprecated 

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

Deprecated: Use Metrics.ProtoReflect.Descriptor instead.

func (*Metrics) GetAhrefsDa 

func (x *Metrics) GetAhrefsDa() int64
func (x *Metrics) GetBacklinks() string

func (*Metrics) GetLoadingTime 

func (x *Metrics) GetLoadingTime() string

func (*Metrics) GetMajesticCf 

func (x *Metrics) GetMajesticCf() int64

func (*Metrics) GetMajesticTf 

func (x *Metrics) GetMajesticTf() int64

func (*Metrics) GetMozDa 

func (x *Metrics) GetMozDa() int64

func (*Metrics) GetMozPa 

func (x *Metrics) GetMozPa() int64

func (*Metrics) GetMozSpamScore 

func (x *Metrics) GetMozSpamScore() int64

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) ProtoReflect 

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

func (*Metrics) Reset 

func (x *Metrics) Reset()

func (*Metrics) String 

func (x *Metrics) String() string

type Response 

type Response struct {
	Error   bool   `protobuf:"varint,2,opt,name=error,proto3" json:"error,omitempty"`
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetError 

func (x *Response) GetError() bool

func (*Response) GetMessage 

func (x *Response) GetMessage() string

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type Scrape 

type Scrape struct {
	Id         string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Url        string   `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	HttpStatus int64    `protobuf:"varint,3,opt,name=http_status,json=httpStatus,proto3" json:"http_status,omitempty"`
	Content    *Content `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	Metrics    *Metrics `protobuf:"bytes,5,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*Scrape) Descriptor deprecated 

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

Deprecated: Use Scrape.ProtoReflect.Descriptor instead.

func (*Scrape) GetContent 

func (x *Scrape) GetContent() *Content

func (*Scrape) GetHttpStatus 

func (x *Scrape) GetHttpStatus() int64

func (*Scrape) GetId 

func (x *Scrape) GetId() string

func (*Scrape) GetMetrics 

func (x *Scrape) GetMetrics() *Metrics

func (*Scrape) GetUrl 

func (x *Scrape) GetUrl() string

func (*Scrape) ProtoMessage 

func (*Scrape) ProtoMessage()

func (*Scrape) ProtoReflect 

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

func (*Scrape) Reset 

func (x *Scrape) Reset()

func (*Scrape) String 

func (x *Scrape) String() string

type TasksServiceClient 

type TasksServiceClient interface {
	CompleteTask(ctx context.Context, in *CompleteRequest, opts ...grpc.CallOption) (*Response, error)
}

TasksServiceClient is the client API for TasksService 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 NewTasksServiceClient 

func NewTasksServiceClient(cc grpc.ClientConnInterface) TasksServiceClient

type TasksServiceServer 

type TasksServiceServer interface {
	CompleteTask(context.Context, *CompleteRequest) (*Response, error)
	// contains filtered or unexported methods
}

TasksServiceServer is the server API for TasksService service. All implementations must embed UnimplementedTasksServiceServer for forward compatibility

type UnimplementedTasksServiceServer 

type UnimplementedTasksServiceServer struct {
}

UnimplementedTasksServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTasksServiceServer) CompleteTask 

func (UnimplementedTasksServiceServer) CompleteTask(context.Context, *CompleteRequest) (*Response, error)

type UnsafeTasksServiceServer 

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

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

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.