veidemann_api

package
v1.0.0-beta9 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Filter_Operator_name = map[int32]string{
	0: "EQ",
	1: "NE",
	2: "MATCH",
	3: "LT",
	4: "GT",
}
View Source
var Filter_Operator_value = map[string]int32{
	"EQ":    0,
	"NE":    1,
	"MATCH": 2,
	"LT":    3,
	"GT":    4,
}
View Source
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",
}
View Source
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,
}
View Source
var PolitenessConfig_RobotsPolicy_name = map[int32]string{
	0: "OBEY_ROBOTS",
	1: "IGNORE_ROBOTS",
	2: "CUSTOM_ROBOTS",
}
View Source
var PolitenessConfig_RobotsPolicy_value = map[string]int32{
	"OBEY_ROBOTS":   0,
	"IGNORE_ROBOTS": 1,
	"CUSTOM_ROBOTS": 2,
}
View Source
var Role_name = map[int32]string{
	0: "ANY_USER",
	1: "ANY",
	2: "ADMIN",
	3: "CURATOR",
	4: "READONLY",
}
View Source
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>&ast;</code> then the key must match and value must match up until the <code>&ast;</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 (*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 (*CrawlHostGroupConfigListReply) ProtoMessage

func (*CrawlHostGroupConfigListReply) ProtoMessage()

func (*CrawlHostGroupConfigListReply) Reset

func (m *CrawlHostGroupConfigListReply) Reset()

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

func (*CrawlJob) GetCrawlConfigId

func (m *CrawlJob) GetCrawlConfigId() string

func (*CrawlJob) GetDisabled

func (m *CrawlJob) GetDisabled() bool

func (*CrawlJob) GetId

func (m *CrawlJob) GetId() string

func (*CrawlJob) GetLimits

func (m *CrawlJob) GetLimits() *CrawlLimitsConfig

func (*CrawlJob) GetMeta

func (m *CrawlJob) GetMeta() *Meta

func (*CrawlJob) GetScheduleId

func (m *CrawlJob) GetScheduleId() string

func (*CrawlJob) ProtoMessage

func (*CrawlJob) ProtoMessage()

func (*CrawlJob) Reset

func (m *CrawlJob) Reset()

func (*CrawlJob) String

func (m *CrawlJob) String() string

func (*CrawlJob) XXX_DiscardUnknown

func (m *CrawlJob) XXX_DiscardUnknown()

func (*CrawlJob) XXX_Marshal

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

func (*CrawlJob) XXX_Merge

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

func (*CrawlJob) XXX_Size

func (m *CrawlJob) XXX_Size() int

func (*CrawlJob) XXX_Unmarshal

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

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 (*CrawlScheduleConfigListReply) ProtoMessage

func (*CrawlScheduleConfigListReply) ProtoMessage()

func (*CrawlScheduleConfigListReply) Reset

func (m *CrawlScheduleConfigListReply) Reset()

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

func (*Filter) GetFieldName

func (m *Filter) GetFieldName() string

func (*Filter) GetOp

func (m *Filter) GetOp() Filter_Operator

func (*Filter) GetValue

func (m *Filter) GetValue() string

func (*Filter) ProtoMessage

func (*Filter) ProtoMessage()

func (*Filter) Reset

func (m *Filter) Reset()

func (*Filter) String

func (m *Filter) String() string

func (*Filter) XXX_DiscardUnknown

func (m *Filter) XXX_DiscardUnknown()

func (*Filter) XXX_Marshal

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

func (*Filter) XXX_Merge

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

func (*Filter) XXX_Size

func (m *Filter) XXX_Size() int

func (*Filter) XXX_Unmarshal

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

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

func (*Label) GetKey

func (m *Label) GetKey() string

func (*Label) GetValue

func (m *Label) GetValue() string

func (*Label) ProtoMessage

func (*Label) ProtoMessage()

func (*Label) Reset

func (m *Label) Reset()

func (*Label) String

func (m *Label) String() string

func (*Label) XXX_DiscardUnknown

func (m *Label) XXX_DiscardUnknown()

func (*Label) XXX_Marshal

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

func (*Label) XXX_Merge

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

func (*Label) XXX_Size

func (m *Label) XXX_Size() int

func (*Label) XXX_Unmarshal

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

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>&ast;</code> then the key must match and value must match up until the <code>&ast;</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) Descriptor() ([]byte, []int)

func (*LogLevels) GetLogLevel

func (m *LogLevels) GetLogLevel() []*LogLevels_LogLevel

func (*LogLevels) ProtoMessage

func (*LogLevels) ProtoMessage()

func (*LogLevels) Reset

func (m *LogLevels) Reset()

func (*LogLevels) String

func (m *LogLevels) String() string

func (*LogLevels) XXX_DiscardUnknown

func (m *LogLevels) XXX_DiscardUnknown()

func (*LogLevels) XXX_Marshal

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

func (*LogLevels) XXX_Merge

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

func (*LogLevels) XXX_Size

func (m *LogLevels) XXX_Size() int

func (*LogLevels) XXX_Unmarshal

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

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

func (*Meta) GetCreated

func (m *Meta) GetCreated() *timestamp.Timestamp

func (*Meta) GetCreatedBy

func (m *Meta) GetCreatedBy() string

func (*Meta) GetDescription

func (m *Meta) GetDescription() string

func (*Meta) GetLabel

func (m *Meta) GetLabel() []*Label

func (*Meta) GetLastModified

func (m *Meta) GetLastModified() *timestamp.Timestamp

func (*Meta) GetLastModifiedBy

func (m *Meta) GetLastModifiedBy() string

func (*Meta) GetName

func (m *Meta) GetName() string

func (*Meta) ProtoMessage

func (*Meta) ProtoMessage()

func (*Meta) Reset

func (m *Meta) Reset()

func (*Meta) String

func (m *Meta) String() string

func (*Meta) XXX_DiscardUnknown

func (m *Meta) XXX_DiscardUnknown()

func (*Meta) XXX_Marshal

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

func (*Meta) XXX_Merge

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

func (*Meta) XXX_Size

func (m *Meta) XXX_Size() int

func (*Meta) XXX_Unmarshal

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

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>&ast;</code> then the key must match and value must match up until the <code>&ast;</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 (*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

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 Role

type Role int32 // Deprecated: Do not use.
const (
	// Any authenticated user
	Role_ANY_USER Role = 0
	// Any user including unauthenticated users
	Role_ANY Role = 1
	// Administrator
	Role_ADMIN Role = 2
	// Curator
	Role_CURATOR Role = 3
	// A user with permission to read internal data
	Role_READONLY Role = 4
)

func (Role) EnumDescriptor

func (Role) EnumDescriptor() ([]byte, []int)

func (Role) String

func (x Role) String() string

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

func (*RoleList) GetRole

func (m *RoleList) GetRole() []Role

func (*RoleList) ProtoMessage

func (*RoleList) ProtoMessage()

func (*RoleList) Reset

func (m *RoleList) Reset()

func (*RoleList) String

func (m *RoleList) String() string

func (*RoleList) XXX_DiscardUnknown

func (m *RoleList) XXX_DiscardUnknown()

func (*RoleList) XXX_Marshal

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

func (*RoleList) XXX_Merge

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

func (*RoleList) XXX_Size

func (m *RoleList) XXX_Size() int

func (*RoleList) XXX_Unmarshal

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

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

func (*Seed) GetDisabled

func (m *Seed) GetDisabled() bool

func (*Seed) GetEntityId

func (m *Seed) GetEntityId() string

func (*Seed) GetId

func (m *Seed) GetId() string

func (*Seed) GetJobId

func (m *Seed) GetJobId() []string

func (*Seed) GetMeta

func (m *Seed) GetMeta() *Meta

func (*Seed) GetScope

func (m *Seed) GetScope() *CrawlScope

func (*Seed) ProtoMessage

func (*Seed) ProtoMessage()

func (*Seed) Reset

func (m *Seed) Reset()

func (*Seed) String

func (m *Seed) String() string

func (*Seed) XXX_DiscardUnknown

func (m *Seed) XXX_DiscardUnknown()

func (*Seed) XXX_Marshal

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

func (*Seed) XXX_Merge

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

func (*Seed) XXX_Size

func (m *Seed) XXX_Size() int

func (*Seed) XXX_Unmarshal

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

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>&ast;</code> then the key must match and value must match up until the <code>&ast;</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 (*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
}

Jump to

Keyboard shortcuts

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