Documentation ¶
Index ¶
- Variables
- func RegisterBrowserControllerServer(s *grpc.Server, srv BrowserControllerServer)
- type BrowserControllerClient
- type BrowserControllerServer
- type BrowserController_DoClient
- type BrowserController_DoServer
- type Completed
- func (*Completed) Descriptor() ([]byte, []int)
- func (m *Completed) GetCrawlLog() *v11.CrawlLog
- func (*Completed) ProtoMessage()
- func (m *Completed) Reset()
- func (m *Completed) String() string
- func (m *Completed) XXX_DiscardUnknown()
- func (m *Completed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Completed) XXX_Merge(src proto.Message)
- func (m *Completed) XXX_Size() int
- func (m *Completed) XXX_Unmarshal(b []byte) error
- type DoReply
- func (*DoReply) Descriptor() ([]byte, []int)
- func (m *DoReply) GetAction() isDoReply_Action
- func (m *DoReply) GetCancel() string
- func (m *DoReply) GetNew() *NewReply
- func (*DoReply) ProtoMessage()
- func (m *DoReply) Reset()
- func (m *DoReply) String() string
- func (m *DoReply) XXX_DiscardUnknown()
- func (m *DoReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DoReply) XXX_Merge(src proto.Message)
- func (*DoReply) XXX_OneofWrappers() []interface{}
- func (m *DoReply) XXX_Size() int
- func (m *DoReply) XXX_Unmarshal(b []byte) error
- type DoReply_Cancel
- type DoReply_New
- type DoRequest
- func (*DoRequest) Descriptor() ([]byte, []int)
- func (m *DoRequest) GetAction() isDoRequest_Action
- func (m *DoRequest) GetCompleted() *Completed
- func (m *DoRequest) GetNew() *RegisterNew
- func (m *DoRequest) GetNotify() *NotifyActivity
- func (*DoRequest) ProtoMessage()
- func (m *DoRequest) Reset()
- func (m *DoRequest) String() string
- func (m *DoRequest) XXX_DiscardUnknown()
- func (m *DoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DoRequest) XXX_Merge(src proto.Message)
- func (*DoRequest) XXX_OneofWrappers() []interface{}
- func (m *DoRequest) XXX_Size() int
- func (m *DoRequest) XXX_Unmarshal(b []byte) error
- type DoRequest_Completed
- type DoRequest_New
- type DoRequest_Notify
- type NewReply
- func (*NewReply) Descriptor() ([]byte, []int)
- func (m *NewReply) GetCollectionRef() *v1.ConfigRef
- func (m *NewReply) GetCrawlExecutionId() string
- func (m *NewReply) GetJobExecutionId() string
- func (m *NewReply) GetReplacementScript() *v1.BrowserScript
- func (*NewReply) ProtoMessage()
- func (m *NewReply) Reset()
- func (m *NewReply) String() string
- func (m *NewReply) XXX_DiscardUnknown()
- func (m *NewReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NewReply) XXX_Merge(src proto.Message)
- func (m *NewReply) XXX_Size() int
- func (m *NewReply) XXX_Unmarshal(b []byte) error
- type NotifyActivity
- func (*NotifyActivity) Descriptor() ([]byte, []int)
- func (m *NotifyActivity) GetActivity() NotifyActivity_Activity
- func (*NotifyActivity) ProtoMessage()
- func (m *NotifyActivity) Reset()
- func (m *NotifyActivity) String() string
- func (m *NotifyActivity) XXX_DiscardUnknown()
- func (m *NotifyActivity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NotifyActivity) XXX_Merge(src proto.Message)
- func (m *NotifyActivity) XXX_Size() int
- func (m *NotifyActivity) XXX_Unmarshal(b []byte) error
- type NotifyActivity_Activity
- type RegisterNew
- func (*RegisterNew) Descriptor() ([]byte, []int)
- func (m *RegisterNew) GetCollectionRef() *v1.ConfigRef
- func (m *RegisterNew) GetCrawlExecutionId() string
- func (m *RegisterNew) GetJobExecutionId() string
- func (m *RegisterNew) GetProxyId() int32
- func (m *RegisterNew) GetUri() string
- func (*RegisterNew) ProtoMessage()
- func (m *RegisterNew) Reset()
- func (m *RegisterNew) String() string
- func (m *RegisterNew) XXX_DiscardUnknown()
- func (m *RegisterNew) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterNew) XXX_Merge(src proto.Message)
- func (m *RegisterNew) XXX_Size() int
- func (m *RegisterNew) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var NotifyActivity_Activity_name = map[int32]string{
0: "DATA_RECEIVED",
1: "ALL_DATA_RECEIVED",
}
View Source
var NotifyActivity_Activity_value = map[string]int32{
"DATA_RECEIVED": 0,
"ALL_DATA_RECEIVED": 1,
}
Functions ¶
func RegisterBrowserControllerServer ¶
func RegisterBrowserControllerServer(s *grpc.Server, srv BrowserControllerServer)
Types ¶
type BrowserControllerClient ¶
type BrowserControllerClient interface {
Do(ctx context.Context, opts ...grpc.CallOption) (BrowserController_DoClient, error)
}
BrowserControllerClient is the client API for BrowserController service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewBrowserControllerClient ¶
func NewBrowserControllerClient(cc *grpc.ClientConn) BrowserControllerClient
type BrowserControllerServer ¶
type BrowserControllerServer interface {
Do(BrowserController_DoServer) error
}
BrowserControllerServer is the server API for BrowserController service.
type Completed ¶
type Completed struct { CrawlLog *v11.CrawlLog `protobuf:"bytes,1,opt,name=crawl_log,json=crawlLog,proto3" json:"crawl_log,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Completed) Descriptor ¶
func (*Completed) GetCrawlLog ¶
func (*Completed) ProtoMessage ¶
func (*Completed) ProtoMessage()
func (*Completed) XXX_DiscardUnknown ¶
func (m *Completed) XXX_DiscardUnknown()
func (*Completed) XXX_Marshal ¶
func (*Completed) XXX_Unmarshal ¶
type DoReply ¶
type DoReply struct { // Types that are valid to be assigned to Action: // *DoReply_New // *DoReply_Cancel Action isDoReply_Action `protobuf_oneof:"action"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DoReply) Descriptor ¶
func (*DoReply) ProtoMessage ¶
func (*DoReply) ProtoMessage()
func (*DoReply) XXX_DiscardUnknown ¶
func (m *DoReply) XXX_DiscardUnknown()
func (*DoReply) XXX_Marshal ¶
func (*DoReply) XXX_OneofWrappers ¶
func (*DoReply) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*DoReply) XXX_Unmarshal ¶
type DoReply_Cancel ¶
type DoReply_Cancel struct {
Cancel string `protobuf:"bytes,4,opt,name=cancel,proto3,oneof"`
}
type DoReply_New ¶
type DoReply_New struct {
New *NewReply `protobuf:"bytes,1,opt,name=new,proto3,oneof"`
}
type DoRequest ¶
type DoRequest struct { // Types that are valid to be assigned to Action: // *DoRequest_New // *DoRequest_Notify // *DoRequest_Completed Action isDoRequest_Action `protobuf_oneof:"action"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DoRequest) Descriptor ¶
func (*DoRequest) GetCompleted ¶
func (*DoRequest) GetNew ¶
func (m *DoRequest) GetNew() *RegisterNew
func (*DoRequest) GetNotify ¶
func (m *DoRequest) GetNotify() *NotifyActivity
func (*DoRequest) ProtoMessage ¶
func (*DoRequest) ProtoMessage()
func (*DoRequest) XXX_DiscardUnknown ¶
func (m *DoRequest) XXX_DiscardUnknown()
func (*DoRequest) XXX_Marshal ¶
func (*DoRequest) XXX_OneofWrappers ¶
func (*DoRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*DoRequest) XXX_Unmarshal ¶
type DoRequest_Completed ¶
type DoRequest_Completed struct {
Completed *Completed `protobuf:"bytes,3,opt,name=completed,proto3,oneof"`
}
type DoRequest_New ¶
type DoRequest_New struct {
New *RegisterNew `protobuf:"bytes,1,opt,name=new,proto3,oneof"`
}
type DoRequest_Notify ¶
type DoRequest_Notify struct {
Notify *NotifyActivity `protobuf:"bytes,2,opt,name=notify,proto3,oneof"`
}
type NewReply ¶
type NewReply 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,4,opt,name=collection_ref,json=collectionRef,proto3" json:"collection_ref,omitempty"` ReplacementScript *v1.BrowserScript `protobuf:"bytes,5,opt,name=replacement_script,json=replacementScript,proto3" json:"replacement_script,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NewReply) Descriptor ¶
func (*NewReply) GetCollectionRef ¶
func (*NewReply) GetCrawlExecutionId ¶
func (*NewReply) GetJobExecutionId ¶
func (*NewReply) GetReplacementScript ¶
func (m *NewReply) GetReplacementScript() *v1.BrowserScript
func (*NewReply) ProtoMessage ¶
func (*NewReply) ProtoMessage()
func (*NewReply) XXX_DiscardUnknown ¶
func (m *NewReply) XXX_DiscardUnknown()
func (*NewReply) XXX_Marshal ¶
func (*NewReply) XXX_Unmarshal ¶
type NotifyActivity ¶
type NotifyActivity struct { Activity NotifyActivity_Activity `` /* 134-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NotifyActivity) Descriptor ¶
func (*NotifyActivity) Descriptor() ([]byte, []int)
func (*NotifyActivity) GetActivity ¶
func (m *NotifyActivity) GetActivity() NotifyActivity_Activity
func (*NotifyActivity) ProtoMessage ¶
func (*NotifyActivity) ProtoMessage()
func (*NotifyActivity) Reset ¶
func (m *NotifyActivity) Reset()
func (*NotifyActivity) String ¶
func (m *NotifyActivity) String() string
func (*NotifyActivity) XXX_DiscardUnknown ¶
func (m *NotifyActivity) XXX_DiscardUnknown()
func (*NotifyActivity) XXX_Marshal ¶
func (m *NotifyActivity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NotifyActivity) XXX_Merge ¶
func (m *NotifyActivity) XXX_Merge(src proto.Message)
func (*NotifyActivity) XXX_Size ¶
func (m *NotifyActivity) XXX_Size() int
func (*NotifyActivity) XXX_Unmarshal ¶
func (m *NotifyActivity) XXX_Unmarshal(b []byte) error
type NotifyActivity_Activity ¶
type NotifyActivity_Activity int32
const ( NotifyActivity_DATA_RECEIVED NotifyActivity_Activity = 0 NotifyActivity_ALL_DATA_RECEIVED NotifyActivity_Activity = 1 )
func (NotifyActivity_Activity) EnumDescriptor ¶
func (NotifyActivity_Activity) EnumDescriptor() ([]byte, []int)
func (NotifyActivity_Activity) String ¶
func (x NotifyActivity_Activity) String() string
type RegisterNew ¶
type RegisterNew 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RegisterNew) Descriptor ¶
func (*RegisterNew) Descriptor() ([]byte, []int)
func (*RegisterNew) GetCollectionRef ¶
func (m *RegisterNew) GetCollectionRef() *v1.ConfigRef
func (*RegisterNew) GetCrawlExecutionId ¶
func (m *RegisterNew) GetCrawlExecutionId() string
func (*RegisterNew) GetJobExecutionId ¶
func (m *RegisterNew) GetJobExecutionId() string
func (*RegisterNew) GetProxyId ¶
func (m *RegisterNew) GetProxyId() int32
func (*RegisterNew) GetUri ¶
func (m *RegisterNew) GetUri() string
func (*RegisterNew) ProtoMessage ¶
func (*RegisterNew) ProtoMessage()
func (*RegisterNew) Reset ¶
func (m *RegisterNew) Reset()
func (*RegisterNew) String ¶
func (m *RegisterNew) String() string
func (*RegisterNew) XXX_DiscardUnknown ¶
func (m *RegisterNew) XXX_DiscardUnknown()
func (*RegisterNew) XXX_Marshal ¶
func (m *RegisterNew) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterNew) XXX_Merge ¶
func (m *RegisterNew) XXX_Merge(src proto.Message)
func (*RegisterNew) XXX_Size ¶
func (m *RegisterNew) XXX_Size() int
func (*RegisterNew) XXX_Unmarshal ¶
func (m *RegisterNew) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.