Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterBrowserControllerServer(s grpc.ServiceRegistrar, srv BrowserControllerServer)
- type BrowserControllerClient
- type BrowserControllerServer
- type CompleteResourceReply
- type CompleteResourceRequest
- func (*CompleteResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CompleteResourceRequest) GetCached() bool
- func (x *CompleteResourceRequest) GetCrawlLog() *v11.CrawlLog
- func (x *CompleteResourceRequest) GetProxyId() int32
- func (x *CompleteResourceRequest) GetRequestId() string
- func (*CompleteResourceRequest) ProtoMessage()
- func (x *CompleteResourceRequest) ProtoReflect() protoreflect.Message
- func (x *CompleteResourceRequest) Reset()
- func (x *CompleteResourceRequest) String() string
- type RegisterResourceReply
- func (*RegisterResourceReply) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterResourceReply) GetCancel() string
- func (x *RegisterResourceReply) GetRegistered() *ResourceRegistered
- func (x *RegisterResourceReply) GetResult() isRegisterResourceReply_Result
- func (*RegisterResourceReply) ProtoMessage()
- func (x *RegisterResourceReply) ProtoReflect() protoreflect.Message
- func (x *RegisterResourceReply) Reset()
- func (x *RegisterResourceReply) String() string
- type RegisterResourceReply_Cancel
- type RegisterResourceReply_Registered
- type RegisterResourceRequest
- func (*RegisterResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterResourceRequest) GetCollectionRef() *v1.ConfigRef
- func (x *RegisterResourceRequest) GetCrawlExecutionId() string
- func (x *RegisterResourceRequest) GetJobExecutionId() string
- func (x *RegisterResourceRequest) GetMethod() string
- func (x *RegisterResourceRequest) GetProxyId() int32
- func (x *RegisterResourceRequest) GetRequestId() string
- func (x *RegisterResourceRequest) GetUri() string
- func (*RegisterResourceRequest) ProtoMessage()
- func (x *RegisterResourceRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterResourceRequest) Reset()
- func (x *RegisterResourceRequest) String() string
- type ResourceRegistered
- func (*ResourceRegistered) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceRegistered) GetCollectionRef() *v1.ConfigRef
- func (x *ResourceRegistered) GetCrawlExecutionId() string
- func (x *ResourceRegistered) GetJobExecutionId() string
- func (*ResourceRegistered) ProtoMessage()
- func (x *ResourceRegistered) ProtoReflect() protoreflect.Message
- func (x *ResourceRegistered) Reset()
- func (x *ResourceRegistered) String() string
- type UnimplementedBrowserControllerServer
- type UnsafeBrowserControllerServer
Constants ¶
const ( BrowserController_RegisterResource_FullMethodName = "/veidemann.api.browsercontroller.v2.BrowserController/registerResource" BrowserController_CompleteResource_FullMethodName = "/veidemann.api.browsercontroller.v2.BrowserController/completeResource" )
Variables ¶
var BrowserController_ServiceDesc = grpc.ServiceDesc{ ServiceName: "veidemann.api.browsercontroller.v2.BrowserController", HandlerType: (*BrowserControllerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "registerResource", Handler: _BrowserController_RegisterResource_Handler, }, { MethodName: "completeResource", Handler: _BrowserController_CompleteResource_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "browsercontroller/v2/browsercontroller.proto", }
BrowserController_ServiceDesc is the grpc.ServiceDesc for BrowserController service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_browsercontroller_v2_browsercontroller_proto protoreflect.FileDescriptor
Functions ¶
func RegisterBrowserControllerServer ¶
func RegisterBrowserControllerServer(s grpc.ServiceRegistrar, srv BrowserControllerServer)
Types ¶
type BrowserControllerClient ¶
type BrowserControllerClient interface {
RegisterResource(ctx context.Context, in *RegisterResourceRequest, opts ...grpc.CallOption) (*RegisterResourceReply, error)
CompleteResource(ctx context.Context, in *CompleteResourceRequest, opts ...grpc.CallOption) (*CompleteResourceReply, error)
}
BrowserControllerClient is the client API for BrowserController 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 NewBrowserControllerClient ¶
func NewBrowserControllerClient(cc grpc.ClientConnInterface) BrowserControllerClient
type BrowserControllerServer ¶
type BrowserControllerServer interface {
RegisterResource(context.Context, *RegisterResourceRequest) (*RegisterResourceReply, error)
CompleteResource(context.Context, *CompleteResourceRequest) (*CompleteResourceReply, error)
}
BrowserControllerServer is the server API for BrowserController service. All implementations should embed UnimplementedBrowserControllerServer for forward compatibility.
type CompleteResourceReply ¶
type CompleteResourceReply struct {
// contains filtered or unexported fields
}
func (*CompleteResourceReply) Descriptor
deprecated
func (*CompleteResourceReply) Descriptor() ([]byte, []int)
Deprecated: Use CompleteResourceReply.ProtoReflect.Descriptor instead.
func (*CompleteResourceReply) ProtoMessage ¶
func (*CompleteResourceReply) ProtoMessage()
func (*CompleteResourceReply) ProtoReflect ¶
func (x *CompleteResourceReply) ProtoReflect() protoreflect.Message
func (*CompleteResourceReply) Reset ¶
func (x *CompleteResourceReply) Reset()
func (*CompleteResourceReply) String ¶
func (x *CompleteResourceReply) String() string
type CompleteResourceRequest ¶
type CompleteResourceRequest struct {
ProxyId int32 `protobuf:"varint,1,opt,name=proxy_id,json=proxyId,proto3" json:"proxy_id,omitempty"`
RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
CrawlLog *v11.CrawlLog `protobuf:"bytes,3,opt,name=crawl_log,json=crawlLog,proto3" json:"crawl_log,omitempty"`
Cached bool `protobuf:"varint,4,opt,name=cached,proto3" json:"cached,omitempty"`
// contains filtered or unexported fields
}
func (*CompleteResourceRequest) Descriptor
deprecated
func (*CompleteResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CompleteResourceRequest.ProtoReflect.Descriptor instead.
func (*CompleteResourceRequest) GetCached ¶
func (x *CompleteResourceRequest) GetCached() bool
func (*CompleteResourceRequest) GetCrawlLog ¶
func (x *CompleteResourceRequest) GetCrawlLog() *v11.CrawlLog
func (*CompleteResourceRequest) GetProxyId ¶
func (x *CompleteResourceRequest) GetProxyId() int32
func (*CompleteResourceRequest) GetRequestId ¶
func (x *CompleteResourceRequest) GetRequestId() string
func (*CompleteResourceRequest) ProtoMessage ¶
func (*CompleteResourceRequest) ProtoMessage()
func (*CompleteResourceRequest) ProtoReflect ¶
func (x *CompleteResourceRequest) ProtoReflect() protoreflect.Message
func (*CompleteResourceRequest) Reset ¶
func (x *CompleteResourceRequest) Reset()
func (*CompleteResourceRequest) String ¶
func (x *CompleteResourceRequest) String() string
type RegisterResourceReply ¶
type RegisterResourceReply struct {
// Types that are valid to be assigned to Result:
//
// *RegisterResourceReply_Registered
// *RegisterResourceReply_Cancel
Result isRegisterResourceReply_Result `protobuf_oneof:"result"`
// contains filtered or unexported fields
}
func (*RegisterResourceReply) Descriptor
deprecated
func (*RegisterResourceReply) Descriptor() ([]byte, []int)
Deprecated: Use RegisterResourceReply.ProtoReflect.Descriptor instead.
func (*RegisterResourceReply) GetCancel ¶
func (x *RegisterResourceReply) GetCancel() string
func (*RegisterResourceReply) GetRegistered ¶
func (x *RegisterResourceReply) GetRegistered() *ResourceRegistered
func (*RegisterResourceReply) GetResult ¶
func (x *RegisterResourceReply) GetResult() isRegisterResourceReply_Result
func (*RegisterResourceReply) ProtoMessage ¶
func (*RegisterResourceReply) ProtoMessage()
func (*RegisterResourceReply) ProtoReflect ¶
func (x *RegisterResourceReply) ProtoReflect() protoreflect.Message
func (*RegisterResourceReply) Reset ¶
func (x *RegisterResourceReply) Reset()
func (*RegisterResourceReply) String ¶
func (x *RegisterResourceReply) String() string
type RegisterResourceReply_Cancel ¶
type RegisterResourceReply_Cancel struct {
Cancel string `protobuf:"bytes,2,opt,name=cancel,proto3,oneof"`
}
type RegisterResourceReply_Registered ¶
type RegisterResourceReply_Registered struct {
Registered *ResourceRegistered `protobuf:"bytes,1,opt,name=registered,proto3,oneof"`
}
type RegisterResourceRequest ¶
type RegisterResourceRequest struct {
ProxyId int32 `protobuf:"varint,1,opt,name=proxy_id,json=proxyId,proto3" json:"proxy_id,omitempty"`
Uri string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`
CrawlExecutionId string `protobuf:"bytes,3,opt,name=crawl_execution_id,json=crawlExecutionId,proto3" json:"crawl_execution_id,omitempty"`
JobExecutionId string `protobuf:"bytes,4,opt,name=job_execution_id,json=jobExecutionId,proto3" json:"job_execution_id,omitempty"`
CollectionRef *v1.ConfigRef `protobuf:"bytes,5,opt,name=collection_ref,json=collectionRef,proto3" json:"collection_ref,omitempty"`
Method string `protobuf:"bytes,6,opt,name=method,proto3" json:"method,omitempty"`
RequestId string `protobuf:"bytes,7,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
func (*RegisterResourceRequest) Descriptor
deprecated
func (*RegisterResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterResourceRequest.ProtoReflect.Descriptor instead.
func (*RegisterResourceRequest) GetCollectionRef ¶
func (x *RegisterResourceRequest) GetCollectionRef() *v1.ConfigRef
func (*RegisterResourceRequest) GetCrawlExecutionId ¶
func (x *RegisterResourceRequest) GetCrawlExecutionId() string
func (*RegisterResourceRequest) GetJobExecutionId ¶
func (x *RegisterResourceRequest) GetJobExecutionId() string
func (*RegisterResourceRequest) GetMethod ¶
func (x *RegisterResourceRequest) GetMethod() string
func (*RegisterResourceRequest) GetProxyId ¶
func (x *RegisterResourceRequest) GetProxyId() int32
func (*RegisterResourceRequest) GetRequestId ¶
func (x *RegisterResourceRequest) GetRequestId() string
func (*RegisterResourceRequest) GetUri ¶
func (x *RegisterResourceRequest) GetUri() string
func (*RegisterResourceRequest) ProtoMessage ¶
func (*RegisterResourceRequest) ProtoMessage()
func (*RegisterResourceRequest) ProtoReflect ¶
func (x *RegisterResourceRequest) ProtoReflect() protoreflect.Message
func (*RegisterResourceRequest) Reset ¶
func (x *RegisterResourceRequest) Reset()
func (*RegisterResourceRequest) String ¶
func (x *RegisterResourceRequest) String() string
type ResourceRegistered ¶
type ResourceRegistered struct {
CrawlExecutionId string `protobuf:"bytes,1,opt,name=crawl_execution_id,json=crawlExecutionId,proto3" json:"crawl_execution_id,omitempty"`
JobExecutionId string `protobuf:"bytes,2,opt,name=job_execution_id,json=jobExecutionId,proto3" json:"job_execution_id,omitempty"`
CollectionRef *v1.ConfigRef `protobuf:"bytes,3,opt,name=collection_ref,json=collectionRef,proto3" json:"collection_ref,omitempty"`
// contains filtered or unexported fields
}
func (*ResourceRegistered) Descriptor
deprecated
func (*ResourceRegistered) Descriptor() ([]byte, []int)
Deprecated: Use ResourceRegistered.ProtoReflect.Descriptor instead.
func (*ResourceRegistered) GetCollectionRef ¶
func (x *ResourceRegistered) GetCollectionRef() *v1.ConfigRef
func (*ResourceRegistered) GetCrawlExecutionId ¶
func (x *ResourceRegistered) GetCrawlExecutionId() string
func (*ResourceRegistered) GetJobExecutionId ¶
func (x *ResourceRegistered) GetJobExecutionId() string
func (*ResourceRegistered) ProtoMessage ¶
func (*ResourceRegistered) ProtoMessage()
func (*ResourceRegistered) ProtoReflect ¶
func (x *ResourceRegistered) ProtoReflect() protoreflect.Message
func (*ResourceRegistered) Reset ¶
func (x *ResourceRegistered) Reset()
func (*ResourceRegistered) String ¶
func (x *ResourceRegistered) String() string
type UnimplementedBrowserControllerServer ¶
type UnimplementedBrowserControllerServer struct{}
UnimplementedBrowserControllerServer should be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedBrowserControllerServer) CompleteResource ¶
func (UnimplementedBrowserControllerServer) CompleteResource(context.Context, *CompleteResourceRequest) (*CompleteResourceReply, error)
func (UnimplementedBrowserControllerServer) RegisterResource ¶
func (UnimplementedBrowserControllerServer) RegisterResource(context.Context, *RegisterResourceRequest) (*RegisterResourceReply, error)
type UnsafeBrowserControllerServer ¶
type UnsafeBrowserControllerServer interface {
// contains filtered or unexported methods
}
UnsafeBrowserControllerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BrowserControllerServer will result in compilation errors.