Documentation ¶
Index ¶
- Variables
- func RegisterControllerServer(s *grpc.Server, srv ControllerServer)
- func RegisterReportServer(s *grpc.Server, srv ReportServer)
- func RegisterStatusServer(s *grpc.Server, srv StatusServer)
- type AbortCrawlRequest
- func (*AbortCrawlRequest) Descriptor() ([]byte, []int)
- func (m *AbortCrawlRequest) GetId() string
- func (*AbortCrawlRequest) ProtoMessage()
- func (m *AbortCrawlRequest) Reset()
- func (m *AbortCrawlRequest) String() string
- func (m *AbortCrawlRequest) XXX_DiscardUnknown()
- func (m *AbortCrawlRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AbortCrawlRequest) XXX_Merge(src proto.Message)
- func (m *AbortCrawlRequest) XXX_Size() int
- func (m *AbortCrawlRequest) XXX_Unmarshal(b []byte) error
- type BrowserConfigdeprecated
- func (*BrowserConfig) Descriptor() ([]byte, []int)
- func (m *BrowserConfig) GetHeaders() map[string]string
- func (m *BrowserConfig) GetId() string
- func (m *BrowserConfig) GetMeta() *Meta
- func (m *BrowserConfig) GetPageLoadTimeoutMs() int64
- func (m *BrowserConfig) GetScriptId() []string
- func (m *BrowserConfig) GetScriptParameters() map[string]string
- func (m *BrowserConfig) GetScriptSelector() []string
- func (m *BrowserConfig) GetSleepAfterPageloadMs() int64
- func (m *BrowserConfig) GetUserAgent() string
- func (m *BrowserConfig) GetWindowHeight() int32
- func (m *BrowserConfig) GetWindowWidth() int32
- func (*BrowserConfig) ProtoMessage()
- func (m *BrowserConfig) Reset()
- func (m *BrowserConfig) String() string
- func (m *BrowserConfig) XXX_DiscardUnknown()
- func (m *BrowserConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BrowserConfig) XXX_Merge(src proto.Message)
- func (m *BrowserConfig) XXX_Size() int
- func (m *BrowserConfig) XXX_Unmarshal(b []byte) error
- type BrowserConfigListReplydeprecated
- func (*BrowserConfigListReply) Descriptor() ([]byte, []int)
- func (m *BrowserConfigListReply) GetCount() int64
- func (m *BrowserConfigListReply) GetPage() int32
- func (m *BrowserConfigListReply) GetPageSize() int32
- func (m *BrowserConfigListReply) GetValue() []*BrowserConfig
- func (*BrowserConfigListReply) ProtoMessage()
- func (m *BrowserConfigListReply) Reset()
- func (m *BrowserConfigListReply) String() string
- func (m *BrowserConfigListReply) XXX_DiscardUnknown()
- func (m *BrowserConfigListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BrowserConfigListReply) XXX_Merge(src proto.Message)
- func (m *BrowserConfigListReply) XXX_Size() int
- func (m *BrowserConfigListReply) XXX_Unmarshal(b []byte) error
- type BrowserScriptdeprecated
- func (*BrowserScript) Descriptor() ([]byte, []int)
- func (m *BrowserScript) GetId() string
- func (m *BrowserScript) GetMeta() *Meta
- func (m *BrowserScript) GetScript() string
- func (m *BrowserScript) GetUrlRegexp() string
- func (*BrowserScript) ProtoMessage()
- func (m *BrowserScript) Reset()
- func (m *BrowserScript) String() string
- func (m *BrowserScript) XXX_DiscardUnknown()
- func (m *BrowserScript) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BrowserScript) XXX_Merge(src proto.Message)
- func (m *BrowserScript) XXX_Size() int
- func (m *BrowserScript) XXX_Unmarshal(b []byte) error
- type BrowserScriptListReplydeprecated
- func (*BrowserScriptListReply) Descriptor() ([]byte, []int)
- func (m *BrowserScriptListReply) GetCount() int64
- func (m *BrowserScriptListReply) GetPage() int32
- func (m *BrowserScriptListReply) GetPageSize() int32
- func (m *BrowserScriptListReply) GetValue() []*BrowserScript
- func (*BrowserScriptListReply) ProtoMessage()
- func (m *BrowserScriptListReply) Reset()
- func (m *BrowserScriptListReply) String() string
- func (m *BrowserScriptListReply) XXX_DiscardUnknown()
- func (m *BrowserScriptListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BrowserScriptListReply) XXX_Merge(src proto.Message)
- func (m *BrowserScriptListReply) XXX_Size() int
- func (m *BrowserScriptListReply) XXX_Unmarshal(b []byte) error
- type ControllerClient
- type ControllerServer
- type CrawlConfigdeprecated
- func (*CrawlConfig) Descriptor() ([]byte, []int)
- func (m *CrawlConfig) GetBrowserConfigId() string
- func (m *CrawlConfig) GetDepthFirst() bool
- func (m *CrawlConfig) GetExtra() *ExtraConfig
- func (m *CrawlConfig) GetId() string
- func (m *CrawlConfig) GetMeta() *Meta
- func (m *CrawlConfig) GetMinimumDnsTtlS() int32
- func (m *CrawlConfig) GetPolitenessId() string
- func (m *CrawlConfig) GetPriorityWeight() float64
- func (*CrawlConfig) ProtoMessage()
- func (m *CrawlConfig) Reset()
- func (m *CrawlConfig) String() string
- func (m *CrawlConfig) XXX_DiscardUnknown()
- func (m *CrawlConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrawlConfig) XXX_Merge(src proto.Message)
- func (m *CrawlConfig) XXX_Size() int
- func (m *CrawlConfig) XXX_Unmarshal(b []byte) error
- type CrawlConfigListReplydeprecated
- func (*CrawlConfigListReply) Descriptor() ([]byte, []int)
- func (m *CrawlConfigListReply) GetCount() int64
- func (m *CrawlConfigListReply) GetPage() int32
- func (m *CrawlConfigListReply) GetPageSize() int32
- func (m *CrawlConfigListReply) GetValue() []*CrawlConfig
- func (*CrawlConfigListReply) ProtoMessage()
- func (m *CrawlConfigListReply) Reset()
- func (m *CrawlConfigListReply) String() string
- func (m *CrawlConfigListReply) XXX_DiscardUnknown()
- func (m *CrawlConfigListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrawlConfigListReply) XXX_Merge(src proto.Message)
- func (m *CrawlConfigListReply) XXX_Size() int
- func (m *CrawlConfigListReply) XXX_Unmarshal(b []byte) error
- type CrawlEntitydeprecated
- func (*CrawlEntity) Descriptor() ([]byte, []int)
- func (m *CrawlEntity) GetId() string
- func (m *CrawlEntity) GetMeta() *Meta
- func (*CrawlEntity) ProtoMessage()
- func (m *CrawlEntity) Reset()
- func (m *CrawlEntity) String() string
- func (m *CrawlEntity) XXX_DiscardUnknown()
- func (m *CrawlEntity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrawlEntity) XXX_Merge(src proto.Message)
- func (m *CrawlEntity) XXX_Size() int
- func (m *CrawlEntity) XXX_Unmarshal(b []byte) error
- type CrawlEntityListReplydeprecated
- func (*CrawlEntityListReply) Descriptor() ([]byte, []int)
- func (m *CrawlEntityListReply) GetCount() int64
- func (m *CrawlEntityListReply) GetPage() int32
- func (m *CrawlEntityListReply) GetPageSize() int32
- func (m *CrawlEntityListReply) GetValue() []*CrawlEntity
- func (*CrawlEntityListReply) ProtoMessage()
- func (m *CrawlEntityListReply) Reset()
- func (m *CrawlEntityListReply) String() string
- func (m *CrawlEntityListReply) XXX_DiscardUnknown()
- func (m *CrawlEntityListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrawlEntityListReply) XXX_Merge(src proto.Message)
- func (m *CrawlEntityListReply) XXX_Size() int
- func (m *CrawlEntityListReply) XXX_Unmarshal(b []byte) error
- type CrawlHostGroupConfigdeprecated
- func (*CrawlHostGroupConfig) Descriptor() ([]byte, []int)
- func (m *CrawlHostGroupConfig) GetId() string
- func (m *CrawlHostGroupConfig) GetIpRange() []*CrawlHostGroupConfig_IpRange
- func (m *CrawlHostGroupConfig) GetMeta() *Meta
- func (*CrawlHostGroupConfig) ProtoMessage()
- func (m *CrawlHostGroupConfig) Reset()
- func (m *CrawlHostGroupConfig) String() string
- func (m *CrawlHostGroupConfig) XXX_DiscardUnknown()
- func (m *CrawlHostGroupConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrawlHostGroupConfig) XXX_Merge(src proto.Message)
- func (m *CrawlHostGroupConfig) XXX_Size() int
- func (m *CrawlHostGroupConfig) XXX_Unmarshal(b []byte) error
- type CrawlHostGroupConfigListReplydeprecated
- func (*CrawlHostGroupConfigListReply) Descriptor() ([]byte, []int)
- func (m *CrawlHostGroupConfigListReply) GetCount() int64
- func (m *CrawlHostGroupConfigListReply) GetPage() int32
- func (m *CrawlHostGroupConfigListReply) GetPageSize() int32
- func (m *CrawlHostGroupConfigListReply) GetValue() []*CrawlHostGroupConfig
- func (*CrawlHostGroupConfigListReply) ProtoMessage()
- func (m *CrawlHostGroupConfigListReply) Reset()
- func (m *CrawlHostGroupConfigListReply) String() string
- func (m *CrawlHostGroupConfigListReply) XXX_DiscardUnknown()
- func (m *CrawlHostGroupConfigListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrawlHostGroupConfigListReply) XXX_Merge(src proto.Message)
- func (m *CrawlHostGroupConfigListReply) XXX_Size() int
- func (m *CrawlHostGroupConfigListReply) XXX_Unmarshal(b []byte) error
- type CrawlHostGroupConfig_IpRange
- func (*CrawlHostGroupConfig_IpRange) Descriptor() ([]byte, []int)
- func (m *CrawlHostGroupConfig_IpRange) GetIpFrom() string
- func (m *CrawlHostGroupConfig_IpRange) GetIpTo() string
- func (*CrawlHostGroupConfig_IpRange) ProtoMessage()
- func (m *CrawlHostGroupConfig_IpRange) Reset()
- func (m *CrawlHostGroupConfig_IpRange) String() string
- func (m *CrawlHostGroupConfig_IpRange) XXX_DiscardUnknown()
- func (m *CrawlHostGroupConfig_IpRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrawlHostGroupConfig_IpRange) XXX_Merge(src proto.Message)
- func (m *CrawlHostGroupConfig_IpRange) XXX_Size() int
- func (m *CrawlHostGroupConfig_IpRange) XXX_Unmarshal(b []byte) error
- type CrawlJobdeprecated
- func (*CrawlJob) Descriptor() ([]byte, []int)
- func (m *CrawlJob) GetCrawlConfigId() string
- func (m *CrawlJob) GetDisabled() bool
- func (m *CrawlJob) GetId() string
- func (m *CrawlJob) GetLimits() *CrawlLimitsConfig
- func (m *CrawlJob) GetMeta() *Meta
- func (m *CrawlJob) GetScheduleId() string
- func (*CrawlJob) ProtoMessage()
- func (m *CrawlJob) Reset()
- func (m *CrawlJob) String() string
- func (m *CrawlJob) XXX_DiscardUnknown()
- func (m *CrawlJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrawlJob) XXX_Merge(src proto.Message)
- func (m *CrawlJob) XXX_Size() int
- func (m *CrawlJob) XXX_Unmarshal(b []byte) error
- type CrawlJobListReplydeprecated
- func (*CrawlJobListReply) Descriptor() ([]byte, []int)
- func (m *CrawlJobListReply) GetCount() int64
- func (m *CrawlJobListReply) GetPage() int32
- func (m *CrawlJobListReply) GetPageSize() int32
- func (m *CrawlJobListReply) GetValue() []*CrawlJob
- func (*CrawlJobListReply) ProtoMessage()
- func (m *CrawlJobListReply) Reset()
- func (m *CrawlJobListReply) String() string
- func (m *CrawlJobListReply) XXX_DiscardUnknown()
- func (m *CrawlJobListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrawlJobListReply) XXX_Merge(src proto.Message)
- func (m *CrawlJobListReply) XXX_Size() int
- func (m *CrawlJobListReply) XXX_Unmarshal(b []byte) error
- type CrawlLimitsConfigdeprecated
- func (*CrawlLimitsConfig) Descriptor() ([]byte, []int)
- func (m *CrawlLimitsConfig) GetDepth() int32
- func (m *CrawlLimitsConfig) GetMaxBytes() int64
- func (m *CrawlLimitsConfig) GetMaxDurationS() int64
- func (*CrawlLimitsConfig) ProtoMessage()
- func (m *CrawlLimitsConfig) Reset()
- func (m *CrawlLimitsConfig) String() string
- func (m *CrawlLimitsConfig) XXX_DiscardUnknown()
- func (m *CrawlLimitsConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrawlLimitsConfig) XXX_Merge(src proto.Message)
- func (m *CrawlLimitsConfig) XXX_Size() int
- func (m *CrawlLimitsConfig) XXX_Unmarshal(b []byte) error
- type CrawlLogListReply
- func (*CrawlLogListReply) Descriptor() ([]byte, []int)
- func (m *CrawlLogListReply) GetCount() int64
- func (m *CrawlLogListReply) GetPage() int32
- func (m *CrawlLogListReply) GetPageSize() int32
- func (m *CrawlLogListReply) GetValue() []*v1.CrawlLog
- func (*CrawlLogListReply) ProtoMessage()
- func (m *CrawlLogListReply) Reset()
- func (m *CrawlLogListReply) String() string
- func (m *CrawlLogListReply) XXX_DiscardUnknown()
- func (m *CrawlLogListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrawlLogListReply) XXX_Merge(src proto.Message)
- func (m *CrawlLogListReply) XXX_Size() int
- func (m *CrawlLogListReply) XXX_Unmarshal(b []byte) error
- type CrawlLogListRequest
- func (*CrawlLogListRequest) Descriptor() ([]byte, []int)
- func (m *CrawlLogListRequest) GetExecutionId() string
- func (m *CrawlLogListRequest) GetFilter() []*Filter
- func (m *CrawlLogListRequest) GetPage() int32
- func (m *CrawlLogListRequest) GetPageSize() int32
- func (m *CrawlLogListRequest) GetWarcId() []string
- func (*CrawlLogListRequest) ProtoMessage()
- func (m *CrawlLogListRequest) Reset()
- func (m *CrawlLogListRequest) String() string
- func (m *CrawlLogListRequest) XXX_DiscardUnknown()
- func (m *CrawlLogListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrawlLogListRequest) XXX_Merge(src proto.Message)
- func (m *CrawlLogListRequest) XXX_Size() int
- func (m *CrawlLogListRequest) XXX_Unmarshal(b []byte) error
- type CrawlScheduleConfigdeprecated
- func (*CrawlScheduleConfig) Descriptor() ([]byte, []int)
- func (m *CrawlScheduleConfig) GetCronExpression() string
- func (m *CrawlScheduleConfig) GetId() string
- func (m *CrawlScheduleConfig) GetMeta() *Meta
- func (m *CrawlScheduleConfig) GetValidFrom() *timestamp.Timestamp
- func (m *CrawlScheduleConfig) GetValidTo() *timestamp.Timestamp
- func (*CrawlScheduleConfig) ProtoMessage()
- func (m *CrawlScheduleConfig) Reset()
- func (m *CrawlScheduleConfig) String() string
- func (m *CrawlScheduleConfig) XXX_DiscardUnknown()
- func (m *CrawlScheduleConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrawlScheduleConfig) XXX_Merge(src proto.Message)
- func (m *CrawlScheduleConfig) XXX_Size() int
- func (m *CrawlScheduleConfig) XXX_Unmarshal(b []byte) error
- type CrawlScheduleConfigListReplydeprecated
- func (*CrawlScheduleConfigListReply) Descriptor() ([]byte, []int)
- func (m *CrawlScheduleConfigListReply) GetCount() int64
- func (m *CrawlScheduleConfigListReply) GetPage() int32
- func (m *CrawlScheduleConfigListReply) GetPageSize() int32
- func (m *CrawlScheduleConfigListReply) GetValue() []*CrawlScheduleConfig
- func (*CrawlScheduleConfigListReply) ProtoMessage()
- func (m *CrawlScheduleConfigListReply) Reset()
- func (m *CrawlScheduleConfigListReply) String() string
- func (m *CrawlScheduleConfigListReply) XXX_DiscardUnknown()
- func (m *CrawlScheduleConfigListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrawlScheduleConfigListReply) XXX_Merge(src proto.Message)
- func (m *CrawlScheduleConfigListReply) XXX_Size() int
- func (m *CrawlScheduleConfigListReply) XXX_Unmarshal(b []byte) error
- type CrawlScopedeprecated
- func (*CrawlScope) Descriptor() ([]byte, []int)
- func (m *CrawlScope) GetSurtPrefix() string
- func (*CrawlScope) ProtoMessage()
- func (m *CrawlScope) Reset()
- func (m *CrawlScope) String() string
- func (m *CrawlScope) XXX_DiscardUnknown()
- func (m *CrawlScope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrawlScope) XXX_Merge(src proto.Message)
- func (m *CrawlScope) XXX_Size() int
- func (m *CrawlScope) XXX_Unmarshal(b []byte) error
- type ExecuteDbQueryReply
- func (*ExecuteDbQueryReply) Descriptor() ([]byte, []int)
- func (m *ExecuteDbQueryReply) GetRecord() string
- func (*ExecuteDbQueryReply) ProtoMessage()
- func (m *ExecuteDbQueryReply) Reset()
- func (m *ExecuteDbQueryReply) String() string
- func (m *ExecuteDbQueryReply) XXX_DiscardUnknown()
- func (m *ExecuteDbQueryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecuteDbQueryReply) XXX_Merge(src proto.Message)
- func (m *ExecuteDbQueryReply) XXX_Size() int
- func (m *ExecuteDbQueryReply) XXX_Unmarshal(b []byte) error
- type ExecuteDbQueryRequest
- func (*ExecuteDbQueryRequest) Descriptor() ([]byte, []int)
- func (m *ExecuteDbQueryRequest) GetLimit() int32
- func (m *ExecuteDbQueryRequest) GetQuery() string
- func (*ExecuteDbQueryRequest) ProtoMessage()
- func (m *ExecuteDbQueryRequest) Reset()
- func (m *ExecuteDbQueryRequest) String() string
- func (m *ExecuteDbQueryRequest) XXX_DiscardUnknown()
- func (m *ExecuteDbQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecuteDbQueryRequest) XXX_Merge(src proto.Message)
- func (m *ExecuteDbQueryRequest) XXX_Size() int
- func (m *ExecuteDbQueryRequest) XXX_Unmarshal(b []byte) error
- type ExecutionId
- func (*ExecutionId) Descriptor() ([]byte, []int)
- func (m *ExecutionId) GetId() string
- func (*ExecutionId) ProtoMessage()
- func (m *ExecutionId) Reset()
- func (m *ExecutionId) String() string
- func (m *ExecutionId) XXX_DiscardUnknown()
- func (m *ExecutionId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecutionId) XXX_Merge(src proto.Message)
- func (m *ExecutionId) XXX_Size() int
- func (m *ExecutionId) XXX_Unmarshal(b []byte) error
- type ExecutionsListReply
- func (*ExecutionsListReply) Descriptor() ([]byte, []int)
- func (m *ExecutionsListReply) GetCount() int64
- func (m *ExecutionsListReply) GetPage() int32
- func (m *ExecutionsListReply) GetPageSize() int32
- func (m *ExecutionsListReply) GetValue() []*v1.CrawlExecutionStatus
- func (*ExecutionsListReply) ProtoMessage()
- func (m *ExecutionsListReply) Reset()
- func (m *ExecutionsListReply) String() string
- func (m *ExecutionsListReply) XXX_DiscardUnknown()
- func (m *ExecutionsListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecutionsListReply) XXX_Merge(src proto.Message)
- func (m *ExecutionsListReply) XXX_Size() int
- func (m *ExecutionsListReply) XXX_Unmarshal(b []byte) error
- type ExtraConfigdeprecated
- func (*ExtraConfig) Descriptor() ([]byte, []int)
- func (m *ExtraConfig) GetCreateSnapshot() bool
- func (m *ExtraConfig) GetExtractText() bool
- func (*ExtraConfig) ProtoMessage()
- func (m *ExtraConfig) Reset()
- func (m *ExtraConfig) String() string
- func (m *ExtraConfig) XXX_DiscardUnknown()
- func (m *ExtraConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExtraConfig) XXX_Merge(src proto.Message)
- func (m *ExtraConfig) XXX_Size() int
- func (m *ExtraConfig) XXX_Unmarshal(b []byte) error
- type ExtractedText
- func (*ExtractedText) Descriptor() ([]byte, []int)
- func (m *ExtractedText) GetCharacterCount() int64
- func (m *ExtractedText) GetLanguage() string
- func (m *ExtractedText) GetLix() int64
- func (m *ExtractedText) GetLongWordCount() int64
- func (m *ExtractedText) GetSentenceCount() int64
- func (m *ExtractedText) GetText() string
- func (m *ExtractedText) GetWarcId() string
- func (m *ExtractedText) GetWordCount() int64
- func (*ExtractedText) ProtoMessage()
- func (m *ExtractedText) Reset()
- func (m *ExtractedText) String() string
- func (m *ExtractedText) XXX_DiscardUnknown()
- func (m *ExtractedText) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExtractedText) XXX_Merge(src proto.Message)
- func (m *ExtractedText) XXX_Size() int
- func (m *ExtractedText) XXX_Unmarshal(b []byte) error
- type Filter
- func (*Filter) Descriptor() ([]byte, []int)
- func (m *Filter) GetFieldName() string
- func (m *Filter) GetOp() Filter_Operator
- func (m *Filter) GetValue() string
- func (*Filter) ProtoMessage()
- func (m *Filter) Reset()
- func (m *Filter) String() string
- func (m *Filter) XXX_DiscardUnknown()
- func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Filter) XXX_Merge(src proto.Message)
- func (m *Filter) XXX_Size() int
- func (m *Filter) XXX_Unmarshal(b []byte) error
- type Filter_Operator
- type GetRequestdeprecated
- func (*GetRequest) Descriptor() ([]byte, []int)
- func (m *GetRequest) GetId() string
- func (*GetRequest) ProtoMessage()
- func (m *GetRequest) Reset()
- func (m *GetRequest) String() string
- func (m *GetRequest) XXX_DiscardUnknown()
- func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRequest) XXX_Merge(src proto.Message)
- func (m *GetRequest) XXX_Size() int
- func (m *GetRequest) XXX_Unmarshal(b []byte) error
- type JobExecutionsListReply
- func (*JobExecutionsListReply) Descriptor() ([]byte, []int)
- func (m *JobExecutionsListReply) GetCount() int64
- func (m *JobExecutionsListReply) GetPage() int32
- func (m *JobExecutionsListReply) GetPageSize() int32
- func (m *JobExecutionsListReply) GetValue() []*v1.JobExecutionStatus
- func (*JobExecutionsListReply) ProtoMessage()
- func (m *JobExecutionsListReply) Reset()
- func (m *JobExecutionsListReply) String() string
- func (m *JobExecutionsListReply) XXX_DiscardUnknown()
- func (m *JobExecutionsListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobExecutionsListReply) XXX_Merge(src proto.Message)
- func (m *JobExecutionsListReply) XXX_Size() int
- func (m *JobExecutionsListReply) XXX_Unmarshal(b []byte) error
- type Labeldeprecated
- func (*Label) Descriptor() ([]byte, []int)
- func (m *Label) GetKey() string
- func (m *Label) GetValue() string
- func (*Label) ProtoMessage()
- func (m *Label) Reset()
- func (m *Label) String() string
- func (m *Label) XXX_DiscardUnknown()
- func (m *Label) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Label) XXX_Merge(src proto.Message)
- func (m *Label) XXX_Size() int
- func (m *Label) XXX_Unmarshal(b []byte) error
- type ListExecutionsRequest
- func (*ListExecutionsRequest) Descriptor() ([]byte, []int)
- func (m *ListExecutionsRequest) GetId() []string
- func (m *ListExecutionsRequest) GetJobExecutionId() string
- func (m *ListExecutionsRequest) GetJobId() string
- func (m *ListExecutionsRequest) GetPage() int32
- func (m *ListExecutionsRequest) GetPageSize() int32
- func (m *ListExecutionsRequest) GetSeedId() string
- func (m *ListExecutionsRequest) GetState() []string
- func (*ListExecutionsRequest) ProtoMessage()
- func (m *ListExecutionsRequest) Reset()
- func (m *ListExecutionsRequest) String() string
- func (m *ListExecutionsRequest) XXX_DiscardUnknown()
- func (m *ListExecutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListExecutionsRequest) XXX_Merge(src proto.Message)
- func (m *ListExecutionsRequest) XXX_Size() int
- func (m *ListExecutionsRequest) XXX_Unmarshal(b []byte) error
- type ListJobExecutionsRequest
- func (*ListJobExecutionsRequest) Descriptor() ([]byte, []int)
- func (m *ListJobExecutionsRequest) GetId() []string
- func (m *ListJobExecutionsRequest) GetJobId() string
- func (m *ListJobExecutionsRequest) GetPage() int32
- func (m *ListJobExecutionsRequest) GetPageSize() int32
- func (m *ListJobExecutionsRequest) GetState() []string
- func (*ListJobExecutionsRequest) ProtoMessage()
- func (m *ListJobExecutionsRequest) Reset()
- func (m *ListJobExecutionsRequest) String() string
- func (m *ListJobExecutionsRequest) XXX_DiscardUnknown()
- func (m *ListJobExecutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListJobExecutionsRequest) XXX_Merge(src proto.Message)
- func (m *ListJobExecutionsRequest) XXX_Size() int
- func (m *ListJobExecutionsRequest) XXX_Unmarshal(b []byte) error
- type ListRequestdeprecated
- func (*ListRequest) Descriptor() ([]byte, []int)
- func (m *ListRequest) GetId() []string
- func (m *ListRequest) GetLabelSelector() []string
- func (m *ListRequest) GetName() string
- func (m *ListRequest) GetPage() int32
- func (m *ListRequest) GetPageSize() int32
- func (*ListRequest) ProtoMessage()
- func (m *ListRequest) Reset()
- func (m *ListRequest) String() string
- func (m *ListRequest) XXX_DiscardUnknown()
- func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRequest) XXX_Merge(src proto.Message)
- func (m *ListRequest) XXX_Size() int
- func (m *ListRequest) XXX_Unmarshal(b []byte) error
- type LogLevels
- func (*LogLevels) Descriptor() ([]byte, []int)
- func (m *LogLevels) GetLogLevel() []*LogLevels_LogLevel
- func (*LogLevels) ProtoMessage()
- func (m *LogLevels) Reset()
- func (m *LogLevels) String() string
- func (m *LogLevels) XXX_DiscardUnknown()
- func (m *LogLevels) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogLevels) XXX_Merge(src proto.Message)
- func (m *LogLevels) XXX_Size() int
- func (m *LogLevels) XXX_Unmarshal(b []byte) error
- type LogLevels_Level
- type LogLevels_LogLevel
- func (*LogLevels_LogLevel) Descriptor() ([]byte, []int)
- func (m *LogLevels_LogLevel) GetLevel() LogLevels_Level
- func (m *LogLevels_LogLevel) GetLogger() string
- func (*LogLevels_LogLevel) ProtoMessage()
- func (m *LogLevels_LogLevel) Reset()
- func (m *LogLevels_LogLevel) String() string
- func (m *LogLevels_LogLevel) XXX_DiscardUnknown()
- func (m *LogLevels_LogLevel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogLevels_LogLevel) XXX_Merge(src proto.Message)
- func (m *LogLevels_LogLevel) XXX_Size() int
- func (m *LogLevels_LogLevel) XXX_Unmarshal(b []byte) error
- type Meta
- func (*Meta) Descriptor() ([]byte, []int)
- func (m *Meta) GetCreated() *timestamp.Timestamp
- func (m *Meta) GetCreatedBy() string
- func (m *Meta) GetDescription() string
- func (m *Meta) GetLabel() []*Label
- func (m *Meta) GetLastModified() *timestamp.Timestamp
- func (m *Meta) GetLastModifiedBy() string
- func (m *Meta) GetName() string
- func (*Meta) ProtoMessage()
- func (m *Meta) Reset()
- func (m *Meta) String() string
- func (m *Meta) XXX_DiscardUnknown()
- func (m *Meta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Meta) XXX_Merge(src proto.Message)
- func (m *Meta) XXX_Size() int
- func (m *Meta) XXX_Unmarshal(b []byte) error
- type OpenIdConnectIssuerReply
- func (*OpenIdConnectIssuerReply) Descriptor() ([]byte, []int)
- func (m *OpenIdConnectIssuerReply) GetOpenIdConnectIssuer() string
- func (*OpenIdConnectIssuerReply) ProtoMessage()
- func (m *OpenIdConnectIssuerReply) Reset()
- func (m *OpenIdConnectIssuerReply) String() string
- func (m *OpenIdConnectIssuerReply) XXX_DiscardUnknown()
- func (m *OpenIdConnectIssuerReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenIdConnectIssuerReply) XXX_Merge(src proto.Message)
- func (m *OpenIdConnectIssuerReply) XXX_Size() int
- func (m *OpenIdConnectIssuerReply) XXX_Unmarshal(b []byte) error
- type PageLogListReply
- func (*PageLogListReply) Descriptor() ([]byte, []int)
- func (m *PageLogListReply) GetCount() int64
- func (m *PageLogListReply) GetPage() int32
- func (m *PageLogListReply) GetPageSize() int32
- func (m *PageLogListReply) GetValue() []*v1.PageLog
- func (*PageLogListReply) ProtoMessage()
- func (m *PageLogListReply) Reset()
- func (m *PageLogListReply) String() string
- func (m *PageLogListReply) XXX_DiscardUnknown()
- func (m *PageLogListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PageLogListReply) XXX_Merge(src proto.Message)
- func (m *PageLogListReply) XXX_Size() int
- func (m *PageLogListReply) XXX_Unmarshal(b []byte) error
- type PageLogListRequest
- func (*PageLogListRequest) Descriptor() ([]byte, []int)
- func (m *PageLogListRequest) GetExecutionId() string
- func (m *PageLogListRequest) GetFilter() []*Filter
- func (m *PageLogListRequest) GetPage() int32
- func (m *PageLogListRequest) GetPageSize() int32
- func (m *PageLogListRequest) GetWarcId() []string
- func (*PageLogListRequest) ProtoMessage()
- func (m *PageLogListRequest) Reset()
- func (m *PageLogListRequest) String() string
- func (m *PageLogListRequest) XXX_DiscardUnknown()
- func (m *PageLogListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PageLogListRequest) XXX_Merge(src proto.Message)
- func (m *PageLogListRequest) XXX_Size() int
- func (m *PageLogListRequest) XXX_Unmarshal(b []byte) error
- type PolitenessConfigdeprecated
- func (*PolitenessConfig) Descriptor() ([]byte, []int)
- func (m *PolitenessConfig) GetCrawlHostGroupSelector() []string
- func (m *PolitenessConfig) GetCustomRobots() string
- func (m *PolitenessConfig) GetDelayFactor() float32
- func (m *PolitenessConfig) GetId() string
- func (m *PolitenessConfig) GetMaxRetries() int32
- func (m *PolitenessConfig) GetMaxTimeBetweenPageLoadMs() int64
- func (m *PolitenessConfig) GetMeta() *Meta
- func (m *PolitenessConfig) GetMinTimeBetweenPageLoadMs() int64
- func (m *PolitenessConfig) GetMinimumRobotsValidityDurationS() int32
- func (m *PolitenessConfig) GetRetryDelaySeconds() int32
- func (m *PolitenessConfig) GetRobotsPolicy() PolitenessConfig_RobotsPolicy
- func (m *PolitenessConfig) GetUseHostname() bool
- func (*PolitenessConfig) ProtoMessage()
- func (m *PolitenessConfig) Reset()
- func (m *PolitenessConfig) String() string
- func (m *PolitenessConfig) XXX_DiscardUnknown()
- func (m *PolitenessConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PolitenessConfig) XXX_Merge(src proto.Message)
- func (m *PolitenessConfig) XXX_Size() int
- func (m *PolitenessConfig) XXX_Unmarshal(b []byte) error
- type PolitenessConfigListReplydeprecated
- func (*PolitenessConfigListReply) Descriptor() ([]byte, []int)
- func (m *PolitenessConfigListReply) GetCount() int64
- func (m *PolitenessConfigListReply) GetPage() int32
- func (m *PolitenessConfigListReply) GetPageSize() int32
- func (m *PolitenessConfigListReply) GetValue() []*PolitenessConfig
- func (*PolitenessConfigListReply) ProtoMessage()
- func (m *PolitenessConfigListReply) Reset()
- func (m *PolitenessConfigListReply) String() string
- func (m *PolitenessConfigListReply) XXX_DiscardUnknown()
- func (m *PolitenessConfigListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PolitenessConfigListReply) XXX_Merge(src proto.Message)
- func (m *PolitenessConfigListReply) XXX_Size() int
- func (m *PolitenessConfigListReply) XXX_Unmarshal(b []byte) error
- type PolitenessConfig_RobotsPolicy
- type ReportClient
- type ReportServer
- type Report_ExecuteDbQueryClient
- type Report_ExecuteDbQueryServer
- type Role
- type RoleList
- func (*RoleList) Descriptor() ([]byte, []int)
- func (m *RoleList) GetRole() []Role
- func (*RoleList) ProtoMessage()
- func (m *RoleList) Reset()
- func (m *RoleList) String() string
- func (m *RoleList) XXX_DiscardUnknown()
- func (m *RoleList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RoleList) XXX_Merge(src proto.Message)
- func (m *RoleList) XXX_Size() int
- func (m *RoleList) XXX_Unmarshal(b []byte) error
- type RoleMappingdeprecated
- func (*RoleMapping) Descriptor() ([]byte, []int)
- func (m *RoleMapping) GetEmail() string
- func (m *RoleMapping) GetEmailOrGroup() isRoleMapping_EmailOrGroup
- func (m *RoleMapping) GetGroup() string
- func (m *RoleMapping) GetId() string
- func (m *RoleMapping) GetRole() []Role
- func (*RoleMapping) ProtoMessage()
- func (m *RoleMapping) Reset()
- func (m *RoleMapping) String() string
- func (m *RoleMapping) XXX_DiscardUnknown()
- func (m *RoleMapping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RoleMapping) XXX_Merge(src proto.Message)
- func (*RoleMapping) XXX_OneofWrappers() []interface{}
- func (m *RoleMapping) XXX_Size() int
- func (m *RoleMapping) XXX_Unmarshal(b []byte) error
- type RoleMapping_Email
- type RoleMapping_Group
- type RoleMappingsListReplydeprecated
- func (*RoleMappingsListReply) Descriptor() ([]byte, []int)
- func (m *RoleMappingsListReply) GetCount() int64
- func (m *RoleMappingsListReply) GetPage() int32
- func (m *RoleMappingsListReply) GetPageSize() int32
- func (m *RoleMappingsListReply) GetValue() []*RoleMapping
- func (*RoleMappingsListReply) ProtoMessage()
- func (m *RoleMappingsListReply) Reset()
- func (m *RoleMappingsListReply) String() string
- func (m *RoleMappingsListReply) XXX_DiscardUnknown()
- func (m *RoleMappingsListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RoleMappingsListReply) XXX_Merge(src proto.Message)
- func (m *RoleMappingsListReply) XXX_Size() int
- func (m *RoleMappingsListReply) XXX_Unmarshal(b []byte) error
- type RoleMappingsListRequestdeprecated
- func (*RoleMappingsListRequest) Descriptor() ([]byte, []int)
- func (m *RoleMappingsListRequest) GetId() string
- func (m *RoleMappingsListRequest) GetPage() int32
- func (m *RoleMappingsListRequest) GetPageSize() int32
- func (*RoleMappingsListRequest) ProtoMessage()
- func (m *RoleMappingsListRequest) Reset()
- func (m *RoleMappingsListRequest) String() string
- func (m *RoleMappingsListRequest) XXX_DiscardUnknown()
- func (m *RoleMappingsListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RoleMappingsListRequest) XXX_Merge(src proto.Message)
- func (m *RoleMappingsListRequest) XXX_Size() int
- func (m *RoleMappingsListRequest) XXX_Unmarshal(b []byte) error
- type RunCrawlReply
- func (*RunCrawlReply) Descriptor() ([]byte, []int)
- func (m *RunCrawlReply) GetJobExecutionId() string
- func (*RunCrawlReply) ProtoMessage()
- func (m *RunCrawlReply) Reset()
- func (m *RunCrawlReply) String() string
- func (m *RunCrawlReply) XXX_DiscardUnknown()
- func (m *RunCrawlReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RunCrawlReply) XXX_Merge(src proto.Message)
- func (m *RunCrawlReply) XXX_Size() int
- func (m *RunCrawlReply) XXX_Unmarshal(b []byte) error
- type RunCrawlRequest
- func (*RunCrawlRequest) Descriptor() ([]byte, []int)
- func (m *RunCrawlRequest) GetJobId() string
- func (m *RunCrawlRequest) GetSeedId() string
- func (*RunCrawlRequest) ProtoMessage()
- func (m *RunCrawlRequest) Reset()
- func (m *RunCrawlRequest) String() string
- func (m *RunCrawlRequest) XXX_DiscardUnknown()
- func (m *RunCrawlRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RunCrawlRequest) XXX_Merge(src proto.Message)
- func (m *RunCrawlRequest) XXX_Size() int
- func (m *RunCrawlRequest) XXX_Unmarshal(b []byte) error
- type RunningExecutionsListReply
- func (*RunningExecutionsListReply) Descriptor() ([]byte, []int)
- func (m *RunningExecutionsListReply) GetCount() int64
- func (m *RunningExecutionsListReply) GetPage() int32
- func (m *RunningExecutionsListReply) GetPageSize() int32
- func (m *RunningExecutionsListReply) GetValue() []*StatusDetail
- func (*RunningExecutionsListReply) ProtoMessage()
- func (m *RunningExecutionsListReply) Reset()
- func (m *RunningExecutionsListReply) String() string
- func (m *RunningExecutionsListReply) XXX_DiscardUnknown()
- func (m *RunningExecutionsListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RunningExecutionsListReply) XXX_Merge(src proto.Message)
- func (m *RunningExecutionsListReply) XXX_Size() int
- func (m *RunningExecutionsListReply) XXX_Unmarshal(b []byte) error
- type RunningExecutionsRequest
- func (*RunningExecutionsRequest) Descriptor() ([]byte, []int)
- func (m *RunningExecutionsRequest) GetPage() int32
- func (m *RunningExecutionsRequest) GetPageSize() int32
- func (*RunningExecutionsRequest) ProtoMessage()
- func (m *RunningExecutionsRequest) Reset()
- func (m *RunningExecutionsRequest) String() string
- func (m *RunningExecutionsRequest) XXX_DiscardUnknown()
- func (m *RunningExecutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RunningExecutionsRequest) XXX_Merge(src proto.Message)
- func (m *RunningExecutionsRequest) XXX_Size() int
- func (m *RunningExecutionsRequest) XXX_Unmarshal(b []byte) error
- type Screenshot
- func (*Screenshot) Descriptor() ([]byte, []int)
- func (m *Screenshot) GetExecutionId() string
- func (m *Screenshot) GetId() string
- func (m *Screenshot) GetImg() []byte
- func (m *Screenshot) GetUri() string
- func (*Screenshot) ProtoMessage()
- func (m *Screenshot) Reset()
- func (m *Screenshot) String() string
- func (m *Screenshot) XXX_DiscardUnknown()
- func (m *Screenshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Screenshot) XXX_Merge(src proto.Message)
- func (m *Screenshot) XXX_Size() int
- func (m *Screenshot) XXX_Unmarshal(b []byte) error
- type ScreenshotListReply
- func (*ScreenshotListReply) Descriptor() ([]byte, []int)
- func (m *ScreenshotListReply) GetCount() int64
- func (m *ScreenshotListReply) GetPage() int32
- func (m *ScreenshotListReply) GetPageSize() int32
- func (m *ScreenshotListReply) GetValue() []*Screenshot
- func (*ScreenshotListReply) ProtoMessage()
- func (m *ScreenshotListReply) Reset()
- func (m *ScreenshotListReply) String() string
- func (m *ScreenshotListReply) XXX_DiscardUnknown()
- func (m *ScreenshotListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ScreenshotListReply) XXX_Merge(src proto.Message)
- func (m *ScreenshotListReply) XXX_Size() int
- func (m *ScreenshotListReply) XXX_Unmarshal(b []byte) error
- type ScreenshotListRequest
- func (*ScreenshotListRequest) Descriptor() ([]byte, []int)
- func (m *ScreenshotListRequest) GetExecutionId() string
- func (m *ScreenshotListRequest) GetFilter() []*Filter
- func (m *ScreenshotListRequest) GetId() []string
- func (m *ScreenshotListRequest) GetImgData() bool
- func (m *ScreenshotListRequest) GetPage() int32
- func (m *ScreenshotListRequest) GetPageSize() int32
- func (*ScreenshotListRequest) ProtoMessage()
- func (m *ScreenshotListRequest) Reset()
- func (m *ScreenshotListRequest) String() string
- func (m *ScreenshotListRequest) XXX_DiscardUnknown()
- func (m *ScreenshotListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ScreenshotListRequest) XXX_Merge(src proto.Message)
- func (m *ScreenshotListRequest) XXX_Size() int
- func (m *ScreenshotListRequest) XXX_Unmarshal(b []byte) error
- type Seeddeprecated
- func (*Seed) Descriptor() ([]byte, []int)
- func (m *Seed) GetDisabled() bool
- func (m *Seed) GetEntityId() string
- func (m *Seed) GetId() string
- func (m *Seed) GetJobId() []string
- func (m *Seed) GetMeta() *Meta
- func (m *Seed) GetScope() *CrawlScope
- func (*Seed) ProtoMessage()
- func (m *Seed) Reset()
- func (m *Seed) String() string
- func (m *Seed) XXX_DiscardUnknown()
- func (m *Seed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Seed) XXX_Merge(src proto.Message)
- func (m *Seed) XXX_Size() int
- func (m *Seed) XXX_Unmarshal(b []byte) error
- type SeedListReplydeprecated
- func (*SeedListReply) Descriptor() ([]byte, []int)
- func (m *SeedListReply) GetCount() int64
- func (m *SeedListReply) GetPage() int32
- func (m *SeedListReply) GetPageSize() int32
- func (m *SeedListReply) GetValue() []*Seed
- func (*SeedListReply) ProtoMessage()
- func (m *SeedListReply) Reset()
- func (m *SeedListReply) String() string
- func (m *SeedListReply) XXX_DiscardUnknown()
- func (m *SeedListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SeedListReply) XXX_Merge(src proto.Message)
- func (m *SeedListReply) XXX_Size() int
- func (m *SeedListReply) XXX_Unmarshal(b []byte) error
- type SeedListRequestdeprecated
- func (*SeedListRequest) Descriptor() ([]byte, []int)
- func (m *SeedListRequest) GetCrawlJobId() string
- func (m *SeedListRequest) GetEntityId() string
- func (m *SeedListRequest) GetId() []string
- func (m *SeedListRequest) GetLabelSelector() []string
- func (m *SeedListRequest) GetName() string
- func (m *SeedListRequest) GetPage() int32
- func (m *SeedListRequest) GetPageSize() int32
- func (*SeedListRequest) ProtoMessage()
- func (m *SeedListRequest) Reset()
- func (m *SeedListRequest) String() string
- func (m *SeedListRequest) XXX_DiscardUnknown()
- func (m *SeedListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SeedListRequest) XXX_Merge(src proto.Message)
- func (m *SeedListRequest) XXX_Size() int
- func (m *SeedListRequest) XXX_Unmarshal(b []byte) error
- type StatusClient
- type StatusDetail
- func (*StatusDetail) Descriptor() ([]byte, []int)
- func (m *StatusDetail) GetBytesCrawled() int64
- func (m *StatusDetail) GetCurrentUri() string
- func (m *StatusDetail) GetDocumentsCrawled() int64
- func (m *StatusDetail) GetDocumentsDenied() int64
- func (m *StatusDetail) GetDocumentsFailed() int64
- func (m *StatusDetail) GetDocumentsOutOfScope() int64
- func (m *StatusDetail) GetDocumentsRetried() int64
- func (m *StatusDetail) GetEndTime() *timestamp.Timestamp
- func (m *StatusDetail) GetId() string
- func (m *StatusDetail) GetJobId() string
- func (m *StatusDetail) GetQueueSize() int64
- func (m *StatusDetail) GetSeed() string
- func (m *StatusDetail) GetStartTime() *timestamp.Timestamp
- func (m *StatusDetail) GetState() v1.CrawlExecutionStatus_State
- func (m *StatusDetail) GetUrisCrawled() int64
- func (*StatusDetail) ProtoMessage()
- func (m *StatusDetail) Reset()
- func (m *StatusDetail) String() string
- func (m *StatusDetail) XXX_DiscardUnknown()
- func (m *StatusDetail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusDetail) XXX_Merge(src proto.Message)
- func (m *StatusDetail) XXX_Size() int
- func (m *StatusDetail) XXX_Unmarshal(b []byte) error
- type StatusServer
- type Status_GetRunningExecutionsClient
- type Status_GetRunningExecutionsServer
Constants ¶
This section is empty.
Variables ¶
var Filter_Operator_name = map[int32]string{
0: "EQ",
1: "NE",
2: "MATCH",
3: "LT",
4: "GT",
}
var Filter_Operator_value = map[string]int32{
"EQ": 0,
"NE": 1,
"MATCH": 2,
"LT": 3,
"GT": 4,
}
var LogLevels_Level_name = map[int32]string{
0: "UNDEFINED",
1: "ALL",
2: "TRACE",
3: "DEBUG",
4: "INFO",
5: "WARN",
6: "ERROR",
7: "FATAL",
8: "OFF",
}
var LogLevels_Level_value = map[string]int32{
"UNDEFINED": 0,
"ALL": 1,
"TRACE": 2,
"DEBUG": 3,
"INFO": 4,
"WARN": 5,
"ERROR": 6,
"FATAL": 7,
"OFF": 8,
}
var PolitenessConfig_RobotsPolicy_name = map[int32]string{
0: "OBEY_ROBOTS",
1: "IGNORE_ROBOTS",
2: "CUSTOM_ROBOTS",
}
var PolitenessConfig_RobotsPolicy_value = map[string]int32{
"OBEY_ROBOTS": 0,
"IGNORE_ROBOTS": 1,
"CUSTOM_ROBOTS": 2,
}
var Role_name = map[int32]string{
0: "ANY_USER",
1: "ANY",
2: "ADMIN",
3: "CURATOR",
4: "READONLY",
}
var Role_value = map[string]int32{
"ANY_USER": 0,
"ANY": 1,
"ADMIN": 2,
"CURATOR": 3,
"READONLY": 4,
}
Functions ¶
func RegisterControllerServer ¶
func RegisterControllerServer(s *grpc.Server, srv ControllerServer)
func RegisterReportServer ¶
func RegisterReportServer(s *grpc.Server, srv ReportServer)
func RegisterStatusServer ¶
func RegisterStatusServer(s *grpc.Server, srv StatusServer)
Types ¶
type AbortCrawlRequest ¶
type AbortCrawlRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AbortCrawlRequest) Descriptor ¶
func (*AbortCrawlRequest) Descriptor() ([]byte, []int)
func (*AbortCrawlRequest) GetId ¶
func (m *AbortCrawlRequest) GetId() string
func (*AbortCrawlRequest) ProtoMessage ¶
func (*AbortCrawlRequest) ProtoMessage()
func (*AbortCrawlRequest) Reset ¶
func (m *AbortCrawlRequest) Reset()
func (*AbortCrawlRequest) String ¶
func (m *AbortCrawlRequest) String() string
func (*AbortCrawlRequest) XXX_DiscardUnknown ¶
func (m *AbortCrawlRequest) XXX_DiscardUnknown()
func (*AbortCrawlRequest) XXX_Marshal ¶
func (m *AbortCrawlRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AbortCrawlRequest) XXX_Merge ¶
func (m *AbortCrawlRequest) XXX_Merge(src proto.Message)
func (*AbortCrawlRequest) XXX_Size ¶
func (m *AbortCrawlRequest) XXX_Size() int
func (*AbortCrawlRequest) XXX_Unmarshal ¶
func (m *AbortCrawlRequest) XXX_Unmarshal(b []byte) error
type BrowserConfig
deprecated
type BrowserConfig struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Meta *Meta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` UserAgent string `protobuf:"bytes,3,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"` WindowWidth int32 `protobuf:"varint,4,opt,name=window_width,json=windowWidth,proto3" json:"window_width,omitempty"` WindowHeight int32 `protobuf:"varint,5,opt,name=window_height,json=windowHeight,proto3" json:"window_height,omitempty"` PageLoadTimeoutMs int64 `protobuf:"varint,6,opt,name=page_load_timeout_ms,json=pageLoadTimeoutMs,proto3" json:"page_load_timeout_ms,omitempty"` // Select scripts by label // A string representing a label query. The query matches if at least one label matches the query. // If there are multiple queries, then each query must match at least one label. // Label quries are case insensitive. The basic format is <code>key:value</code> where both key and value must match. // If value ends with <code>*</code> then the key must match and value must match up until the <code>*</code>. // If value is empty, all labels matching the key will match. // If key is empty, then the matching is done on the value for all keys. // If key is empty, then the <code>:</code> might be ommitted. // <pre> // Examples: // "foo:bar" - matches exactly labels with key=foo and value=bar // "foo:" - matches all labels with key=foo // ":bar" - matches all labels with value=bar // "bar" - matches all labels with value=bar // "foo:ba*" - matches labels with key=foo and value starting with ba (e.g. matches bar, but not ber) // ":ba*" - matches labels with any key and value starting with ba (e.g. matches bar, but not ber) // "ba*" - matches labels with any key and value starting with ba (e.g. matches bar, but not ber) // ":" - matches every label // "" - matches every label // </pre> ScriptSelector []string `protobuf:"bytes,7,rep,name=script_selector,json=scriptSelector,proto3" json:"script_selector,omitempty"` ScriptId []string `protobuf:"bytes,8,rep,name=script_id,json=scriptId,proto3" json:"script_id,omitempty"` Headers map[string]string `` /* 156-byte string literal not displayed */ ScriptParameters map[string]string `` /* 198-byte string literal not displayed */ SleepAfterPageloadMs int64 `` /* 127-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*BrowserConfig) Descriptor ¶
func (*BrowserConfig) Descriptor() ([]byte, []int)
func (*BrowserConfig) GetHeaders ¶
func (m *BrowserConfig) GetHeaders() map[string]string
func (*BrowserConfig) GetId ¶
func (m *BrowserConfig) GetId() string
func (*BrowserConfig) GetMeta ¶
func (m *BrowserConfig) GetMeta() *Meta
func (*BrowserConfig) GetPageLoadTimeoutMs ¶
func (m *BrowserConfig) GetPageLoadTimeoutMs() int64
func (*BrowserConfig) GetScriptId ¶
func (m *BrowserConfig) GetScriptId() []string
func (*BrowserConfig) GetScriptParameters ¶
func (m *BrowserConfig) GetScriptParameters() map[string]string
func (*BrowserConfig) GetScriptSelector ¶
func (m *BrowserConfig) GetScriptSelector() []string
func (*BrowserConfig) GetSleepAfterPageloadMs ¶
func (m *BrowserConfig) GetSleepAfterPageloadMs() int64
func (*BrowserConfig) GetUserAgent ¶
func (m *BrowserConfig) GetUserAgent() string
func (*BrowserConfig) GetWindowHeight ¶
func (m *BrowserConfig) GetWindowHeight() int32
func (*BrowserConfig) GetWindowWidth ¶
func (m *BrowserConfig) GetWindowWidth() int32
func (*BrowserConfig) ProtoMessage ¶
func (*BrowserConfig) ProtoMessage()
func (*BrowserConfig) Reset ¶
func (m *BrowserConfig) Reset()
func (*BrowserConfig) String ¶
func (m *BrowserConfig) String() string
func (*BrowserConfig) XXX_DiscardUnknown ¶
func (m *BrowserConfig) XXX_DiscardUnknown()
func (*BrowserConfig) XXX_Marshal ¶
func (m *BrowserConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BrowserConfig) XXX_Merge ¶
func (m *BrowserConfig) XXX_Merge(src proto.Message)
func (*BrowserConfig) XXX_Size ¶
func (m *BrowserConfig) XXX_Size() int
func (*BrowserConfig) XXX_Unmarshal ¶
func (m *BrowserConfig) XXX_Unmarshal(b []byte) error
type BrowserConfigListReply
deprecated
type BrowserConfigListReply struct { Value []*BrowserConfig `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*BrowserConfigListReply) Descriptor ¶
func (*BrowserConfigListReply) Descriptor() ([]byte, []int)
func (*BrowserConfigListReply) GetCount ¶
func (m *BrowserConfigListReply) GetCount() int64
func (*BrowserConfigListReply) GetPage ¶
func (m *BrowserConfigListReply) GetPage() int32
func (*BrowserConfigListReply) GetPageSize ¶
func (m *BrowserConfigListReply) GetPageSize() int32
func (*BrowserConfigListReply) GetValue ¶
func (m *BrowserConfigListReply) GetValue() []*BrowserConfig
func (*BrowserConfigListReply) ProtoMessage ¶
func (*BrowserConfigListReply) ProtoMessage()
func (*BrowserConfigListReply) Reset ¶
func (m *BrowserConfigListReply) Reset()
func (*BrowserConfigListReply) String ¶
func (m *BrowserConfigListReply) String() string
func (*BrowserConfigListReply) XXX_DiscardUnknown ¶
func (m *BrowserConfigListReply) XXX_DiscardUnknown()
func (*BrowserConfigListReply) XXX_Marshal ¶
func (m *BrowserConfigListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BrowserConfigListReply) XXX_Merge ¶
func (m *BrowserConfigListReply) XXX_Merge(src proto.Message)
func (*BrowserConfigListReply) XXX_Size ¶
func (m *BrowserConfigListReply) XXX_Size() int
func (*BrowserConfigListReply) XXX_Unmarshal ¶
func (m *BrowserConfigListReply) XXX_Unmarshal(b []byte) error
type BrowserScript
deprecated
type BrowserScript struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Meta *Meta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` Script string `protobuf:"bytes,3,opt,name=script,proto3" json:"script,omitempty"` UrlRegexp string `protobuf:"bytes,4,opt,name=url_regexp,json=urlRegexp,proto3" json:"url_regexp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Message containing a javascript to be run in a browser
Deprecated: Do not use.
func (*BrowserScript) Descriptor ¶
func (*BrowserScript) Descriptor() ([]byte, []int)
func (*BrowserScript) GetId ¶
func (m *BrowserScript) GetId() string
func (*BrowserScript) GetMeta ¶
func (m *BrowserScript) GetMeta() *Meta
func (*BrowserScript) GetScript ¶
func (m *BrowserScript) GetScript() string
func (*BrowserScript) GetUrlRegexp ¶
func (m *BrowserScript) GetUrlRegexp() string
func (*BrowserScript) ProtoMessage ¶
func (*BrowserScript) ProtoMessage()
func (*BrowserScript) Reset ¶
func (m *BrowserScript) Reset()
func (*BrowserScript) String ¶
func (m *BrowserScript) String() string
func (*BrowserScript) XXX_DiscardUnknown ¶
func (m *BrowserScript) XXX_DiscardUnknown()
func (*BrowserScript) XXX_Marshal ¶
func (m *BrowserScript) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BrowserScript) XXX_Merge ¶
func (m *BrowserScript) XXX_Merge(src proto.Message)
func (*BrowserScript) XXX_Size ¶
func (m *BrowserScript) XXX_Size() int
func (*BrowserScript) XXX_Unmarshal ¶
func (m *BrowserScript) XXX_Unmarshal(b []byte) error
type BrowserScriptListReply
deprecated
type BrowserScriptListReply struct { Value []*BrowserScript `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A list of browserscripts
Deprecated: Do not use.
func (*BrowserScriptListReply) Descriptor ¶
func (*BrowserScriptListReply) Descriptor() ([]byte, []int)
func (*BrowserScriptListReply) GetCount ¶
func (m *BrowserScriptListReply) GetCount() int64
func (*BrowserScriptListReply) GetPage ¶
func (m *BrowserScriptListReply) GetPage() int32
func (*BrowserScriptListReply) GetPageSize ¶
func (m *BrowserScriptListReply) GetPageSize() int32
func (*BrowserScriptListReply) GetValue ¶
func (m *BrowserScriptListReply) GetValue() []*BrowserScript
func (*BrowserScriptListReply) ProtoMessage ¶
func (*BrowserScriptListReply) ProtoMessage()
func (*BrowserScriptListReply) Reset ¶
func (m *BrowserScriptListReply) Reset()
func (*BrowserScriptListReply) String ¶
func (m *BrowserScriptListReply) String() string
func (*BrowserScriptListReply) XXX_DiscardUnknown ¶
func (m *BrowserScriptListReply) XXX_DiscardUnknown()
func (*BrowserScriptListReply) XXX_Marshal ¶
func (m *BrowserScriptListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BrowserScriptListReply) XXX_Merge ¶
func (m *BrowserScriptListReply) XXX_Merge(src proto.Message)
func (*BrowserScriptListReply) XXX_Size ¶
func (m *BrowserScriptListReply) XXX_Size() int
func (*BrowserScriptListReply) XXX_Unmarshal ¶
func (m *BrowserScriptListReply) XXX_Unmarshal(b []byte) error
type ControllerClient ¶
type ControllerClient interface { // Get a crawl entity by ID GetCrawlEntity(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*CrawlEntity, error) // List a set of crawl entities ListCrawlEntities(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*CrawlEntityListReply, error) // Save a crawl entity SaveEntity(ctx context.Context, in *CrawlEntity, opts ...grpc.CallOption) (*CrawlEntity, error) // Delete a crawl entity DeleteEntity(ctx context.Context, in *CrawlEntity, opts ...grpc.CallOption) (*empty.Empty, error) // Get a seed by ID GetSeed(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*Seed, error) // List a set of seeds ListSeeds(ctx context.Context, in *SeedListRequest, opts ...grpc.CallOption) (*SeedListReply, error) SaveSeed(ctx context.Context, in *Seed, opts ...grpc.CallOption) (*Seed, error) DeleteSeed(ctx context.Context, in *Seed, opts ...grpc.CallOption) (*empty.Empty, error) // Get a crawl job by ID GetCrawlJob(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*CrawlJob, error) // List a set of crawl jobs ListCrawlJobs(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*CrawlJobListReply, error) SaveCrawlJob(ctx context.Context, in *CrawlJob, opts ...grpc.CallOption) (*CrawlJob, error) DeleteCrawlJob(ctx context.Context, in *CrawlJob, opts ...grpc.CallOption) (*empty.Empty, error) // Get a crawl config by ID GetCrawlConfig(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*CrawlConfig, error) // List a set of crawl configs ListCrawlConfigs(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*CrawlConfigListReply, error) SaveCrawlConfig(ctx context.Context, in *CrawlConfig, opts ...grpc.CallOption) (*CrawlConfig, error) DeleteCrawlConfig(ctx context.Context, in *CrawlConfig, opts ...grpc.CallOption) (*empty.Empty, error) // Get a crawl schedule config by ID GetCrawlScheduleConfig(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*CrawlScheduleConfig, error) // List a set of crawl schedule configs ListCrawlScheduleConfigs(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*CrawlScheduleConfigListReply, error) SaveCrawlScheduleConfig(ctx context.Context, in *CrawlScheduleConfig, opts ...grpc.CallOption) (*CrawlScheduleConfig, error) DeleteCrawlScheduleConfig(ctx context.Context, in *CrawlScheduleConfig, opts ...grpc.CallOption) (*empty.Empty, error) // Get a politeness config by ID GetPolitenessConfig(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*PolitenessConfig, error) // List a set of politeness configs ListPolitenessConfigs(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*PolitenessConfigListReply, error) SavePolitenessConfig(ctx context.Context, in *PolitenessConfig, opts ...grpc.CallOption) (*PolitenessConfig, error) DeletePolitenessConfig(ctx context.Context, in *PolitenessConfig, opts ...grpc.CallOption) (*empty.Empty, error) // Get a browser config by ID GetBrowserConfig(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*BrowserConfig, error) // List a set of browser configs ListBrowserConfigs(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*BrowserConfigListReply, error) SaveBrowserConfig(ctx context.Context, in *BrowserConfig, opts ...grpc.CallOption) (*BrowserConfig, error) DeleteBrowserConfig(ctx context.Context, in *BrowserConfig, opts ...grpc.CallOption) (*empty.Empty, error) // Get a browser script by ID GetBrowserScript(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*BrowserScript, error) // List a set of browser scripts ListBrowserScripts(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*BrowserScriptListReply, error) SaveBrowserScript(ctx context.Context, in *BrowserScript, opts ...grpc.CallOption) (*BrowserScript, error) DeleteBrowserScript(ctx context.Context, in *BrowserScript, opts ...grpc.CallOption) (*empty.Empty, error) // Get a crawl host group config by ID GetCrawlHostGroupConfig(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*CrawlHostGroupConfig, error) // List a set of crawl host group configs ListCrawlHostGroupConfigs(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*CrawlHostGroupConfigListReply, error) SaveCrawlHostGroupConfig(ctx context.Context, in *CrawlHostGroupConfig, opts ...grpc.CallOption) (*CrawlHostGroupConfig, error) DeleteCrawlHostGroupConfig(ctx context.Context, in *CrawlHostGroupConfig, opts ...grpc.CallOption) (*empty.Empty, error) GetLogConfig(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*LogLevels, error) SaveLogConfig(ctx context.Context, in *LogLevels, opts ...grpc.CallOption) (*LogLevels, error) ListRoleMappings(ctx context.Context, in *RoleMappingsListRequest, opts ...grpc.CallOption) (*RoleMappingsListReply, error) SaveRoleMapping(ctx context.Context, in *RoleMapping, opts ...grpc.CallOption) (*RoleMapping, error) DeleteRoleMapping(ctx context.Context, in *RoleMapping, opts ...grpc.CallOption) (*empty.Empty, error) GetRolesForActiveUser(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*RoleList, error) RunCrawl(ctx context.Context, in *RunCrawlRequest, opts ...grpc.CallOption) (*RunCrawlReply, error) // Get the configured OpenID connect issuer address GetOpenIdConnectIssuer(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*OpenIdConnectIssuerReply, error) }
ControllerClient is the client API for Controller service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewControllerClient ¶
func NewControllerClient(cc *grpc.ClientConn) ControllerClient
type ControllerServer ¶
type ControllerServer interface { // Get a crawl entity by ID GetCrawlEntity(context.Context, *GetRequest) (*CrawlEntity, error) // List a set of crawl entities ListCrawlEntities(context.Context, *ListRequest) (*CrawlEntityListReply, error) // Save a crawl entity SaveEntity(context.Context, *CrawlEntity) (*CrawlEntity, error) // Delete a crawl entity DeleteEntity(context.Context, *CrawlEntity) (*empty.Empty, error) // Get a seed by ID GetSeed(context.Context, *GetRequest) (*Seed, error) // List a set of seeds ListSeeds(context.Context, *SeedListRequest) (*SeedListReply, error) SaveSeed(context.Context, *Seed) (*Seed, error) DeleteSeed(context.Context, *Seed) (*empty.Empty, error) // Get a crawl job by ID GetCrawlJob(context.Context, *GetRequest) (*CrawlJob, error) // List a set of crawl jobs ListCrawlJobs(context.Context, *ListRequest) (*CrawlJobListReply, error) SaveCrawlJob(context.Context, *CrawlJob) (*CrawlJob, error) DeleteCrawlJob(context.Context, *CrawlJob) (*empty.Empty, error) // Get a crawl config by ID GetCrawlConfig(context.Context, *GetRequest) (*CrawlConfig, error) // List a set of crawl configs ListCrawlConfigs(context.Context, *ListRequest) (*CrawlConfigListReply, error) SaveCrawlConfig(context.Context, *CrawlConfig) (*CrawlConfig, error) DeleteCrawlConfig(context.Context, *CrawlConfig) (*empty.Empty, error) // Get a crawl schedule config by ID GetCrawlScheduleConfig(context.Context, *GetRequest) (*CrawlScheduleConfig, error) // List a set of crawl schedule configs ListCrawlScheduleConfigs(context.Context, *ListRequest) (*CrawlScheduleConfigListReply, error) SaveCrawlScheduleConfig(context.Context, *CrawlScheduleConfig) (*CrawlScheduleConfig, error) DeleteCrawlScheduleConfig(context.Context, *CrawlScheduleConfig) (*empty.Empty, error) // Get a politeness config by ID GetPolitenessConfig(context.Context, *GetRequest) (*PolitenessConfig, error) // List a set of politeness configs ListPolitenessConfigs(context.Context, *ListRequest) (*PolitenessConfigListReply, error) SavePolitenessConfig(context.Context, *PolitenessConfig) (*PolitenessConfig, error) DeletePolitenessConfig(context.Context, *PolitenessConfig) (*empty.Empty, error) // Get a browser config by ID GetBrowserConfig(context.Context, *GetRequest) (*BrowserConfig, error) // List a set of browser configs ListBrowserConfigs(context.Context, *ListRequest) (*BrowserConfigListReply, error) SaveBrowserConfig(context.Context, *BrowserConfig) (*BrowserConfig, error) DeleteBrowserConfig(context.Context, *BrowserConfig) (*empty.Empty, error) // Get a browser script by ID GetBrowserScript(context.Context, *GetRequest) (*BrowserScript, error) // List a set of browser scripts ListBrowserScripts(context.Context, *ListRequest) (*BrowserScriptListReply, error) SaveBrowserScript(context.Context, *BrowserScript) (*BrowserScript, error) DeleteBrowserScript(context.Context, *BrowserScript) (*empty.Empty, error) // Get a crawl host group config by ID GetCrawlHostGroupConfig(context.Context, *GetRequest) (*CrawlHostGroupConfig, error) // List a set of crawl host group configs ListCrawlHostGroupConfigs(context.Context, *ListRequest) (*CrawlHostGroupConfigListReply, error) SaveCrawlHostGroupConfig(context.Context, *CrawlHostGroupConfig) (*CrawlHostGroupConfig, error) DeleteCrawlHostGroupConfig(context.Context, *CrawlHostGroupConfig) (*empty.Empty, error) GetLogConfig(context.Context, *empty.Empty) (*LogLevels, error) SaveLogConfig(context.Context, *LogLevels) (*LogLevels, error) ListRoleMappings(context.Context, *RoleMappingsListRequest) (*RoleMappingsListReply, error) SaveRoleMapping(context.Context, *RoleMapping) (*RoleMapping, error) DeleteRoleMapping(context.Context, *RoleMapping) (*empty.Empty, error) GetRolesForActiveUser(context.Context, *empty.Empty) (*RoleList, error) RunCrawl(context.Context, *RunCrawlRequest) (*RunCrawlReply, error) // Get the configured OpenID connect issuer address GetOpenIdConnectIssuer(context.Context, *empty.Empty) (*OpenIdConnectIssuerReply, error) }
ControllerServer is the server API for Controller service.
type CrawlConfig
deprecated
type CrawlConfig struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Meta *Meta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` BrowserConfigId string `protobuf:"bytes,7,opt,name=browser_config_id,json=browserConfigId,proto3" json:"browser_config_id,omitempty"` PolitenessId string `protobuf:"bytes,8,opt,name=politeness_id,json=politenessId,proto3" json:"politeness_id,omitempty"` Extra *ExtraConfig `protobuf:"bytes,9,opt,name=extra,proto3" json:"extra,omitempty"` MinimumDnsTtlS int32 `protobuf:"varint,10,opt,name=minimum_dns_ttl_s,json=minimumDnsTtlS,proto3" json:"minimum_dns_ttl_s,omitempty"` // The weighting between jobs when two jobs compete on fetching resources from the same hosts. // The job will be randomly choosed, but weighted such that if that two jobs with weight 1.0 and one job with // weight 2.0 compete, then the two first jobs will each have 25% probability of beeing choosed and the the third // job will have 50% probability of beeing choosed. PriorityWeight float64 `protobuf:"fixed64,11,opt,name=priority_weight,json=priorityWeight,proto3" json:"priority_weight,omitempty"` DepthFirst bool `protobuf:"varint,20,opt,name=depth_first,json=depthFirst,proto3" json:"depth_first,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*CrawlConfig) Descriptor ¶
func (*CrawlConfig) Descriptor() ([]byte, []int)
func (*CrawlConfig) GetBrowserConfigId ¶
func (m *CrawlConfig) GetBrowserConfigId() string
func (*CrawlConfig) GetDepthFirst ¶
func (m *CrawlConfig) GetDepthFirst() bool
func (*CrawlConfig) GetExtra ¶
func (m *CrawlConfig) GetExtra() *ExtraConfig
func (*CrawlConfig) GetId ¶
func (m *CrawlConfig) GetId() string
func (*CrawlConfig) GetMeta ¶
func (m *CrawlConfig) GetMeta() *Meta
func (*CrawlConfig) GetMinimumDnsTtlS ¶
func (m *CrawlConfig) GetMinimumDnsTtlS() int32
func (*CrawlConfig) GetPolitenessId ¶
func (m *CrawlConfig) GetPolitenessId() string
func (*CrawlConfig) GetPriorityWeight ¶
func (m *CrawlConfig) GetPriorityWeight() float64
func (*CrawlConfig) ProtoMessage ¶
func (*CrawlConfig) ProtoMessage()
func (*CrawlConfig) Reset ¶
func (m *CrawlConfig) Reset()
func (*CrawlConfig) String ¶
func (m *CrawlConfig) String() string
func (*CrawlConfig) XXX_DiscardUnknown ¶
func (m *CrawlConfig) XXX_DiscardUnknown()
func (*CrawlConfig) XXX_Marshal ¶
func (m *CrawlConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CrawlConfig) XXX_Merge ¶
func (m *CrawlConfig) XXX_Merge(src proto.Message)
func (*CrawlConfig) XXX_Size ¶
func (m *CrawlConfig) XXX_Size() int
func (*CrawlConfig) XXX_Unmarshal ¶
func (m *CrawlConfig) XXX_Unmarshal(b []byte) error
type CrawlConfigListReply
deprecated
type CrawlConfigListReply struct { Value []*CrawlConfig `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*CrawlConfigListReply) Descriptor ¶
func (*CrawlConfigListReply) Descriptor() ([]byte, []int)
func (*CrawlConfigListReply) GetCount ¶
func (m *CrawlConfigListReply) GetCount() int64
func (*CrawlConfigListReply) GetPage ¶
func (m *CrawlConfigListReply) GetPage() int32
func (*CrawlConfigListReply) GetPageSize ¶
func (m *CrawlConfigListReply) GetPageSize() int32
func (*CrawlConfigListReply) GetValue ¶
func (m *CrawlConfigListReply) GetValue() []*CrawlConfig
func (*CrawlConfigListReply) ProtoMessage ¶
func (*CrawlConfigListReply) ProtoMessage()
func (*CrawlConfigListReply) Reset ¶
func (m *CrawlConfigListReply) Reset()
func (*CrawlConfigListReply) String ¶
func (m *CrawlConfigListReply) String() string
func (*CrawlConfigListReply) XXX_DiscardUnknown ¶
func (m *CrawlConfigListReply) XXX_DiscardUnknown()
func (*CrawlConfigListReply) XXX_Marshal ¶
func (m *CrawlConfigListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CrawlConfigListReply) XXX_Merge ¶
func (m *CrawlConfigListReply) XXX_Merge(src proto.Message)
func (*CrawlConfigListReply) XXX_Size ¶
func (m *CrawlConfigListReply) XXX_Size() int
func (*CrawlConfigListReply) XXX_Unmarshal ¶
func (m *CrawlConfigListReply) XXX_Unmarshal(b []byte) error
type CrawlEntity
deprecated
type CrawlEntity struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Meta *Meta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A crawl entity (might be an organisation with one or more seeds)
Deprecated: Do not use.
func (*CrawlEntity) Descriptor ¶
func (*CrawlEntity) Descriptor() ([]byte, []int)
func (*CrawlEntity) GetId ¶
func (m *CrawlEntity) GetId() string
func (*CrawlEntity) GetMeta ¶
func (m *CrawlEntity) GetMeta() *Meta
func (*CrawlEntity) ProtoMessage ¶
func (*CrawlEntity) ProtoMessage()
func (*CrawlEntity) Reset ¶
func (m *CrawlEntity) Reset()
func (*CrawlEntity) String ¶
func (m *CrawlEntity) String() string
func (*CrawlEntity) XXX_DiscardUnknown ¶
func (m *CrawlEntity) XXX_DiscardUnknown()
func (*CrawlEntity) XXX_Marshal ¶
func (m *CrawlEntity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CrawlEntity) XXX_Merge ¶
func (m *CrawlEntity) XXX_Merge(src proto.Message)
func (*CrawlEntity) XXX_Size ¶
func (m *CrawlEntity) XXX_Size() int
func (*CrawlEntity) XXX_Unmarshal ¶
func (m *CrawlEntity) XXX_Unmarshal(b []byte) error
type CrawlEntityListReply
deprecated
type CrawlEntityListReply struct { Value []*CrawlEntity `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A list of entities
Deprecated: Do not use.
func (*CrawlEntityListReply) Descriptor ¶
func (*CrawlEntityListReply) Descriptor() ([]byte, []int)
func (*CrawlEntityListReply) GetCount ¶
func (m *CrawlEntityListReply) GetCount() int64
func (*CrawlEntityListReply) GetPage ¶
func (m *CrawlEntityListReply) GetPage() int32
func (*CrawlEntityListReply) GetPageSize ¶
func (m *CrawlEntityListReply) GetPageSize() int32
func (*CrawlEntityListReply) GetValue ¶
func (m *CrawlEntityListReply) GetValue() []*CrawlEntity
func (*CrawlEntityListReply) ProtoMessage ¶
func (*CrawlEntityListReply) ProtoMessage()
func (*CrawlEntityListReply) Reset ¶
func (m *CrawlEntityListReply) Reset()
func (*CrawlEntityListReply) String ¶
func (m *CrawlEntityListReply) String() string
func (*CrawlEntityListReply) XXX_DiscardUnknown ¶
func (m *CrawlEntityListReply) XXX_DiscardUnknown()
func (*CrawlEntityListReply) XXX_Marshal ¶
func (m *CrawlEntityListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CrawlEntityListReply) XXX_Merge ¶
func (m *CrawlEntityListReply) XXX_Merge(src proto.Message)
func (*CrawlEntityListReply) XXX_Size ¶
func (m *CrawlEntityListReply) XXX_Size() int
func (*CrawlEntityListReply) XXX_Unmarshal ¶
func (m *CrawlEntityListReply) XXX_Unmarshal(b []byte) error
type CrawlHostGroupConfig
deprecated
type CrawlHostGroupConfig struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Meta *Meta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` IpRange []*CrawlHostGroupConfig_IpRange `protobuf:"bytes,3,rep,name=ip_range,json=ipRange,proto3" json:"ip_range,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*CrawlHostGroupConfig) Descriptor ¶
func (*CrawlHostGroupConfig) Descriptor() ([]byte, []int)
func (*CrawlHostGroupConfig) GetId ¶
func (m *CrawlHostGroupConfig) GetId() string
func (*CrawlHostGroupConfig) GetIpRange ¶
func (m *CrawlHostGroupConfig) GetIpRange() []*CrawlHostGroupConfig_IpRange
func (*CrawlHostGroupConfig) GetMeta ¶
func (m *CrawlHostGroupConfig) GetMeta() *Meta
func (*CrawlHostGroupConfig) ProtoMessage ¶
func (*CrawlHostGroupConfig) ProtoMessage()
func (*CrawlHostGroupConfig) Reset ¶
func (m *CrawlHostGroupConfig) Reset()
func (*CrawlHostGroupConfig) String ¶
func (m *CrawlHostGroupConfig) String() string
func (*CrawlHostGroupConfig) XXX_DiscardUnknown ¶
func (m *CrawlHostGroupConfig) XXX_DiscardUnknown()
func (*CrawlHostGroupConfig) XXX_Marshal ¶
func (m *CrawlHostGroupConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CrawlHostGroupConfig) XXX_Merge ¶
func (m *CrawlHostGroupConfig) XXX_Merge(src proto.Message)
func (*CrawlHostGroupConfig) XXX_Size ¶
func (m *CrawlHostGroupConfig) XXX_Size() int
func (*CrawlHostGroupConfig) XXX_Unmarshal ¶
func (m *CrawlHostGroupConfig) XXX_Unmarshal(b []byte) error
type CrawlHostGroupConfigListReply
deprecated
type CrawlHostGroupConfigListReply struct { Value []*CrawlHostGroupConfig `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A list of CrawlHostGroupConfigs
Deprecated: Do not use.
func (*CrawlHostGroupConfigListReply) Descriptor ¶
func (*CrawlHostGroupConfigListReply) Descriptor() ([]byte, []int)
func (*CrawlHostGroupConfigListReply) GetCount ¶
func (m *CrawlHostGroupConfigListReply) GetCount() int64
func (*CrawlHostGroupConfigListReply) GetPage ¶
func (m *CrawlHostGroupConfigListReply) GetPage() int32
func (*CrawlHostGroupConfigListReply) GetPageSize ¶
func (m *CrawlHostGroupConfigListReply) GetPageSize() int32
func (*CrawlHostGroupConfigListReply) GetValue ¶
func (m *CrawlHostGroupConfigListReply) GetValue() []*CrawlHostGroupConfig
func (*CrawlHostGroupConfigListReply) ProtoMessage ¶
func (*CrawlHostGroupConfigListReply) ProtoMessage()
func (*CrawlHostGroupConfigListReply) Reset ¶
func (m *CrawlHostGroupConfigListReply) Reset()
func (*CrawlHostGroupConfigListReply) String ¶
func (m *CrawlHostGroupConfigListReply) String() string
func (*CrawlHostGroupConfigListReply) XXX_DiscardUnknown ¶
func (m *CrawlHostGroupConfigListReply) XXX_DiscardUnknown()
func (*CrawlHostGroupConfigListReply) XXX_Marshal ¶
func (m *CrawlHostGroupConfigListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CrawlHostGroupConfigListReply) XXX_Merge ¶
func (m *CrawlHostGroupConfigListReply) XXX_Merge(src proto.Message)
func (*CrawlHostGroupConfigListReply) XXX_Size ¶
func (m *CrawlHostGroupConfigListReply) XXX_Size() int
func (*CrawlHostGroupConfigListReply) XXX_Unmarshal ¶
func (m *CrawlHostGroupConfigListReply) XXX_Unmarshal(b []byte) error
type CrawlHostGroupConfig_IpRange ¶
type CrawlHostGroupConfig_IpRange struct { IpFrom string `protobuf:"bytes,1,opt,name=ip_from,json=ipFrom,proto3" json:"ip_from,omitempty"` IpTo string `protobuf:"bytes,2,opt,name=ip_to,json=ipTo,proto3" json:"ip_to,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CrawlHostGroupConfig_IpRange) Descriptor ¶
func (*CrawlHostGroupConfig_IpRange) Descriptor() ([]byte, []int)
func (*CrawlHostGroupConfig_IpRange) GetIpFrom ¶
func (m *CrawlHostGroupConfig_IpRange) GetIpFrom() string
func (*CrawlHostGroupConfig_IpRange) GetIpTo ¶
func (m *CrawlHostGroupConfig_IpRange) GetIpTo() string
func (*CrawlHostGroupConfig_IpRange) ProtoMessage ¶
func (*CrawlHostGroupConfig_IpRange) ProtoMessage()
func (*CrawlHostGroupConfig_IpRange) Reset ¶
func (m *CrawlHostGroupConfig_IpRange) Reset()
func (*CrawlHostGroupConfig_IpRange) String ¶
func (m *CrawlHostGroupConfig_IpRange) String() string
func (*CrawlHostGroupConfig_IpRange) XXX_DiscardUnknown ¶
func (m *CrawlHostGroupConfig_IpRange) XXX_DiscardUnknown()
func (*CrawlHostGroupConfig_IpRange) XXX_Marshal ¶
func (m *CrawlHostGroupConfig_IpRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CrawlHostGroupConfig_IpRange) XXX_Merge ¶
func (m *CrawlHostGroupConfig_IpRange) XXX_Merge(src proto.Message)
func (*CrawlHostGroupConfig_IpRange) XXX_Size ¶
func (m *CrawlHostGroupConfig_IpRange) XXX_Size() int
func (*CrawlHostGroupConfig_IpRange) XXX_Unmarshal ¶
func (m *CrawlHostGroupConfig_IpRange) XXX_Unmarshal(b []byte) error
type CrawlJob
deprecated
type CrawlJob struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Meta *Meta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` ScheduleId string `protobuf:"bytes,3,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"` Limits *CrawlLimitsConfig `protobuf:"bytes,4,opt,name=limits,proto3" json:"limits,omitempty"` CrawlConfigId string `protobuf:"bytes,5,opt,name=crawl_config_id,json=crawlConfigId,proto3" json:"crawl_config_id,omitempty"` Disabled bool `protobuf:"varint,18,opt,name=disabled,proto3" json:"disabled,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*CrawlJob) Descriptor ¶
func (*CrawlJob) GetCrawlConfigId ¶
func (*CrawlJob) GetDisabled ¶
func (*CrawlJob) GetLimits ¶
func (m *CrawlJob) GetLimits() *CrawlLimitsConfig
func (*CrawlJob) GetScheduleId ¶
func (*CrawlJob) ProtoMessage ¶
func (*CrawlJob) ProtoMessage()
func (*CrawlJob) XXX_DiscardUnknown ¶
func (m *CrawlJob) XXX_DiscardUnknown()
func (*CrawlJob) XXX_Marshal ¶
func (*CrawlJob) XXX_Unmarshal ¶
type CrawlJobListReply
deprecated
type CrawlJobListReply struct { Value []*CrawlJob `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*CrawlJobListReply) Descriptor ¶
func (*CrawlJobListReply) Descriptor() ([]byte, []int)
func (*CrawlJobListReply) GetCount ¶
func (m *CrawlJobListReply) GetCount() int64
func (*CrawlJobListReply) GetPage ¶
func (m *CrawlJobListReply) GetPage() int32
func (*CrawlJobListReply) GetPageSize ¶
func (m *CrawlJobListReply) GetPageSize() int32
func (*CrawlJobListReply) GetValue ¶
func (m *CrawlJobListReply) GetValue() []*CrawlJob
func (*CrawlJobListReply) ProtoMessage ¶
func (*CrawlJobListReply) ProtoMessage()
func (*CrawlJobListReply) Reset ¶
func (m *CrawlJobListReply) Reset()
func (*CrawlJobListReply) String ¶
func (m *CrawlJobListReply) String() string
func (*CrawlJobListReply) XXX_DiscardUnknown ¶
func (m *CrawlJobListReply) XXX_DiscardUnknown()
func (*CrawlJobListReply) XXX_Marshal ¶
func (m *CrawlJobListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CrawlJobListReply) XXX_Merge ¶
func (m *CrawlJobListReply) XXX_Merge(src proto.Message)
func (*CrawlJobListReply) XXX_Size ¶
func (m *CrawlJobListReply) XXX_Size() int
func (*CrawlJobListReply) XXX_Unmarshal ¶
func (m *CrawlJobListReply) XXX_Unmarshal(b []byte) error
type CrawlLimitsConfig
deprecated
type CrawlLimitsConfig struct { // How deep from a seed to crawl Depth int32 `protobuf:"varint,1,opt,name=depth,proto3" json:"depth,omitempty"` // Maximum time in seconds allowed for crawl to finish MaxDurationS int64 `protobuf:"varint,2,opt,name=max_duration_s,json=maxDurationS,proto3" json:"max_duration_s,omitempty"` // Maximum number of bytes to fetch before ending crawl MaxBytes int64 `protobuf:"varint,3,opt,name=max_bytes,json=maxBytes,proto3" json:"max_bytes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*CrawlLimitsConfig) Descriptor ¶
func (*CrawlLimitsConfig) Descriptor() ([]byte, []int)
func (*CrawlLimitsConfig) GetDepth ¶
func (m *CrawlLimitsConfig) GetDepth() int32
func (*CrawlLimitsConfig) GetMaxBytes ¶
func (m *CrawlLimitsConfig) GetMaxBytes() int64
func (*CrawlLimitsConfig) GetMaxDurationS ¶
func (m *CrawlLimitsConfig) GetMaxDurationS() int64
func (*CrawlLimitsConfig) ProtoMessage ¶
func (*CrawlLimitsConfig) ProtoMessage()
func (*CrawlLimitsConfig) Reset ¶
func (m *CrawlLimitsConfig) Reset()
func (*CrawlLimitsConfig) String ¶
func (m *CrawlLimitsConfig) String() string
func (*CrawlLimitsConfig) XXX_DiscardUnknown ¶
func (m *CrawlLimitsConfig) XXX_DiscardUnknown()
func (*CrawlLimitsConfig) XXX_Marshal ¶
func (m *CrawlLimitsConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CrawlLimitsConfig) XXX_Merge ¶
func (m *CrawlLimitsConfig) XXX_Merge(src proto.Message)
func (*CrawlLimitsConfig) XXX_Size ¶
func (m *CrawlLimitsConfig) XXX_Size() int
func (*CrawlLimitsConfig) XXX_Unmarshal ¶
func (m *CrawlLimitsConfig) XXX_Unmarshal(b []byte) error
type CrawlLogListReply ¶
type CrawlLogListReply struct { Value []*v1.CrawlLog `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CrawlLogListReply) Descriptor ¶
func (*CrawlLogListReply) Descriptor() ([]byte, []int)
func (*CrawlLogListReply) GetCount ¶
func (m *CrawlLogListReply) GetCount() int64
func (*CrawlLogListReply) GetPage ¶
func (m *CrawlLogListReply) GetPage() int32
func (*CrawlLogListReply) GetPageSize ¶
func (m *CrawlLogListReply) GetPageSize() int32
func (*CrawlLogListReply) GetValue ¶
func (m *CrawlLogListReply) GetValue() []*v1.CrawlLog
func (*CrawlLogListReply) ProtoMessage ¶
func (*CrawlLogListReply) ProtoMessage()
func (*CrawlLogListReply) Reset ¶
func (m *CrawlLogListReply) Reset()
func (*CrawlLogListReply) String ¶
func (m *CrawlLogListReply) String() string
func (*CrawlLogListReply) XXX_DiscardUnknown ¶
func (m *CrawlLogListReply) XXX_DiscardUnknown()
func (*CrawlLogListReply) XXX_Marshal ¶
func (m *CrawlLogListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CrawlLogListReply) XXX_Merge ¶
func (m *CrawlLogListReply) XXX_Merge(src proto.Message)
func (*CrawlLogListReply) XXX_Size ¶
func (m *CrawlLogListReply) XXX_Size() int
func (*CrawlLogListReply) XXX_Unmarshal ¶
func (m *CrawlLogListReply) XXX_Unmarshal(b []byte) error
type CrawlLogListRequest ¶
type CrawlLogListRequest struct { WarcId []string `protobuf:"bytes,1,rep,name=warc_id,json=warcId,proto3" json:"warc_id,omitempty"` ExecutionId string `protobuf:"bytes,2,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"` Filter []*Filter `protobuf:"bytes,3,rep,name=filter,proto3" json:"filter,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CrawlLogListRequest) Descriptor ¶
func (*CrawlLogListRequest) Descriptor() ([]byte, []int)
func (*CrawlLogListRequest) GetExecutionId ¶
func (m *CrawlLogListRequest) GetExecutionId() string
func (*CrawlLogListRequest) GetFilter ¶
func (m *CrawlLogListRequest) GetFilter() []*Filter
func (*CrawlLogListRequest) GetPage ¶
func (m *CrawlLogListRequest) GetPage() int32
func (*CrawlLogListRequest) GetPageSize ¶
func (m *CrawlLogListRequest) GetPageSize() int32
func (*CrawlLogListRequest) GetWarcId ¶
func (m *CrawlLogListRequest) GetWarcId() []string
func (*CrawlLogListRequest) ProtoMessage ¶
func (*CrawlLogListRequest) ProtoMessage()
func (*CrawlLogListRequest) Reset ¶
func (m *CrawlLogListRequest) Reset()
func (*CrawlLogListRequest) String ¶
func (m *CrawlLogListRequest) String() string
func (*CrawlLogListRequest) XXX_DiscardUnknown ¶
func (m *CrawlLogListRequest) XXX_DiscardUnknown()
func (*CrawlLogListRequest) XXX_Marshal ¶
func (m *CrawlLogListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CrawlLogListRequest) XXX_Merge ¶
func (m *CrawlLogListRequest) XXX_Merge(src proto.Message)
func (*CrawlLogListRequest) XXX_Size ¶
func (m *CrawlLogListRequest) XXX_Size() int
func (*CrawlLogListRequest) XXX_Unmarshal ¶
func (m *CrawlLogListRequest) XXX_Unmarshal(b []byte) error
type CrawlScheduleConfig
deprecated
type CrawlScheduleConfig struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Meta *Meta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` CronExpression string `protobuf:"bytes,3,opt,name=cron_expression,json=cronExpression,proto3" json:"cron_expression,omitempty"` ValidFrom *timestamp.Timestamp `protobuf:"bytes,4,opt,name=valid_from,json=validFrom,proto3" json:"valid_from,omitempty"` ValidTo *timestamp.Timestamp `protobuf:"bytes,5,opt,name=valid_to,json=validTo,proto3" json:"valid_to,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*CrawlScheduleConfig) Descriptor ¶
func (*CrawlScheduleConfig) Descriptor() ([]byte, []int)
func (*CrawlScheduleConfig) GetCronExpression ¶
func (m *CrawlScheduleConfig) GetCronExpression() string
func (*CrawlScheduleConfig) GetId ¶
func (m *CrawlScheduleConfig) GetId() string
func (*CrawlScheduleConfig) GetMeta ¶
func (m *CrawlScheduleConfig) GetMeta() *Meta
func (*CrawlScheduleConfig) GetValidFrom ¶
func (m *CrawlScheduleConfig) GetValidFrom() *timestamp.Timestamp
func (*CrawlScheduleConfig) GetValidTo ¶
func (m *CrawlScheduleConfig) GetValidTo() *timestamp.Timestamp
func (*CrawlScheduleConfig) ProtoMessage ¶
func (*CrawlScheduleConfig) ProtoMessage()
func (*CrawlScheduleConfig) Reset ¶
func (m *CrawlScheduleConfig) Reset()
func (*CrawlScheduleConfig) String ¶
func (m *CrawlScheduleConfig) String() string
func (*CrawlScheduleConfig) XXX_DiscardUnknown ¶
func (m *CrawlScheduleConfig) XXX_DiscardUnknown()
func (*CrawlScheduleConfig) XXX_Marshal ¶
func (m *CrawlScheduleConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CrawlScheduleConfig) XXX_Merge ¶
func (m *CrawlScheduleConfig) XXX_Merge(src proto.Message)
func (*CrawlScheduleConfig) XXX_Size ¶
func (m *CrawlScheduleConfig) XXX_Size() int
func (*CrawlScheduleConfig) XXX_Unmarshal ¶
func (m *CrawlScheduleConfig) XXX_Unmarshal(b []byte) error
type CrawlScheduleConfigListReply
deprecated
type CrawlScheduleConfigListReply struct { Value []*CrawlScheduleConfig `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*CrawlScheduleConfigListReply) Descriptor ¶
func (*CrawlScheduleConfigListReply) Descriptor() ([]byte, []int)
func (*CrawlScheduleConfigListReply) GetCount ¶
func (m *CrawlScheduleConfigListReply) GetCount() int64
func (*CrawlScheduleConfigListReply) GetPage ¶
func (m *CrawlScheduleConfigListReply) GetPage() int32
func (*CrawlScheduleConfigListReply) GetPageSize ¶
func (m *CrawlScheduleConfigListReply) GetPageSize() int32
func (*CrawlScheduleConfigListReply) GetValue ¶
func (m *CrawlScheduleConfigListReply) GetValue() []*CrawlScheduleConfig
func (*CrawlScheduleConfigListReply) ProtoMessage ¶
func (*CrawlScheduleConfigListReply) ProtoMessage()
func (*CrawlScheduleConfigListReply) Reset ¶
func (m *CrawlScheduleConfigListReply) Reset()
func (*CrawlScheduleConfigListReply) String ¶
func (m *CrawlScheduleConfigListReply) String() string
func (*CrawlScheduleConfigListReply) XXX_DiscardUnknown ¶
func (m *CrawlScheduleConfigListReply) XXX_DiscardUnknown()
func (*CrawlScheduleConfigListReply) XXX_Marshal ¶
func (m *CrawlScheduleConfigListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CrawlScheduleConfigListReply) XXX_Merge ¶
func (m *CrawlScheduleConfigListReply) XXX_Merge(src proto.Message)
func (*CrawlScheduleConfigListReply) XXX_Size ¶
func (m *CrawlScheduleConfigListReply) XXX_Size() int
func (*CrawlScheduleConfigListReply) XXX_Unmarshal ¶
func (m *CrawlScheduleConfigListReply) XXX_Unmarshal(b []byte) error
type CrawlScope
deprecated
type CrawlScope struct { SurtPrefix string `protobuf:"bytes,1,opt,name=surt_prefix,json=surtPrefix,proto3" json:"surt_prefix,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*CrawlScope) Descriptor ¶
func (*CrawlScope) Descriptor() ([]byte, []int)
func (*CrawlScope) GetSurtPrefix ¶
func (m *CrawlScope) GetSurtPrefix() string
func (*CrawlScope) ProtoMessage ¶
func (*CrawlScope) ProtoMessage()
func (*CrawlScope) Reset ¶
func (m *CrawlScope) Reset()
func (*CrawlScope) String ¶
func (m *CrawlScope) String() string
func (*CrawlScope) XXX_DiscardUnknown ¶
func (m *CrawlScope) XXX_DiscardUnknown()
func (*CrawlScope) XXX_Marshal ¶
func (m *CrawlScope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CrawlScope) XXX_Merge ¶
func (m *CrawlScope) XXX_Merge(src proto.Message)
func (*CrawlScope) XXX_Size ¶
func (m *CrawlScope) XXX_Size() int
func (*CrawlScope) XXX_Unmarshal ¶
func (m *CrawlScope) XXX_Unmarshal(b []byte) error
type ExecuteDbQueryReply ¶
type ExecuteDbQueryReply struct { Record string `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ExecuteDbQueryReply) Descriptor ¶
func (*ExecuteDbQueryReply) Descriptor() ([]byte, []int)
func (*ExecuteDbQueryReply) GetRecord ¶
func (m *ExecuteDbQueryReply) GetRecord() string
func (*ExecuteDbQueryReply) ProtoMessage ¶
func (*ExecuteDbQueryReply) ProtoMessage()
func (*ExecuteDbQueryReply) Reset ¶
func (m *ExecuteDbQueryReply) Reset()
func (*ExecuteDbQueryReply) String ¶
func (m *ExecuteDbQueryReply) String() string
func (*ExecuteDbQueryReply) XXX_DiscardUnknown ¶
func (m *ExecuteDbQueryReply) XXX_DiscardUnknown()
func (*ExecuteDbQueryReply) XXX_Marshal ¶
func (m *ExecuteDbQueryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecuteDbQueryReply) XXX_Merge ¶
func (m *ExecuteDbQueryReply) XXX_Merge(src proto.Message)
func (*ExecuteDbQueryReply) XXX_Size ¶
func (m *ExecuteDbQueryReply) XXX_Size() int
func (*ExecuteDbQueryReply) XXX_Unmarshal ¶
func (m *ExecuteDbQueryReply) XXX_Unmarshal(b []byte) error
type ExecuteDbQueryRequest ¶
type ExecuteDbQueryRequest struct { // The query to execute Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // Maximum number of rows to return. A limit of -1 indicates no limit. If unset or zero, use default limit. Limit int32 `protobuf:"varint,14,opt,name=limit,proto3" json:"limit,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ExecuteDbQueryRequest) Descriptor ¶
func (*ExecuteDbQueryRequest) Descriptor() ([]byte, []int)
func (*ExecuteDbQueryRequest) GetLimit ¶
func (m *ExecuteDbQueryRequest) GetLimit() int32
func (*ExecuteDbQueryRequest) GetQuery ¶
func (m *ExecuteDbQueryRequest) GetQuery() string
func (*ExecuteDbQueryRequest) ProtoMessage ¶
func (*ExecuteDbQueryRequest) ProtoMessage()
func (*ExecuteDbQueryRequest) Reset ¶
func (m *ExecuteDbQueryRequest) Reset()
func (*ExecuteDbQueryRequest) String ¶
func (m *ExecuteDbQueryRequest) String() string
func (*ExecuteDbQueryRequest) XXX_DiscardUnknown ¶
func (m *ExecuteDbQueryRequest) XXX_DiscardUnknown()
func (*ExecuteDbQueryRequest) XXX_Marshal ¶
func (m *ExecuteDbQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecuteDbQueryRequest) XXX_Merge ¶
func (m *ExecuteDbQueryRequest) XXX_Merge(src proto.Message)
func (*ExecuteDbQueryRequest) XXX_Size ¶
func (m *ExecuteDbQueryRequest) XXX_Size() int
func (*ExecuteDbQueryRequest) XXX_Unmarshal ¶
func (m *ExecuteDbQueryRequest) XXX_Unmarshal(b []byte) error
type ExecutionId ¶
type ExecutionId struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Request for getting an execution by id
func (*ExecutionId) Descriptor ¶
func (*ExecutionId) Descriptor() ([]byte, []int)
func (*ExecutionId) GetId ¶
func (m *ExecutionId) GetId() string
func (*ExecutionId) ProtoMessage ¶
func (*ExecutionId) ProtoMessage()
func (*ExecutionId) Reset ¶
func (m *ExecutionId) Reset()
func (*ExecutionId) String ¶
func (m *ExecutionId) String() string
func (*ExecutionId) XXX_DiscardUnknown ¶
func (m *ExecutionId) XXX_DiscardUnknown()
func (*ExecutionId) XXX_Marshal ¶
func (m *ExecutionId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecutionId) XXX_Merge ¶
func (m *ExecutionId) XXX_Merge(src proto.Message)
func (*ExecutionId) XXX_Size ¶
func (m *ExecutionId) XXX_Size() int
func (*ExecutionId) XXX_Unmarshal ¶
func (m *ExecutionId) XXX_Unmarshal(b []byte) error
type ExecutionsListReply ¶
type ExecutionsListReply struct { Value []*v1.CrawlExecutionStatus `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A list of crawl executions
func (*ExecutionsListReply) Descriptor ¶
func (*ExecutionsListReply) Descriptor() ([]byte, []int)
func (*ExecutionsListReply) GetCount ¶
func (m *ExecutionsListReply) GetCount() int64
func (*ExecutionsListReply) GetPage ¶
func (m *ExecutionsListReply) GetPage() int32
func (*ExecutionsListReply) GetPageSize ¶
func (m *ExecutionsListReply) GetPageSize() int32
func (*ExecutionsListReply) GetValue ¶
func (m *ExecutionsListReply) GetValue() []*v1.CrawlExecutionStatus
func (*ExecutionsListReply) ProtoMessage ¶
func (*ExecutionsListReply) ProtoMessage()
func (*ExecutionsListReply) Reset ¶
func (m *ExecutionsListReply) Reset()
func (*ExecutionsListReply) String ¶
func (m *ExecutionsListReply) String() string
func (*ExecutionsListReply) XXX_DiscardUnknown ¶
func (m *ExecutionsListReply) XXX_DiscardUnknown()
func (*ExecutionsListReply) XXX_Marshal ¶
func (m *ExecutionsListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecutionsListReply) XXX_Merge ¶
func (m *ExecutionsListReply) XXX_Merge(src proto.Message)
func (*ExecutionsListReply) XXX_Size ¶
func (m *ExecutionsListReply) XXX_Size() int
func (*ExecutionsListReply) XXX_Unmarshal ¶
func (m *ExecutionsListReply) XXX_Unmarshal(b []byte) error
type ExtraConfig
deprecated
type ExtraConfig struct { ExtractText bool `protobuf:"varint,5,opt,name=extract_text,json=extractText,proto3" json:"extract_text,omitempty"` CreateSnapshot bool `protobuf:"varint,6,opt,name=create_snapshot,json=createSnapshot,proto3" json:"create_snapshot,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*ExtraConfig) Descriptor ¶
func (*ExtraConfig) Descriptor() ([]byte, []int)
func (*ExtraConfig) GetCreateSnapshot ¶
func (m *ExtraConfig) GetCreateSnapshot() bool
func (*ExtraConfig) GetExtractText ¶
func (m *ExtraConfig) GetExtractText() bool
func (*ExtraConfig) ProtoMessage ¶
func (*ExtraConfig) ProtoMessage()
func (*ExtraConfig) Reset ¶
func (m *ExtraConfig) Reset()
func (*ExtraConfig) String ¶
func (m *ExtraConfig) String() string
func (*ExtraConfig) XXX_DiscardUnknown ¶
func (m *ExtraConfig) XXX_DiscardUnknown()
func (*ExtraConfig) XXX_Marshal ¶
func (m *ExtraConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExtraConfig) XXX_Merge ¶
func (m *ExtraConfig) XXX_Merge(src proto.Message)
func (*ExtraConfig) XXX_Size ¶
func (m *ExtraConfig) XXX_Size() int
func (*ExtraConfig) XXX_Unmarshal ¶
func (m *ExtraConfig) XXX_Unmarshal(b []byte) error
type ExtractedText ¶
type ExtractedText struct { WarcId string `protobuf:"bytes,1,opt,name=warc_id,json=warcId,proto3" json:"warc_id,omitempty"` Text string `protobuf:"bytes,2,opt,name=text,proto3" json:"text,omitempty"` SentenceCount int64 `protobuf:"varint,3,opt,name=sentence_count,json=sentenceCount,proto3" json:"sentence_count,omitempty"` WordCount int64 `protobuf:"varint,4,opt,name=word_count,json=wordCount,proto3" json:"word_count,omitempty"` LongWordCount int64 `protobuf:"varint,5,opt,name=long_word_count,json=longWordCount,proto3" json:"long_word_count,omitempty"` CharacterCount int64 `protobuf:"varint,6,opt,name=character_count,json=characterCount,proto3" json:"character_count,omitempty"` Lix int64 `protobuf:"varint,7,opt,name=lix,proto3" json:"lix,omitempty"` Language string `protobuf:"bytes,8,opt,name=language,proto3" json:"language,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ExtractedText) Descriptor ¶
func (*ExtractedText) Descriptor() ([]byte, []int)
func (*ExtractedText) GetCharacterCount ¶
func (m *ExtractedText) GetCharacterCount() int64
func (*ExtractedText) GetLanguage ¶
func (m *ExtractedText) GetLanguage() string
func (*ExtractedText) GetLix ¶
func (m *ExtractedText) GetLix() int64
func (*ExtractedText) GetLongWordCount ¶
func (m *ExtractedText) GetLongWordCount() int64
func (*ExtractedText) GetSentenceCount ¶
func (m *ExtractedText) GetSentenceCount() int64
func (*ExtractedText) GetText ¶
func (m *ExtractedText) GetText() string
func (*ExtractedText) GetWarcId ¶
func (m *ExtractedText) GetWarcId() string
func (*ExtractedText) GetWordCount ¶
func (m *ExtractedText) GetWordCount() int64
func (*ExtractedText) ProtoMessage ¶
func (*ExtractedText) ProtoMessage()
func (*ExtractedText) Reset ¶
func (m *ExtractedText) Reset()
func (*ExtractedText) String ¶
func (m *ExtractedText) String() string
func (*ExtractedText) XXX_DiscardUnknown ¶
func (m *ExtractedText) XXX_DiscardUnknown()
func (*ExtractedText) XXX_Marshal ¶
func (m *ExtractedText) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExtractedText) XXX_Merge ¶
func (m *ExtractedText) XXX_Merge(src proto.Message)
func (*ExtractedText) XXX_Size ¶
func (m *ExtractedText) XXX_Size() int
func (*ExtractedText) XXX_Unmarshal ¶
func (m *ExtractedText) XXX_Unmarshal(b []byte) error
type Filter ¶
type Filter struct { FieldName string `protobuf:"bytes,1,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"` Op Filter_Operator `protobuf:"varint,2,opt,name=op,proto3,enum=veidemann.api.Filter_Operator" json:"op,omitempty"` Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Filter) Descriptor ¶
func (*Filter) GetFieldName ¶
func (*Filter) GetOp ¶
func (m *Filter) GetOp() Filter_Operator
func (*Filter) ProtoMessage ¶
func (*Filter) ProtoMessage()
func (*Filter) XXX_DiscardUnknown ¶
func (m *Filter) XXX_DiscardUnknown()
func (*Filter) XXX_Marshal ¶
func (*Filter) XXX_Unmarshal ¶
type Filter_Operator ¶
type Filter_Operator int32
const ( Filter_EQ Filter_Operator = 0 Filter_NE Filter_Operator = 1 Filter_MATCH Filter_Operator = 2 Filter_LT Filter_Operator = 3 Filter_GT Filter_Operator = 4 )
func (Filter_Operator) EnumDescriptor ¶
func (Filter_Operator) EnumDescriptor() ([]byte, []int)
func (Filter_Operator) String ¶
func (x Filter_Operator) String() string
type GetRequest
deprecated
type GetRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Request for getting an object by id
Deprecated: Do not use.
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetId ¶
func (m *GetRequest) GetId() string
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) String ¶
func (m *GetRequest) String() string
func (*GetRequest) XXX_DiscardUnknown ¶
func (m *GetRequest) XXX_DiscardUnknown()
func (*GetRequest) XXX_Marshal ¶
func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRequest) XXX_Merge ¶
func (m *GetRequest) XXX_Merge(src proto.Message)
func (*GetRequest) XXX_Size ¶
func (m *GetRequest) XXX_Size() int
func (*GetRequest) XXX_Unmarshal ¶
func (m *GetRequest) XXX_Unmarshal(b []byte) error
type JobExecutionsListReply ¶
type JobExecutionsListReply struct { Value []*v1.JobExecutionStatus `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A list of job executions
func (*JobExecutionsListReply) Descriptor ¶
func (*JobExecutionsListReply) Descriptor() ([]byte, []int)
func (*JobExecutionsListReply) GetCount ¶
func (m *JobExecutionsListReply) GetCount() int64
func (*JobExecutionsListReply) GetPage ¶
func (m *JobExecutionsListReply) GetPage() int32
func (*JobExecutionsListReply) GetPageSize ¶
func (m *JobExecutionsListReply) GetPageSize() int32
func (*JobExecutionsListReply) GetValue ¶
func (m *JobExecutionsListReply) GetValue() []*v1.JobExecutionStatus
func (*JobExecutionsListReply) ProtoMessage ¶
func (*JobExecutionsListReply) ProtoMessage()
func (*JobExecutionsListReply) Reset ¶
func (m *JobExecutionsListReply) Reset()
func (*JobExecutionsListReply) String ¶
func (m *JobExecutionsListReply) String() string
func (*JobExecutionsListReply) XXX_DiscardUnknown ¶
func (m *JobExecutionsListReply) XXX_DiscardUnknown()
func (*JobExecutionsListReply) XXX_Marshal ¶
func (m *JobExecutionsListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobExecutionsListReply) XXX_Merge ¶
func (m *JobExecutionsListReply) XXX_Merge(src proto.Message)
func (*JobExecutionsListReply) XXX_Size ¶
func (m *JobExecutionsListReply) XXX_Size() int
func (*JobExecutionsListReply) XXX_Unmarshal ¶
func (m *JobExecutionsListReply) XXX_Unmarshal(b []byte) error
type Label
deprecated
type Label struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*Label) Descriptor ¶
func (*Label) ProtoMessage ¶
func (*Label) ProtoMessage()
func (*Label) XXX_DiscardUnknown ¶
func (m *Label) XXX_DiscardUnknown()
func (*Label) XXX_Marshal ¶
func (*Label) XXX_Unmarshal ¶
type ListExecutionsRequest ¶
type ListExecutionsRequest struct { // Select executions by id Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"` // Select executions by state State []string `protobuf:"bytes,2,rep,name=state,proto3" json:"state,omitempty"` // Select executions by seed SeedId string `protobuf:"bytes,3,opt,name=seed_id,json=seedId,proto3" json:"seed_id,omitempty"` // Select executions by crawl job JobId string `protobuf:"bytes,4,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` // Select executions by job execution JobExecutionId string `protobuf:"bytes,5,opt,name=job_execution_id,json=jobExecutionId,proto3" json:"job_execution_id,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Specification of wich executions to get.
func (*ListExecutionsRequest) Descriptor ¶
func (*ListExecutionsRequest) Descriptor() ([]byte, []int)
func (*ListExecutionsRequest) GetId ¶
func (m *ListExecutionsRequest) GetId() []string
func (*ListExecutionsRequest) GetJobExecutionId ¶
func (m *ListExecutionsRequest) GetJobExecutionId() string
func (*ListExecutionsRequest) GetJobId ¶
func (m *ListExecutionsRequest) GetJobId() string
func (*ListExecutionsRequest) GetPage ¶
func (m *ListExecutionsRequest) GetPage() int32
func (*ListExecutionsRequest) GetPageSize ¶
func (m *ListExecutionsRequest) GetPageSize() int32
func (*ListExecutionsRequest) GetSeedId ¶
func (m *ListExecutionsRequest) GetSeedId() string
func (*ListExecutionsRequest) GetState ¶
func (m *ListExecutionsRequest) GetState() []string
func (*ListExecutionsRequest) ProtoMessage ¶
func (*ListExecutionsRequest) ProtoMessage()
func (*ListExecutionsRequest) Reset ¶
func (m *ListExecutionsRequest) Reset()
func (*ListExecutionsRequest) String ¶
func (m *ListExecutionsRequest) String() string
func (*ListExecutionsRequest) XXX_DiscardUnknown ¶
func (m *ListExecutionsRequest) XXX_DiscardUnknown()
func (*ListExecutionsRequest) XXX_Marshal ¶
func (m *ListExecutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListExecutionsRequest) XXX_Merge ¶
func (m *ListExecutionsRequest) XXX_Merge(src proto.Message)
func (*ListExecutionsRequest) XXX_Size ¶
func (m *ListExecutionsRequest) XXX_Size() int
func (*ListExecutionsRequest) XXX_Unmarshal ¶
func (m *ListExecutionsRequest) XXX_Unmarshal(b []byte) error
type ListJobExecutionsRequest ¶
type ListJobExecutionsRequest struct { // Select job executions by id Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"` // Select job executions by state State []string `protobuf:"bytes,2,rep,name=state,proto3" json:"state,omitempty"` // Select executions by crawl job JobId string `protobuf:"bytes,4,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Specification of wich executions to get.
func (*ListJobExecutionsRequest) Descriptor ¶
func (*ListJobExecutionsRequest) Descriptor() ([]byte, []int)
func (*ListJobExecutionsRequest) GetId ¶
func (m *ListJobExecutionsRequest) GetId() []string
func (*ListJobExecutionsRequest) GetJobId ¶
func (m *ListJobExecutionsRequest) GetJobId() string
func (*ListJobExecutionsRequest) GetPage ¶
func (m *ListJobExecutionsRequest) GetPage() int32
func (*ListJobExecutionsRequest) GetPageSize ¶
func (m *ListJobExecutionsRequest) GetPageSize() int32
func (*ListJobExecutionsRequest) GetState ¶
func (m *ListJobExecutionsRequest) GetState() []string
func (*ListJobExecutionsRequest) ProtoMessage ¶
func (*ListJobExecutionsRequest) ProtoMessage()
func (*ListJobExecutionsRequest) Reset ¶
func (m *ListJobExecutionsRequest) Reset()
func (*ListJobExecutionsRequest) String ¶
func (m *ListJobExecutionsRequest) String() string
func (*ListJobExecutionsRequest) XXX_DiscardUnknown ¶
func (m *ListJobExecutionsRequest) XXX_DiscardUnknown()
func (*ListJobExecutionsRequest) XXX_Marshal ¶
func (m *ListJobExecutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListJobExecutionsRequest) XXX_Merge ¶
func (m *ListJobExecutionsRequest) XXX_Merge(src proto.Message)
func (*ListJobExecutionsRequest) XXX_Size ¶
func (m *ListJobExecutionsRequest) XXX_Size() int
func (*ListJobExecutionsRequest) XXX_Unmarshal ¶
func (m *ListJobExecutionsRequest) XXX_Unmarshal(b []byte) error
type ListRequest
deprecated
type ListRequest struct { // Select objects by id Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"` // Select objects by name // The name query is a case insensitive regular expresion search on name. // <pre> // Examples: // "foo" - matches all names containing the phrase foo // "^foo$" - matches the exact name foo // "foo.*bar$" - matches names containing foo followed by zero or more tokens and ends with bar // </pre> Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Select objects by label // A string representing a label query. The query matches if at least one label matches the query. // If there are multiple queries, then each query must match at least one label. // Label quries are case insensitive. The basic format is <code>key:value</code> where both key and value must match. // If value ends with <code>*</code> then the key must match and value must match up until the <code>*</code>. // If value is empty, all labels matching the key will match. // If key is empty, then the matching is done on the value for all keys. // If key is empty, then the <code>:</code> might be ommitted. // <pre> // Examples: // "foo:bar" - matches exactly labels with key=foo and value=bar // "foo:" - matches all labels with key=foo // ":bar" - matches all labels with value=bar // "bar" - matches all labels with value=bar // "foo:ba*" - matches labels with key=foo and value starting with ba (e.g. matches bar, but not ber) // ":ba*" - matches labels with any key and value starting with ba (e.g. matches bar, but not ber) // "ba*" - matches labels with any key and value starting with ba (e.g. matches bar, but not ber) // ":" - matches every label // "" - matches every label // </pre> LabelSelector []string `protobuf:"bytes,3,rep,name=label_selector,json=labelSelector,proto3" json:"label_selector,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Specification of wich entities to get.
Deprecated: Do not use.
func (*ListRequest) Descriptor ¶
func (*ListRequest) Descriptor() ([]byte, []int)
func (*ListRequest) GetId ¶
func (m *ListRequest) GetId() []string
func (*ListRequest) GetLabelSelector ¶
func (m *ListRequest) GetLabelSelector() []string
func (*ListRequest) GetName ¶
func (m *ListRequest) GetName() string
func (*ListRequest) GetPage ¶
func (m *ListRequest) GetPage() int32
func (*ListRequest) GetPageSize ¶
func (m *ListRequest) GetPageSize() int32
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) Reset ¶
func (m *ListRequest) Reset()
func (*ListRequest) String ¶
func (m *ListRequest) String() string
func (*ListRequest) XXX_DiscardUnknown ¶
func (m *ListRequest) XXX_DiscardUnknown()
func (*ListRequest) XXX_Marshal ¶
func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListRequest) XXX_Merge ¶
func (m *ListRequest) XXX_Merge(src proto.Message)
func (*ListRequest) XXX_Size ¶
func (m *ListRequest) XXX_Size() int
func (*ListRequest) XXX_Unmarshal ¶
func (m *ListRequest) XXX_Unmarshal(b []byte) error
type LogLevels ¶
type LogLevels struct { LogLevel []*LogLevels_LogLevel `protobuf:"bytes,1,rep,name=log_level,json=logLevel,proto3" json:"log_level,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogLevels) Descriptor ¶
func (*LogLevels) GetLogLevel ¶
func (m *LogLevels) GetLogLevel() []*LogLevels_LogLevel
func (*LogLevels) ProtoMessage ¶
func (*LogLevels) ProtoMessage()
func (*LogLevels) XXX_DiscardUnknown ¶
func (m *LogLevels) XXX_DiscardUnknown()
func (*LogLevels) XXX_Marshal ¶
func (*LogLevels) XXX_Unmarshal ¶
type LogLevels_Level ¶
type LogLevels_Level int32
const ( LogLevels_UNDEFINED LogLevels_Level = 0 LogLevels_ALL LogLevels_Level = 1 LogLevels_TRACE LogLevels_Level = 2 LogLevels_DEBUG LogLevels_Level = 3 LogLevels_INFO LogLevels_Level = 4 LogLevels_WARN LogLevels_Level = 5 LogLevels_ERROR LogLevels_Level = 6 LogLevels_FATAL LogLevels_Level = 7 LogLevels_OFF LogLevels_Level = 8 )
func (LogLevels_Level) EnumDescriptor ¶
func (LogLevels_Level) EnumDescriptor() ([]byte, []int)
func (LogLevels_Level) String ¶
func (x LogLevels_Level) String() string
type LogLevels_LogLevel ¶
type LogLevels_LogLevel struct { Logger string `protobuf:"bytes,1,opt,name=logger,proto3" json:"logger,omitempty"` Level LogLevels_Level `protobuf:"varint,2,opt,name=level,proto3,enum=veidemann.api.LogLevels_Level" json:"level,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogLevels_LogLevel) Descriptor ¶
func (*LogLevels_LogLevel) Descriptor() ([]byte, []int)
func (*LogLevels_LogLevel) GetLevel ¶
func (m *LogLevels_LogLevel) GetLevel() LogLevels_Level
func (*LogLevels_LogLevel) GetLogger ¶
func (m *LogLevels_LogLevel) GetLogger() string
func (*LogLevels_LogLevel) ProtoMessage ¶
func (*LogLevels_LogLevel) ProtoMessage()
func (*LogLevels_LogLevel) Reset ¶
func (m *LogLevels_LogLevel) Reset()
func (*LogLevels_LogLevel) String ¶
func (m *LogLevels_LogLevel) String() string
func (*LogLevels_LogLevel) XXX_DiscardUnknown ¶
func (m *LogLevels_LogLevel) XXX_DiscardUnknown()
func (*LogLevels_LogLevel) XXX_Marshal ¶
func (m *LogLevels_LogLevel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogLevels_LogLevel) XXX_Merge ¶
func (m *LogLevels_LogLevel) XXX_Merge(src proto.Message)
func (*LogLevels_LogLevel) XXX_Size ¶
func (m *LogLevels_LogLevel) XXX_Size() int
func (*LogLevels_LogLevel) XXX_Unmarshal ¶
func (m *LogLevels_LogLevel) XXX_Unmarshal(b []byte) error
type Meta ¶
type Meta struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` Created *timestamp.Timestamp `protobuf:"bytes,3,opt,name=created,proto3" json:"created,omitempty"` CreatedBy string `protobuf:"bytes,4,opt,name=created_by,json=createdBy,proto3" json:"created_by,omitempty"` LastModified *timestamp.Timestamp `protobuf:"bytes,5,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"` LastModifiedBy string `protobuf:"bytes,6,opt,name=last_modified_by,json=lastModifiedBy,proto3" json:"last_modified_by,omitempty"` Label []*Label `protobuf:"bytes,7,rep,name=label,proto3" json:"label,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Meta) Descriptor ¶
func (*Meta) GetCreated ¶
func (*Meta) GetCreatedBy ¶
func (*Meta) GetDescription ¶
func (*Meta) GetLastModified ¶
func (*Meta) GetLastModifiedBy ¶
func (*Meta) ProtoMessage ¶
func (*Meta) ProtoMessage()
func (*Meta) XXX_DiscardUnknown ¶
func (m *Meta) XXX_DiscardUnknown()
func (*Meta) XXX_Unmarshal ¶
type OpenIdConnectIssuerReply ¶
type OpenIdConnectIssuerReply struct { OpenIdConnectIssuer string `protobuf:"bytes,1,opt,name=open_id_connect_issuer,json=openIdConnectIssuer,proto3" json:"open_id_connect_issuer,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*OpenIdConnectIssuerReply) Descriptor ¶
func (*OpenIdConnectIssuerReply) Descriptor() ([]byte, []int)
func (*OpenIdConnectIssuerReply) GetOpenIdConnectIssuer ¶
func (m *OpenIdConnectIssuerReply) GetOpenIdConnectIssuer() string
func (*OpenIdConnectIssuerReply) ProtoMessage ¶
func (*OpenIdConnectIssuerReply) ProtoMessage()
func (*OpenIdConnectIssuerReply) Reset ¶
func (m *OpenIdConnectIssuerReply) Reset()
func (*OpenIdConnectIssuerReply) String ¶
func (m *OpenIdConnectIssuerReply) String() string
func (*OpenIdConnectIssuerReply) XXX_DiscardUnknown ¶
func (m *OpenIdConnectIssuerReply) XXX_DiscardUnknown()
func (*OpenIdConnectIssuerReply) XXX_Marshal ¶
func (m *OpenIdConnectIssuerReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OpenIdConnectIssuerReply) XXX_Merge ¶
func (m *OpenIdConnectIssuerReply) XXX_Merge(src proto.Message)
func (*OpenIdConnectIssuerReply) XXX_Size ¶
func (m *OpenIdConnectIssuerReply) XXX_Size() int
func (*OpenIdConnectIssuerReply) XXX_Unmarshal ¶
func (m *OpenIdConnectIssuerReply) XXX_Unmarshal(b []byte) error
type PageLogListReply ¶
type PageLogListReply struct { Value []*v1.PageLog `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PageLogListReply) Descriptor ¶
func (*PageLogListReply) Descriptor() ([]byte, []int)
func (*PageLogListReply) GetCount ¶
func (m *PageLogListReply) GetCount() int64
func (*PageLogListReply) GetPage ¶
func (m *PageLogListReply) GetPage() int32
func (*PageLogListReply) GetPageSize ¶
func (m *PageLogListReply) GetPageSize() int32
func (*PageLogListReply) GetValue ¶
func (m *PageLogListReply) GetValue() []*v1.PageLog
func (*PageLogListReply) ProtoMessage ¶
func (*PageLogListReply) ProtoMessage()
func (*PageLogListReply) Reset ¶
func (m *PageLogListReply) Reset()
func (*PageLogListReply) String ¶
func (m *PageLogListReply) String() string
func (*PageLogListReply) XXX_DiscardUnknown ¶
func (m *PageLogListReply) XXX_DiscardUnknown()
func (*PageLogListReply) XXX_Marshal ¶
func (m *PageLogListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PageLogListReply) XXX_Merge ¶
func (m *PageLogListReply) XXX_Merge(src proto.Message)
func (*PageLogListReply) XXX_Size ¶
func (m *PageLogListReply) XXX_Size() int
func (*PageLogListReply) XXX_Unmarshal ¶
func (m *PageLogListReply) XXX_Unmarshal(b []byte) error
type PageLogListRequest ¶
type PageLogListRequest struct { WarcId []string `protobuf:"bytes,1,rep,name=warc_id,json=warcId,proto3" json:"warc_id,omitempty"` ExecutionId string `protobuf:"bytes,2,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"` Filter []*Filter `protobuf:"bytes,3,rep,name=filter,proto3" json:"filter,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PageLogListRequest) Descriptor ¶
func (*PageLogListRequest) Descriptor() ([]byte, []int)
func (*PageLogListRequest) GetExecutionId ¶
func (m *PageLogListRequest) GetExecutionId() string
func (*PageLogListRequest) GetFilter ¶
func (m *PageLogListRequest) GetFilter() []*Filter
func (*PageLogListRequest) GetPage ¶
func (m *PageLogListRequest) GetPage() int32
func (*PageLogListRequest) GetPageSize ¶
func (m *PageLogListRequest) GetPageSize() int32
func (*PageLogListRequest) GetWarcId ¶
func (m *PageLogListRequest) GetWarcId() []string
func (*PageLogListRequest) ProtoMessage ¶
func (*PageLogListRequest) ProtoMessage()
func (*PageLogListRequest) Reset ¶
func (m *PageLogListRequest) Reset()
func (*PageLogListRequest) String ¶
func (m *PageLogListRequest) String() string
func (*PageLogListRequest) XXX_DiscardUnknown ¶
func (m *PageLogListRequest) XXX_DiscardUnknown()
func (*PageLogListRequest) XXX_Marshal ¶
func (m *PageLogListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PageLogListRequest) XXX_Merge ¶
func (m *PageLogListRequest) XXX_Merge(src proto.Message)
func (*PageLogListRequest) XXX_Size ¶
func (m *PageLogListRequest) XXX_Size() int
func (*PageLogListRequest) XXX_Unmarshal ¶
func (m *PageLogListRequest) XXX_Unmarshal(b []byte) error
type PolitenessConfig
deprecated
type PolitenessConfig struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Meta *Meta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` RobotsPolicy PolitenessConfig_RobotsPolicy `` /* 147-byte string literal not displayed */ MinimumRobotsValidityDurationS int32 `` /* 159-byte string literal not displayed */ CustomRobots string `protobuf:"bytes,20,opt,name=custom_robots,json=customRobots,proto3" json:"custom_robots,omitempty"` MinTimeBetweenPageLoadMs int64 `` /* 142-byte string literal not displayed */ MaxTimeBetweenPageLoadMs int64 `` /* 142-byte string literal not displayed */ //* // The fetch time of the URI is multiplied with this value to get the delay time before fetching the next URI. // If min_time_between_page_load_ms and/or max_time_between_page_load_ms are set, then those values are used as // the upper/lower limits for delay. // If delay_factor is unset or zero, then a delay_facor of one is assumed. If delay_factor is negative, // a delay_factor of zero is assumed. DelayFactor float32 `protobuf:"fixed32,6,opt,name=delay_factor,json=delayFactor,proto3" json:"delay_factor,omitempty"` MaxRetries int32 `protobuf:"varint,7,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"` RetryDelaySeconds int32 `protobuf:"varint,8,opt,name=retry_delay_seconds,json=retryDelaySeconds,proto3" json:"retry_delay_seconds,omitempty"` // Select crawl host groups by label // A string representing a label query. The query matches if at least one label matches the query. // If there are multiple queries, then each query must match at least one label. // Label quries are case insensitive. The basic format is <code>key:value</code> where both key and value must match. // If value ends with <code>*</code> then the key must match and value must match up until the <code>*</code>. // If value is empty, all labels matching the key will match. // If key is empty, then the matching is done on the value for all keys. // If key is empty, then the <code>:</code> might be ommitted. // <pre> // Examples: // "foo:bar" - matches exactly labels with key=foo and value=bar // "foo:" - matches all labels with key=foo // ":bar" - matches all labels with value=bar // "bar" - matches all labels with value=bar // "foo:ba*" - matches labels with key=foo and value starting with ba (e.g. matches bar, but not ber) // ":ba*" - matches labels with any key and value starting with ba (e.g. matches bar, but not ber) // "ba*" - matches labels with any key and value starting with ba (e.g. matches bar, but not ber) // ":" - matches every label // "" - matches every label // </pre> CrawlHostGroupSelector []string `` /* 131-byte string literal not displayed */ // If true, use hostname instead of ip for politeness UseHostname bool `protobuf:"varint,10,opt,name=use_hostname,json=useHostname,proto3" json:"use_hostname,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*PolitenessConfig) Descriptor ¶
func (*PolitenessConfig) Descriptor() ([]byte, []int)
func (*PolitenessConfig) GetCrawlHostGroupSelector ¶
func (m *PolitenessConfig) GetCrawlHostGroupSelector() []string
func (*PolitenessConfig) GetCustomRobots ¶
func (m *PolitenessConfig) GetCustomRobots() string
func (*PolitenessConfig) GetDelayFactor ¶
func (m *PolitenessConfig) GetDelayFactor() float32
func (*PolitenessConfig) GetId ¶
func (m *PolitenessConfig) GetId() string
func (*PolitenessConfig) GetMaxRetries ¶
func (m *PolitenessConfig) GetMaxRetries() int32
func (*PolitenessConfig) GetMaxTimeBetweenPageLoadMs ¶
func (m *PolitenessConfig) GetMaxTimeBetweenPageLoadMs() int64
func (*PolitenessConfig) GetMeta ¶
func (m *PolitenessConfig) GetMeta() *Meta
func (*PolitenessConfig) GetMinTimeBetweenPageLoadMs ¶
func (m *PolitenessConfig) GetMinTimeBetweenPageLoadMs() int64
func (*PolitenessConfig) GetMinimumRobotsValidityDurationS ¶
func (m *PolitenessConfig) GetMinimumRobotsValidityDurationS() int32
func (*PolitenessConfig) GetRetryDelaySeconds ¶
func (m *PolitenessConfig) GetRetryDelaySeconds() int32
func (*PolitenessConfig) GetRobotsPolicy ¶
func (m *PolitenessConfig) GetRobotsPolicy() PolitenessConfig_RobotsPolicy
func (*PolitenessConfig) GetUseHostname ¶
func (m *PolitenessConfig) GetUseHostname() bool
func (*PolitenessConfig) ProtoMessage ¶
func (*PolitenessConfig) ProtoMessage()
func (*PolitenessConfig) Reset ¶
func (m *PolitenessConfig) Reset()
func (*PolitenessConfig) String ¶
func (m *PolitenessConfig) String() string
func (*PolitenessConfig) XXX_DiscardUnknown ¶
func (m *PolitenessConfig) XXX_DiscardUnknown()
func (*PolitenessConfig) XXX_Marshal ¶
func (m *PolitenessConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PolitenessConfig) XXX_Merge ¶
func (m *PolitenessConfig) XXX_Merge(src proto.Message)
func (*PolitenessConfig) XXX_Size ¶
func (m *PolitenessConfig) XXX_Size() int
func (*PolitenessConfig) XXX_Unmarshal ¶
func (m *PolitenessConfig) XXX_Unmarshal(b []byte) error
type PolitenessConfigListReply
deprecated
type PolitenessConfigListReply struct { Value []*PolitenessConfig `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*PolitenessConfigListReply) Descriptor ¶
func (*PolitenessConfigListReply) Descriptor() ([]byte, []int)
func (*PolitenessConfigListReply) GetCount ¶
func (m *PolitenessConfigListReply) GetCount() int64
func (*PolitenessConfigListReply) GetPage ¶
func (m *PolitenessConfigListReply) GetPage() int32
func (*PolitenessConfigListReply) GetPageSize ¶
func (m *PolitenessConfigListReply) GetPageSize() int32
func (*PolitenessConfigListReply) GetValue ¶
func (m *PolitenessConfigListReply) GetValue() []*PolitenessConfig
func (*PolitenessConfigListReply) ProtoMessage ¶
func (*PolitenessConfigListReply) ProtoMessage()
func (*PolitenessConfigListReply) Reset ¶
func (m *PolitenessConfigListReply) Reset()
func (*PolitenessConfigListReply) String ¶
func (m *PolitenessConfigListReply) String() string
func (*PolitenessConfigListReply) XXX_DiscardUnknown ¶
func (m *PolitenessConfigListReply) XXX_DiscardUnknown()
func (*PolitenessConfigListReply) XXX_Marshal ¶
func (m *PolitenessConfigListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PolitenessConfigListReply) XXX_Merge ¶
func (m *PolitenessConfigListReply) XXX_Merge(src proto.Message)
func (*PolitenessConfigListReply) XXX_Size ¶
func (m *PolitenessConfigListReply) XXX_Size() int
func (*PolitenessConfigListReply) XXX_Unmarshal ¶
func (m *PolitenessConfigListReply) XXX_Unmarshal(b []byte) error
type PolitenessConfig_RobotsPolicy ¶
type PolitenessConfig_RobotsPolicy int32
const ( PolitenessConfig_OBEY_ROBOTS PolitenessConfig_RobotsPolicy = 0 PolitenessConfig_IGNORE_ROBOTS PolitenessConfig_RobotsPolicy = 1 PolitenessConfig_CUSTOM_ROBOTS PolitenessConfig_RobotsPolicy = 2 )
func (PolitenessConfig_RobotsPolicy) EnumDescriptor ¶
func (PolitenessConfig_RobotsPolicy) EnumDescriptor() ([]byte, []int)
func (PolitenessConfig_RobotsPolicy) String ¶
func (x PolitenessConfig_RobotsPolicy) String() string
type ReportClient ¶
type ReportClient interface { // List crawl logs ListCrawlLogs(ctx context.Context, in *CrawlLogListRequest, opts ...grpc.CallOption) (*CrawlLogListReply, error) // List page logs ListPageLogs(ctx context.Context, in *PageLogListRequest, opts ...grpc.CallOption) (*PageLogListReply, error) // List screenshots ListScreenshots(ctx context.Context, in *ScreenshotListRequest, opts ...grpc.CallOption) (*ScreenshotListReply, error) // Execute a query against the database ExecuteDbQuery(ctx context.Context, in *ExecuteDbQueryRequest, opts ...grpc.CallOption) (Report_ExecuteDbQueryClient, error) }
ReportClient is the client API for Report service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewReportClient ¶
func NewReportClient(cc *grpc.ClientConn) ReportClient
type ReportServer ¶
type ReportServer interface { // List crawl logs ListCrawlLogs(context.Context, *CrawlLogListRequest) (*CrawlLogListReply, error) // List page logs ListPageLogs(context.Context, *PageLogListRequest) (*PageLogListReply, error) // List screenshots ListScreenshots(context.Context, *ScreenshotListRequest) (*ScreenshotListReply, error) // Execute a query against the database ExecuteDbQuery(*ExecuteDbQueryRequest, Report_ExecuteDbQueryServer) error }
ReportServer is the server API for Report service.
type Report_ExecuteDbQueryClient ¶
type Report_ExecuteDbQueryClient interface { Recv() (*ExecuteDbQueryReply, error) grpc.ClientStream }
type Report_ExecuteDbQueryServer ¶
type Report_ExecuteDbQueryServer interface { Send(*ExecuteDbQueryReply) error grpc.ServerStream }
type RoleList ¶
type RoleList struct { Role []Role `protobuf:"varint,1,rep,packed,name=role,proto3,enum=veidemann.api.Role" json:"role,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RoleList) Descriptor ¶
func (*RoleList) ProtoMessage ¶
func (*RoleList) ProtoMessage()
func (*RoleList) XXX_DiscardUnknown ¶
func (m *RoleList) XXX_DiscardUnknown()
func (*RoleList) XXX_Marshal ¶
func (*RoleList) XXX_Unmarshal ¶
type RoleMapping
deprecated
type RoleMapping struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Types that are valid to be assigned to EmailOrGroup: // *RoleMapping_Email // *RoleMapping_Group EmailOrGroup isRoleMapping_EmailOrGroup `protobuf_oneof:"email_or_group"` Role []Role `protobuf:"varint,4,rep,packed,name=role,proto3,enum=veidemann.api.Role" json:"role,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*RoleMapping) Descriptor ¶
func (*RoleMapping) Descriptor() ([]byte, []int)
func (*RoleMapping) GetEmail ¶
func (m *RoleMapping) GetEmail() string
func (*RoleMapping) GetEmailOrGroup ¶
func (m *RoleMapping) GetEmailOrGroup() isRoleMapping_EmailOrGroup
func (*RoleMapping) GetGroup ¶
func (m *RoleMapping) GetGroup() string
func (*RoleMapping) GetId ¶
func (m *RoleMapping) GetId() string
func (*RoleMapping) GetRole ¶
func (m *RoleMapping) GetRole() []Role
func (*RoleMapping) ProtoMessage ¶
func (*RoleMapping) ProtoMessage()
func (*RoleMapping) Reset ¶
func (m *RoleMapping) Reset()
func (*RoleMapping) String ¶
func (m *RoleMapping) String() string
func (*RoleMapping) XXX_DiscardUnknown ¶
func (m *RoleMapping) XXX_DiscardUnknown()
func (*RoleMapping) XXX_Marshal ¶
func (m *RoleMapping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RoleMapping) XXX_Merge ¶
func (m *RoleMapping) XXX_Merge(src proto.Message)
func (*RoleMapping) XXX_OneofWrappers ¶
func (*RoleMapping) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*RoleMapping) XXX_Size ¶
func (m *RoleMapping) XXX_Size() int
func (*RoleMapping) XXX_Unmarshal ¶
func (m *RoleMapping) XXX_Unmarshal(b []byte) error
type RoleMapping_Email ¶
type RoleMapping_Email struct {
Email string `protobuf:"bytes,2,opt,name=email,proto3,oneof"`
}
type RoleMapping_Group ¶
type RoleMapping_Group struct {
Group string `protobuf:"bytes,3,opt,name=group,proto3,oneof"`
}
type RoleMappingsListReply
deprecated
type RoleMappingsListReply struct { Value []*RoleMapping `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*RoleMappingsListReply) Descriptor ¶
func (*RoleMappingsListReply) Descriptor() ([]byte, []int)
func (*RoleMappingsListReply) GetCount ¶
func (m *RoleMappingsListReply) GetCount() int64
func (*RoleMappingsListReply) GetPage ¶
func (m *RoleMappingsListReply) GetPage() int32
func (*RoleMappingsListReply) GetPageSize ¶
func (m *RoleMappingsListReply) GetPageSize() int32
func (*RoleMappingsListReply) GetValue ¶
func (m *RoleMappingsListReply) GetValue() []*RoleMapping
func (*RoleMappingsListReply) ProtoMessage ¶
func (*RoleMappingsListReply) ProtoMessage()
func (*RoleMappingsListReply) Reset ¶
func (m *RoleMappingsListReply) Reset()
func (*RoleMappingsListReply) String ¶
func (m *RoleMappingsListReply) String() string
func (*RoleMappingsListReply) XXX_DiscardUnknown ¶
func (m *RoleMappingsListReply) XXX_DiscardUnknown()
func (*RoleMappingsListReply) XXX_Marshal ¶
func (m *RoleMappingsListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RoleMappingsListReply) XXX_Merge ¶
func (m *RoleMappingsListReply) XXX_Merge(src proto.Message)
func (*RoleMappingsListReply) XXX_Size ¶
func (m *RoleMappingsListReply) XXX_Size() int
func (*RoleMappingsListReply) XXX_Unmarshal ¶
func (m *RoleMappingsListReply) XXX_Unmarshal(b []byte) error
type RoleMappingsListRequest
deprecated
type RoleMappingsListRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*RoleMappingsListRequest) Descriptor ¶
func (*RoleMappingsListRequest) Descriptor() ([]byte, []int)
func (*RoleMappingsListRequest) GetId ¶
func (m *RoleMappingsListRequest) GetId() string
func (*RoleMappingsListRequest) GetPage ¶
func (m *RoleMappingsListRequest) GetPage() int32
func (*RoleMappingsListRequest) GetPageSize ¶
func (m *RoleMappingsListRequest) GetPageSize() int32
func (*RoleMappingsListRequest) ProtoMessage ¶
func (*RoleMappingsListRequest) ProtoMessage()
func (*RoleMappingsListRequest) Reset ¶
func (m *RoleMappingsListRequest) Reset()
func (*RoleMappingsListRequest) String ¶
func (m *RoleMappingsListRequest) String() string
func (*RoleMappingsListRequest) XXX_DiscardUnknown ¶
func (m *RoleMappingsListRequest) XXX_DiscardUnknown()
func (*RoleMappingsListRequest) XXX_Marshal ¶
func (m *RoleMappingsListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RoleMappingsListRequest) XXX_Merge ¶
func (m *RoleMappingsListRequest) XXX_Merge(src proto.Message)
func (*RoleMappingsListRequest) XXX_Size ¶
func (m *RoleMappingsListRequest) XXX_Size() int
func (*RoleMappingsListRequest) XXX_Unmarshal ¶
func (m *RoleMappingsListRequest) XXX_Unmarshal(b []byte) error
type RunCrawlReply ¶
type RunCrawlReply struct { JobExecutionId string `protobuf:"bytes,1,opt,name=job_execution_id,json=jobExecutionId,proto3" json:"job_execution_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RunCrawlReply) Descriptor ¶
func (*RunCrawlReply) Descriptor() ([]byte, []int)
func (*RunCrawlReply) GetJobExecutionId ¶
func (m *RunCrawlReply) GetJobExecutionId() string
func (*RunCrawlReply) ProtoMessage ¶
func (*RunCrawlReply) ProtoMessage()
func (*RunCrawlReply) Reset ¶
func (m *RunCrawlReply) Reset()
func (*RunCrawlReply) String ¶
func (m *RunCrawlReply) String() string
func (*RunCrawlReply) XXX_DiscardUnknown ¶
func (m *RunCrawlReply) XXX_DiscardUnknown()
func (*RunCrawlReply) XXX_Marshal ¶
func (m *RunCrawlReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RunCrawlReply) XXX_Merge ¶
func (m *RunCrawlReply) XXX_Merge(src proto.Message)
func (*RunCrawlReply) XXX_Size ¶
func (m *RunCrawlReply) XXX_Size() int
func (*RunCrawlReply) XXX_Unmarshal ¶
func (m *RunCrawlReply) XXX_Unmarshal(b []byte) error
type RunCrawlRequest ¶
type RunCrawlRequest struct { JobId string `protobuf:"bytes,5,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` // If seed id is submitted, only this seed will be harvested. // If empty, all seeds configured with the submitted job id will be harvested. SeedId string `protobuf:"bytes,6,opt,name=seed_id,json=seedId,proto3" json:"seed_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Cick of a crawl job immediately
func (*RunCrawlRequest) Descriptor ¶
func (*RunCrawlRequest) Descriptor() ([]byte, []int)
func (*RunCrawlRequest) GetJobId ¶
func (m *RunCrawlRequest) GetJobId() string
func (*RunCrawlRequest) GetSeedId ¶
func (m *RunCrawlRequest) GetSeedId() string
func (*RunCrawlRequest) ProtoMessage ¶
func (*RunCrawlRequest) ProtoMessage()
func (*RunCrawlRequest) Reset ¶
func (m *RunCrawlRequest) Reset()
func (*RunCrawlRequest) String ¶
func (m *RunCrawlRequest) String() string
func (*RunCrawlRequest) XXX_DiscardUnknown ¶
func (m *RunCrawlRequest) XXX_DiscardUnknown()
func (*RunCrawlRequest) XXX_Marshal ¶
func (m *RunCrawlRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RunCrawlRequest) XXX_Merge ¶
func (m *RunCrawlRequest) XXX_Merge(src proto.Message)
func (*RunCrawlRequest) XXX_Size ¶
func (m *RunCrawlRequest) XXX_Size() int
func (*RunCrawlRequest) XXX_Unmarshal ¶
func (m *RunCrawlRequest) XXX_Unmarshal(b []byte) error
type RunningExecutionsListReply ¶
type RunningExecutionsListReply struct { Value []*StatusDetail `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RunningExecutionsListReply) Descriptor ¶
func (*RunningExecutionsListReply) Descriptor() ([]byte, []int)
func (*RunningExecutionsListReply) GetCount ¶
func (m *RunningExecutionsListReply) GetCount() int64
func (*RunningExecutionsListReply) GetPage ¶
func (m *RunningExecutionsListReply) GetPage() int32
func (*RunningExecutionsListReply) GetPageSize ¶
func (m *RunningExecutionsListReply) GetPageSize() int32
func (*RunningExecutionsListReply) GetValue ¶
func (m *RunningExecutionsListReply) GetValue() []*StatusDetail
func (*RunningExecutionsListReply) ProtoMessage ¶
func (*RunningExecutionsListReply) ProtoMessage()
func (*RunningExecutionsListReply) Reset ¶
func (m *RunningExecutionsListReply) Reset()
func (*RunningExecutionsListReply) String ¶
func (m *RunningExecutionsListReply) String() string
func (*RunningExecutionsListReply) XXX_DiscardUnknown ¶
func (m *RunningExecutionsListReply) XXX_DiscardUnknown()
func (*RunningExecutionsListReply) XXX_Marshal ¶
func (m *RunningExecutionsListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RunningExecutionsListReply) XXX_Merge ¶
func (m *RunningExecutionsListReply) XXX_Merge(src proto.Message)
func (*RunningExecutionsListReply) XXX_Size ¶
func (m *RunningExecutionsListReply) XXX_Size() int
func (*RunningExecutionsListReply) XXX_Unmarshal ¶
func (m *RunningExecutionsListReply) XXX_Unmarshal(b []byte) error
type RunningExecutionsRequest ¶
type RunningExecutionsRequest struct { PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RunningExecutionsRequest) Descriptor ¶
func (*RunningExecutionsRequest) Descriptor() ([]byte, []int)
func (*RunningExecutionsRequest) GetPage ¶
func (m *RunningExecutionsRequest) GetPage() int32
func (*RunningExecutionsRequest) GetPageSize ¶
func (m *RunningExecutionsRequest) GetPageSize() int32
func (*RunningExecutionsRequest) ProtoMessage ¶
func (*RunningExecutionsRequest) ProtoMessage()
func (*RunningExecutionsRequest) Reset ¶
func (m *RunningExecutionsRequest) Reset()
func (*RunningExecutionsRequest) String ¶
func (m *RunningExecutionsRequest) String() string
func (*RunningExecutionsRequest) XXX_DiscardUnknown ¶
func (m *RunningExecutionsRequest) XXX_DiscardUnknown()
func (*RunningExecutionsRequest) XXX_Marshal ¶
func (m *RunningExecutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RunningExecutionsRequest) XXX_Merge ¶
func (m *RunningExecutionsRequest) XXX_Merge(src proto.Message)
func (*RunningExecutionsRequest) XXX_Size ¶
func (m *RunningExecutionsRequest) XXX_Size() int
func (*RunningExecutionsRequest) XXX_Unmarshal ¶
func (m *RunningExecutionsRequest) XXX_Unmarshal(b []byte) error
type Screenshot ¶
type Screenshot struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ExecutionId string `protobuf:"bytes,2,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"` Uri string `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"` Img []byte `protobuf:"bytes,4,opt,name=img,proto3" json:"img,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Screenshot) Descriptor ¶
func (*Screenshot) Descriptor() ([]byte, []int)
func (*Screenshot) GetExecutionId ¶
func (m *Screenshot) GetExecutionId() string
func (*Screenshot) GetId ¶
func (m *Screenshot) GetId() string
func (*Screenshot) GetImg ¶
func (m *Screenshot) GetImg() []byte
func (*Screenshot) GetUri ¶
func (m *Screenshot) GetUri() string
func (*Screenshot) ProtoMessage ¶
func (*Screenshot) ProtoMessage()
func (*Screenshot) Reset ¶
func (m *Screenshot) Reset()
func (*Screenshot) String ¶
func (m *Screenshot) String() string
func (*Screenshot) XXX_DiscardUnknown ¶
func (m *Screenshot) XXX_DiscardUnknown()
func (*Screenshot) XXX_Marshal ¶
func (m *Screenshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Screenshot) XXX_Merge ¶
func (m *Screenshot) XXX_Merge(src proto.Message)
func (*Screenshot) XXX_Size ¶
func (m *Screenshot) XXX_Size() int
func (*Screenshot) XXX_Unmarshal ¶
func (m *Screenshot) XXX_Unmarshal(b []byte) error
type ScreenshotListReply ¶
type ScreenshotListReply struct { Value []*Screenshot `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ScreenshotListReply) Descriptor ¶
func (*ScreenshotListReply) Descriptor() ([]byte, []int)
func (*ScreenshotListReply) GetCount ¶
func (m *ScreenshotListReply) GetCount() int64
func (*ScreenshotListReply) GetPage ¶
func (m *ScreenshotListReply) GetPage() int32
func (*ScreenshotListReply) GetPageSize ¶
func (m *ScreenshotListReply) GetPageSize() int32
func (*ScreenshotListReply) GetValue ¶
func (m *ScreenshotListReply) GetValue() []*Screenshot
func (*ScreenshotListReply) ProtoMessage ¶
func (*ScreenshotListReply) ProtoMessage()
func (*ScreenshotListReply) Reset ¶
func (m *ScreenshotListReply) Reset()
func (*ScreenshotListReply) String ¶
func (m *ScreenshotListReply) String() string
func (*ScreenshotListReply) XXX_DiscardUnknown ¶
func (m *ScreenshotListReply) XXX_DiscardUnknown()
func (*ScreenshotListReply) XXX_Marshal ¶
func (m *ScreenshotListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ScreenshotListReply) XXX_Merge ¶
func (m *ScreenshotListReply) XXX_Merge(src proto.Message)
func (*ScreenshotListReply) XXX_Size ¶
func (m *ScreenshotListReply) XXX_Size() int
func (*ScreenshotListReply) XXX_Unmarshal ¶
func (m *ScreenshotListReply) XXX_Unmarshal(b []byte) error
type ScreenshotListRequest ¶
type ScreenshotListRequest struct { Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"` ExecutionId string `protobuf:"bytes,2,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"` Filter []*Filter `protobuf:"bytes,3,rep,name=filter,proto3" json:"filter,omitempty"` ImgData bool `protobuf:"varint,4,opt,name=img_data,json=imgData,proto3" json:"img_data,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ScreenshotListRequest) Descriptor ¶
func (*ScreenshotListRequest) Descriptor() ([]byte, []int)
func (*ScreenshotListRequest) GetExecutionId ¶
func (m *ScreenshotListRequest) GetExecutionId() string
func (*ScreenshotListRequest) GetFilter ¶
func (m *ScreenshotListRequest) GetFilter() []*Filter
func (*ScreenshotListRequest) GetId ¶
func (m *ScreenshotListRequest) GetId() []string
func (*ScreenshotListRequest) GetImgData ¶
func (m *ScreenshotListRequest) GetImgData() bool
func (*ScreenshotListRequest) GetPage ¶
func (m *ScreenshotListRequest) GetPage() int32
func (*ScreenshotListRequest) GetPageSize ¶
func (m *ScreenshotListRequest) GetPageSize() int32
func (*ScreenshotListRequest) ProtoMessage ¶
func (*ScreenshotListRequest) ProtoMessage()
func (*ScreenshotListRequest) Reset ¶
func (m *ScreenshotListRequest) Reset()
func (*ScreenshotListRequest) String ¶
func (m *ScreenshotListRequest) String() string
func (*ScreenshotListRequest) XXX_DiscardUnknown ¶
func (m *ScreenshotListRequest) XXX_DiscardUnknown()
func (*ScreenshotListRequest) XXX_Marshal ¶
func (m *ScreenshotListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ScreenshotListRequest) XXX_Merge ¶
func (m *ScreenshotListRequest) XXX_Merge(src proto.Message)
func (*ScreenshotListRequest) XXX_Size ¶
func (m *ScreenshotListRequest) XXX_Size() int
func (*ScreenshotListRequest) XXX_Unmarshal ¶
func (m *ScreenshotListRequest) XXX_Unmarshal(b []byte) error
type Seed
deprecated
type Seed struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Meta *Meta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` EntityId string `protobuf:"bytes,3,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"` Scope *CrawlScope `protobuf:"bytes,4,opt,name=scope,proto3" json:"scope,omitempty"` JobId []string `protobuf:"bytes,5,rep,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` Disabled bool `protobuf:"varint,18,opt,name=disabled,proto3" json:"disabled,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*Seed) Descriptor ¶
func (*Seed) GetDisabled ¶
func (*Seed) GetEntityId ¶
func (*Seed) GetScope ¶
func (m *Seed) GetScope() *CrawlScope
func (*Seed) ProtoMessage ¶
func (*Seed) ProtoMessage()
func (*Seed) XXX_DiscardUnknown ¶
func (m *Seed) XXX_DiscardUnknown()
func (*Seed) XXX_Unmarshal ¶
type SeedListReply
deprecated
type SeedListReply struct { Value []*Seed `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*SeedListReply) Descriptor ¶
func (*SeedListReply) Descriptor() ([]byte, []int)
func (*SeedListReply) GetCount ¶
func (m *SeedListReply) GetCount() int64
func (*SeedListReply) GetPage ¶
func (m *SeedListReply) GetPage() int32
func (*SeedListReply) GetPageSize ¶
func (m *SeedListReply) GetPageSize() int32
func (*SeedListReply) GetValue ¶
func (m *SeedListReply) GetValue() []*Seed
func (*SeedListReply) ProtoMessage ¶
func (*SeedListReply) ProtoMessage()
func (*SeedListReply) Reset ¶
func (m *SeedListReply) Reset()
func (*SeedListReply) String ¶
func (m *SeedListReply) String() string
func (*SeedListReply) XXX_DiscardUnknown ¶
func (m *SeedListReply) XXX_DiscardUnknown()
func (*SeedListReply) XXX_Marshal ¶
func (m *SeedListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SeedListReply) XXX_Merge ¶
func (m *SeedListReply) XXX_Merge(src proto.Message)
func (*SeedListReply) XXX_Size ¶
func (m *SeedListReply) XXX_Size() int
func (*SeedListReply) XXX_Unmarshal ¶
func (m *SeedListReply) XXX_Unmarshal(b []byte) error
type SeedListRequest
deprecated
type SeedListRequest struct { // Select objects by id Id []string `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"` // Select objects by name // The name query is a case insensitive regular expresion search on name. // <pre> // Examples: // "foo" - matches all names containing the phrase foo // "^foo$" - matches the exact name foo // "foo.*bar$" - matches names containing foo followed by zero or more tokens and ends with bar // </pre> Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Select objects by label // A string representing a label query. The query matches if at least one label matches the query. // If there are multiple queries, then each query must match at least one label. // Label quries are case insensitive. The basic format is <code>key:value</code> where both key and value must match. // If value ends with <code>*</code> then the key must match and value must match up until the <code>*</code>. // If value is empty, all labels matching the key will match. // If key is empty, then the matching is done on the value for all keys. // If key is empty, then the <code>:</code> might be ommitted. // <pre> // Examples: // "foo:bar" - matches exactly labels with key=foo and value=bar // "foo:" - matches all labels with key=foo // ":bar" - matches all labels with value=bar // "bar" - matches all labels with value=bar // "foo:ba*" - matches labels with key=foo and value starting with ba (e.g. matches bar, but not ber) // ":ba*" - matches labels with any key and value starting with ba (e.g. matches bar, but not ber) // "ba*" - matches labels with any key and value starting with ba (e.g. matches bar, but not ber) // ":" - matches every label // "" - matches every label // </pre> LabelSelector []string `protobuf:"bytes,3,rep,name=label_selector,json=labelSelector,proto3" json:"label_selector,omitempty"` // Select objects by crawl job id CrawlJobId string `protobuf:"bytes,4,opt,name=crawl_job_id,json=crawlJobId,proto3" json:"crawl_job_id,omitempty"` // Select objects by entity id EntityId string `protobuf:"bytes,5,opt,name=entity_id,json=entityId,proto3" json:"entity_id,omitempty"` PageSize int32 `protobuf:"varint,14,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` Page int32 `protobuf:"varint,15,opt,name=page,proto3" json:"page,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Deprecated: Do not use.
func (*SeedListRequest) Descriptor ¶
func (*SeedListRequest) Descriptor() ([]byte, []int)
func (*SeedListRequest) GetCrawlJobId ¶
func (m *SeedListRequest) GetCrawlJobId() string
func (*SeedListRequest) GetEntityId ¶
func (m *SeedListRequest) GetEntityId() string
func (*SeedListRequest) GetId ¶
func (m *SeedListRequest) GetId() []string
func (*SeedListRequest) GetLabelSelector ¶
func (m *SeedListRequest) GetLabelSelector() []string
func (*SeedListRequest) GetName ¶
func (m *SeedListRequest) GetName() string
func (*SeedListRequest) GetPage ¶
func (m *SeedListRequest) GetPage() int32
func (*SeedListRequest) GetPageSize ¶
func (m *SeedListRequest) GetPageSize() int32
func (*SeedListRequest) ProtoMessage ¶
func (*SeedListRequest) ProtoMessage()
func (*SeedListRequest) Reset ¶
func (m *SeedListRequest) Reset()
func (*SeedListRequest) String ¶
func (m *SeedListRequest) String() string
func (*SeedListRequest) XXX_DiscardUnknown ¶
func (m *SeedListRequest) XXX_DiscardUnknown()
func (*SeedListRequest) XXX_Marshal ¶
func (m *SeedListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SeedListRequest) XXX_Merge ¶
func (m *SeedListRequest) XXX_Merge(src proto.Message)
func (*SeedListRequest) XXX_Size ¶
func (m *SeedListRequest) XXX_Size() int
func (*SeedListRequest) XXX_Unmarshal ¶
func (m *SeedListRequest) XXX_Unmarshal(b []byte) error
type StatusClient ¶
type StatusClient interface { // Get status of running crawls GetRunningExecutions(ctx context.Context, in *RunningExecutionsRequest, opts ...grpc.CallOption) (Status_GetRunningExecutionsClient, error) // Get a crawl execution by ID GetExecution(ctx context.Context, in *ExecutionId, opts ...grpc.CallOption) (*v1.CrawlExecutionStatus, error) // List a set of crawl executions ListExecutions(ctx context.Context, in *ListExecutionsRequest, opts ...grpc.CallOption) (*ExecutionsListReply, error) // Abort a crawl execution AbortExecution(ctx context.Context, in *ExecutionId, opts ...grpc.CallOption) (*v1.CrawlExecutionStatus, error) // Get a job execution by ID GetJobExecution(ctx context.Context, in *ExecutionId, opts ...grpc.CallOption) (*v1.JobExecutionStatus, error) // List a set of job executions ListJobExecutions(ctx context.Context, in *ListJobExecutionsRequest, opts ...grpc.CallOption) (*JobExecutionsListReply, error) // Abort a job execution AbortJobExecution(ctx context.Context, in *ExecutionId, opts ...grpc.CallOption) (*v1.JobExecutionStatus, error) }
StatusClient is the client API for Status service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewStatusClient ¶
func NewStatusClient(cc *grpc.ClientConn) StatusClient
type StatusDetail ¶
type StatusDetail struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` State v1.CrawlExecutionStatus_State `protobuf:"varint,2,opt,name=state,proto3,enum=veidemann.api.frontier.v1.CrawlExecutionStatus_State" json:"state,omitempty"` JobId string `protobuf:"bytes,3,opt,name=jobId,proto3" json:"jobId,omitempty"` Seed string `protobuf:"bytes,4,opt,name=seed,proto3" json:"seed,omitempty"` StartTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` EndTime *timestamp.Timestamp `protobuf:"bytes,6,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` DocumentsCrawled int64 `protobuf:"varint,7,opt,name=documents_crawled,json=documentsCrawled,proto3" json:"documents_crawled,omitempty"` BytesCrawled int64 `protobuf:"varint,8,opt,name=bytes_crawled,json=bytesCrawled,proto3" json:"bytes_crawled,omitempty"` UrisCrawled int64 `protobuf:"varint,9,opt,name=uris_crawled,json=urisCrawled,proto3" json:"uris_crawled,omitempty"` DocumentsFailed int64 `protobuf:"varint,10,opt,name=documents_failed,json=documentsFailed,proto3" json:"documents_failed,omitempty"` DocumentsOutOfScope int64 `protobuf:"varint,11,opt,name=documents_out_of_scope,json=documentsOutOfScope,proto3" json:"documents_out_of_scope,omitempty"` DocumentsRetried int64 `protobuf:"varint,12,opt,name=documents_retried,json=documentsRetried,proto3" json:"documents_retried,omitempty"` DocumentsDenied int64 `protobuf:"varint,13,opt,name=documents_denied,json=documentsDenied,proto3" json:"documents_denied,omitempty"` QueueSize int64 `protobuf:"varint,14,opt,name=queue_size,json=queueSize,proto3" json:"queue_size,omitempty"` CurrentUri string `protobuf:"bytes,20,opt,name=current_uri,json=currentUri,proto3" json:"current_uri,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StatusDetail) Descriptor ¶
func (*StatusDetail) Descriptor() ([]byte, []int)
func (*StatusDetail) GetBytesCrawled ¶
func (m *StatusDetail) GetBytesCrawled() int64
func (*StatusDetail) GetCurrentUri ¶
func (m *StatusDetail) GetCurrentUri() string
func (*StatusDetail) GetDocumentsCrawled ¶
func (m *StatusDetail) GetDocumentsCrawled() int64
func (*StatusDetail) GetDocumentsDenied ¶
func (m *StatusDetail) GetDocumentsDenied() int64
func (*StatusDetail) GetDocumentsFailed ¶
func (m *StatusDetail) GetDocumentsFailed() int64
func (*StatusDetail) GetDocumentsOutOfScope ¶
func (m *StatusDetail) GetDocumentsOutOfScope() int64
func (*StatusDetail) GetDocumentsRetried ¶
func (m *StatusDetail) GetDocumentsRetried() int64
func (*StatusDetail) GetEndTime ¶
func (m *StatusDetail) GetEndTime() *timestamp.Timestamp
func (*StatusDetail) GetId ¶
func (m *StatusDetail) GetId() string
func (*StatusDetail) GetJobId ¶
func (m *StatusDetail) GetJobId() string
func (*StatusDetail) GetQueueSize ¶
func (m *StatusDetail) GetQueueSize() int64
func (*StatusDetail) GetSeed ¶
func (m *StatusDetail) GetSeed() string
func (*StatusDetail) GetStartTime ¶
func (m *StatusDetail) GetStartTime() *timestamp.Timestamp
func (*StatusDetail) GetState ¶
func (m *StatusDetail) GetState() v1.CrawlExecutionStatus_State
func (*StatusDetail) GetUrisCrawled ¶
func (m *StatusDetail) GetUrisCrawled() int64
func (*StatusDetail) ProtoMessage ¶
func (*StatusDetail) ProtoMessage()
func (*StatusDetail) Reset ¶
func (m *StatusDetail) Reset()
func (*StatusDetail) String ¶
func (m *StatusDetail) String() string
func (*StatusDetail) XXX_DiscardUnknown ¶
func (m *StatusDetail) XXX_DiscardUnknown()
func (*StatusDetail) XXX_Marshal ¶
func (m *StatusDetail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusDetail) XXX_Merge ¶
func (m *StatusDetail) XXX_Merge(src proto.Message)
func (*StatusDetail) XXX_Size ¶
func (m *StatusDetail) XXX_Size() int
func (*StatusDetail) XXX_Unmarshal ¶
func (m *StatusDetail) XXX_Unmarshal(b []byte) error
type StatusServer ¶
type StatusServer interface { // Get status of running crawls GetRunningExecutions(*RunningExecutionsRequest, Status_GetRunningExecutionsServer) error // Get a crawl execution by ID GetExecution(context.Context, *ExecutionId) (*v1.CrawlExecutionStatus, error) // List a set of crawl executions ListExecutions(context.Context, *ListExecutionsRequest) (*ExecutionsListReply, error) // Abort a crawl execution AbortExecution(context.Context, *ExecutionId) (*v1.CrawlExecutionStatus, error) // Get a job execution by ID GetJobExecution(context.Context, *ExecutionId) (*v1.JobExecutionStatus, error) // List a set of job executions ListJobExecutions(context.Context, *ListJobExecutionsRequest) (*JobExecutionsListReply, error) // Abort a job execution AbortJobExecution(context.Context, *ExecutionId) (*v1.JobExecutionStatus, error) }
StatusServer is the server API for Status service.
type Status_GetRunningExecutionsClient ¶
type Status_GetRunningExecutionsClient interface { Recv() (*RunningExecutionsListReply, error) grpc.ClientStream }
type Status_GetRunningExecutionsServer ¶
type Status_GetRunningExecutionsServer interface { Send(*RunningExecutionsListReply) error grpc.ServerStream }