browsercontroller

package
v1.0.0-beta9 Latest Latest
Warning

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

Go to latest
Published: May 28, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

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 BrowserController_DoClient

type BrowserController_DoClient interface {
	Send(*DoRequest) error
	Recv() (*DoReply, error)
	grpc.ClientStream
}

type BrowserController_DoServer

type BrowserController_DoServer interface {
	Send(*DoReply) error
	Recv() (*DoRequest, error)
	grpc.ServerStream
}

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) Descriptor() ([]byte, []int)

func (*Completed) GetCrawlLog

func (m *Completed) GetCrawlLog() *v11.CrawlLog

func (*Completed) ProtoMessage

func (*Completed) ProtoMessage()

func (*Completed) Reset

func (m *Completed) Reset()

func (*Completed) String

func (m *Completed) String() string

func (*Completed) XXX_DiscardUnknown

func (m *Completed) XXX_DiscardUnknown()

func (*Completed) XXX_Marshal

func (m *Completed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Completed) XXX_Merge

func (m *Completed) XXX_Merge(src proto.Message)

func (*Completed) XXX_Size

func (m *Completed) XXX_Size() int

func (*Completed) XXX_Unmarshal

func (m *Completed) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*DoReply) GetAction

func (m *DoReply) GetAction() isDoReply_Action

func (*DoReply) GetCancel

func (m *DoReply) GetCancel() string

func (*DoReply) GetNew

func (m *DoReply) GetNew() *NewReply

func (*DoReply) ProtoMessage

func (*DoReply) ProtoMessage()

func (*DoReply) Reset

func (m *DoReply) Reset()

func (*DoReply) String

func (m *DoReply) String() string

func (*DoReply) XXX_DiscardUnknown

func (m *DoReply) XXX_DiscardUnknown()

func (*DoReply) XXX_Marshal

func (m *DoReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DoReply) XXX_Merge

func (m *DoReply) XXX_Merge(src proto.Message)

func (*DoReply) XXX_OneofWrappers

func (*DoReply) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*DoReply) XXX_Size

func (m *DoReply) XXX_Size() int

func (*DoReply) XXX_Unmarshal

func (m *DoReply) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*DoRequest) GetAction

func (m *DoRequest) GetAction() isDoRequest_Action

func (*DoRequest) GetCompleted

func (m *DoRequest) GetCompleted() *Completed

func (*DoRequest) GetNew

func (m *DoRequest) GetNew() *RegisterNew

func (*DoRequest) GetNotify

func (m *DoRequest) GetNotify() *NotifyActivity

func (*DoRequest) ProtoMessage

func (*DoRequest) ProtoMessage()

func (*DoRequest) Reset

func (m *DoRequest) Reset()

func (*DoRequest) String

func (m *DoRequest) String() string

func (*DoRequest) XXX_DiscardUnknown

func (m *DoRequest) XXX_DiscardUnknown()

func (*DoRequest) XXX_Marshal

func (m *DoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DoRequest) XXX_Merge

func (m *DoRequest) XXX_Merge(src proto.Message)

func (*DoRequest) XXX_OneofWrappers

func (*DoRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*DoRequest) XXX_Size

func (m *DoRequest) XXX_Size() int

func (*DoRequest) XXX_Unmarshal

func (m *DoRequest) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*NewReply) GetCollectionRef

func (m *NewReply) GetCollectionRef() *v1.ConfigRef

func (*NewReply) GetCrawlExecutionId

func (m *NewReply) GetCrawlExecutionId() string

func (*NewReply) GetJobExecutionId

func (m *NewReply) GetJobExecutionId() string

func (*NewReply) GetReplacementScript

func (m *NewReply) GetReplacementScript() *v1.BrowserScript

func (*NewReply) ProtoMessage

func (*NewReply) ProtoMessage()

func (*NewReply) Reset

func (m *NewReply) Reset()

func (*NewReply) String

func (m *NewReply) String() string

func (*NewReply) XXX_DiscardUnknown

func (m *NewReply) XXX_DiscardUnknown()

func (*NewReply) XXX_Marshal

func (m *NewReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewReply) XXX_Merge

func (m *NewReply) XXX_Merge(src proto.Message)

func (*NewReply) XXX_Size

func (m *NewReply) XXX_Size() int

func (*NewReply) XXX_Unmarshal

func (m *NewReply) XXX_Unmarshal(b []byte) error

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL