index

type BoolQueryV1 struct {
	Must               []*QueryV1 `protobuf:"bytes,1,rep,name=must,proto3" json:"must,omitempty"`
	MustNot            []*QueryV1 `protobuf:"bytes,2,rep,name=must_not,json=mustNot,proto3" json:"must_not,omitempty"`
	Should             []*QueryV1 `protobuf:"bytes,3,rep,name=should,proto3" json:"should,omitempty"`
	Filter             []*QueryV1 `protobuf:"bytes,4,rep,name=filter,proto3" json:"filter,omitempty"`
	MinimumShouldMatch int64      `protobuf:"varint,5,opt,name=minimum_should_match,json=minimumShouldMatch,proto3" json:"minimum_should_match,omitempty"`
	// contains filtered or unexported fields
}

type Cluster struct {

	// Name used to identify the cluster.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Endpoint for the cluster.
	Endpoint string `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Number of index sets in the cluster.
	IndexSetCount int64 `protobuf:"varint,3,opt,name=index_set_count,json=indexSetCount,proto3" json:"index_set_count,omitempty"`
	// Auth options for the cluster.
	Auth *ClusterAuth `protobuf:"bytes,4,opt,name=auth,proto3" json:"auth,omitempty"`
	// contains filtered or unexported fields
}

type ClusterAuth struct {

	// IAM authentication.
	Iam bool `protobuf:"varint,1,opt,name=iam,proto3" json:"iam,omitempty"`
	// contains filtered or unexported fields
}

type DeleteClusterRequest struct {

	// Name of the cluster to delete.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type DeleteClusterResponse struct {
	// contains filtered or unexported fields
}

type DeleteIndexSetRequest struct {

	// Name of the index set to delete.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type DeleteIndexSetResponse struct {
	// contains filtered or unexported fields
}

type EnabledFilter int32

type EndSubscriptionRequest struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type EndSubscriptionResponse struct {
	// contains filtered or unexported fields
}

type FieldValuesV1 struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

type Fuzziness struct {

	// Edits is the maximum allowed Levenshtein Edit Distance (or number of
	// edits).
	Edits int64 `protobuf:"varint,1,opt,name=edits,proto3" json:"edits,omitempty"`
	// contains filtered or unexported fields
}

type GetMappingsRequestV1 struct {
	DocumentType string `protobuf:"bytes,1,opt,name=document_type,json=documentType,proto3" json:"document_type,omitempty"`
	// contains filtered or unexported fields
}

type GetMappingsResponseV1 struct {
	Properties []*MappingPropertyV1 `protobuf:"bytes,1,rep,name=properties,proto3" json:"properties,omitempty"`
	// contains filtered or unexported fields
}

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

type HitV1 struct {
	Id       string                    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Score    float32                   `protobuf:"fixed32,2,opt,name=score,proto3" json:"score,omitempty"`
	Fields   map[string]*FieldValuesV1 `` /* 139-byte string literal not displayed */
	Source   map[string]*FieldValuesV1 `` /* 139-byte string literal not displayed */
	Sort     []string                  `protobuf:"bytes,5,rep,name=sort,proto3" json:"sort,omitempty"`
	Document *newsdoc.Document         `protobuf:"bytes,6,opt,name=document,proto3" json:"document,omitempty"`
	// contains filtered or unexported fields
}

type HitsTotalV1 struct {
	Value    int64  `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	Relation string `protobuf:"bytes,2,opt,name=relation,proto3" json:"relation,omitempty"`
	// contains filtered or unexported fields
}

type HitsV1 struct {
	Total    *HitsTotalV1 `protobuf:"bytes,1,opt,name=total,proto3" json:"total,omitempty"`
	MaxScore float32      `protobuf:"fixed32,2,opt,name=max_score,json=maxScore,proto3" json:"max_score,omitempty"`
	Hits     []*HitV1     `protobuf:"bytes,3,rep,name=hits,proto3" json:"hits,omitempty"`
	// contains filtered or unexported fields
}

type IndexSet struct {

	// Name of the index set.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Cluster that the index set has been created in.
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Enabled status of the index set.
	Enabled bool `protobuf:"varint,3,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Active status of the index set.
	Active bool `protobuf:"varint,4,opt,name=active,proto3" json:"active,omitempty"`
	// Position in the repository content log.
	Position int64 `protobuf:"varint,5,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

type ListClustersRequest struct {
	// contains filtered or unexported fields
}

type ListClustersResponse struct {
	Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

type ListIndexSetsRequest struct {

	// Cluster can be used to filter by cluster.
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// OnlyActive only returns the currently active index set.
	OnlyActive bool `protobuf:"varint,2,opt,name=only_active,json=onlyActive,proto3" json:"only_active,omitempty"`
	// Status can be used to filter index sets by their enabled/disabled status.
	Status EnabledFilter `protobuf:"varint,3,opt,name=status,proto3,enum=elephant.index.EnabledFilter" json:"status,omitempty"`
	// Cursor to the page that should be returned. Omit to get the first page.
	Cursor string `protobuf:"bytes,4,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

type ListIndexSetsResponse struct {

	// IndexSets that matched the criteria.
	IndexSets []*IndexSet `protobuf:"bytes,1,rep,name=index_sets,json=indexSets,proto3" json:"index_sets,omitempty"`
	// NextPage cursor to use to get the next page of index sets. Empty if no more
	// index sets exist.
	NextPage string `protobuf:"bytes,2,opt,name=next_page,json=nextPage,proto3" json:"next_page,omitempty"`
	// contains filtered or unexported fields
}

type Management interface {
	// RegisterCluster for use with index sets.
	RegisterCluster(context.Context, *RegisterClusterRequest) (*RegisterClusterResponse, error)

	// ListClusters returns a list of clusters together with information about the
	// number of index sets they contain.
	ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)

	// DeleteCluster deletes a registered cluster. A cluster cannot be deleted as
	// long as it has associated index sets.
	DeleteCluster(context.Context, *DeleteClusterRequest) (*DeleteClusterResponse, error)

	// DeleteIndexSet deletes an index set. The set cannot be active or enabled.
	DeleteIndexSet(context.Context, *DeleteIndexSetRequest) (*DeleteIndexSetResponse, error)

	// Reindex set creates a new index set in the specified cluster and starts
	// indexing documents to it.
	Reindex(context.Context, *ReindexRequest) (*ReindexResponse, error)

	// PartialReindex restarts an existing index set from a given point in the
	// repository eventlog.
	PartialReindex(context.Context, *PartialReindexRequest) (*PartialReindexResponse, error)

	// ListIndexSets lists the available index set, with optional filtering.
	ListIndexSets(context.Context, *ListIndexSetsRequest) (*ListIndexSetsResponse, error)

	// SetIndexSetStatus is used to change the status of an index set.
	SetIndexSetStatus(context.Context, *SetIndexSetStatusRequest) (*SetIndexSetStatusResponse, error)
}

type MappingFieldV1 struct {

	// Name of the field.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of the field. Does not exactly correspond to Open Search types, but
	// represents the logical type.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

type MappingPropertyV1 struct {

	// Name of the property.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of the property.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Path used for alias properties.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// Fields used for alternate indexing metods for the property.
	Fields []*MappingFieldV1 `protobuf:"bytes,4,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

type MatchAllQueryV1 struct {
	// contains filtered or unexported fields
}

type MatchPhraseQueryV1 struct {
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type MatchQueryV1 struct {
	Field string  `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Value string  `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Boost float64 `protobuf:"fixed64,3,opt,name=boost,proto3" json:"boost,omitempty"`
	// contains filtered or unexported fields
}

type MultiMatchQueryV1 struct {
	Fields []string `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	// Type is the multi-match query type. Valid values are best_fields,
	// most_fields, cross_fields, phrase, phrase_prefix, bool_prefix. Default is
	// best_fields.
	Type  string  `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Query string  `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	Boost float64 `protobuf:"fixed64,4,opt,name=boost,proto3" json:"boost,omitempty"`
	// BooleanAnd can be used to require all terms to match.
	BooleanAnd bool `protobuf:"varint,5,opt,name=boolean_and,json=booleanAnd,proto3" json:"boolean_and,omitempty"`
	// MinimumShouldMatch if the query string contains multiple search terms and
	// you use the or operator, the number of terms that need to match for the
	// document to be considered a match. See
	// https://opensearch.org/docs/latest/query-dsl/minimum-should-match/
	MinimumShouldMatch string  `protobuf:"bytes,6,opt,name=minimum_should_match,json=minimumShouldMatch,proto3" json:"minimum_should_match,omitempty"`
	TieBreaker         float32 `protobuf:"fixed32,7,opt,name=tie_breaker,json=tieBreaker,proto3" json:"tie_breaker,omitempty"`
	// PrefixLength is the number of beginning characters left unchanged for fuzzy
	// matching. Optional, defaults to 0.
	PrefixLength int64 `protobuf:"varint,8,opt,name=prefix_length,json=prefixLength,proto3" json:"prefix_length,omitempty"`
	// Fuzziness is the maximum edit distance allowed for matching.
	Fuzziness *Fuzziness `protobuf:"bytes,9,opt,name=fuzziness,proto3" json:"fuzziness,omitempty"`
	// contains filtered or unexported fields
}

type MultiSearchRequest struct {
	Queries []*QueryRequestV1 `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
	// contains filtered or unexported fields
}

type MultiSearchResponse struct {
	Results []*QueryResponseV1 `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

type PartialReindexRequest struct {

	// IndexSet to re-index.
	IndexSet string `protobuf:"bytes,1,opt,name=index_set,json=indexSet,proto3" json:"index_set,omitempty"`
	// Position to start from.
	Position int64 `protobuf:"varint,2,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

type PartialReindexResponse struct {
	// contains filtered or unexported fields
}

type PollSubscriptionRequest struct {

	// Subscriptions to poll.
	Subscriptions []*SubscriptionReference `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// MaxWaitMS is the maximum time to wait before returning an empty
	// response. Optional, defaults to 10s.
	MaxWaitMs int64 `protobuf:"varint,2,opt,name=max_wait_ms,json=maxWaitMs,proto3" json:"max_wait_ms,omitempty"`
	// BatchDelayMS is the number of milliseconds to wait for more items after the
	// first. Optional, defaults to 200ms.
	BatchDelayMs int64 `protobuf:"varint,3,opt,name=batch_delay_ms,json=batchDelayMs,proto3" json:"batch_delay_ms,omitempty"`
	// NotifyOnly will skip loading any data to include with the hits.
	NotifyOnly bool `protobuf:"varint,4,opt,name=notify_only,json=notifyOnly,proto3" json:"notify_only,omitempty"`
	// contains filtered or unexported fields
}

type PollSubscriptionResponse struct {

	// Results will be empty if the poll timed out.
	Result []*SubscriptionPollResult `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
	// List of subscriptions that are unknown, have expired f.ex.
	UnknownSubscriptions []int64 `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

type PrefixQueryV1 struct {
	Field           string  `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Value           string  `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	CaseInsensitive bool    `protobuf:"varint,3,opt,name=case_insensitive,json=caseInsensitive,proto3" json:"case_insensitive,omitempty"`
	Boost           float64 `protobuf:"fixed64,4,opt,name=boost,proto3" json:"boost,omitempty"`
	// contains filtered or unexported fields
}

type QueryRequestV1 struct {
	DocumentType string       `protobuf:"bytes,1,opt,name=document_type,json=documentType,proto3" json:"document_type,omitempty"`
	Language     string       `protobuf:"bytes,2,opt,name=language,proto3" json:"language,omitempty"`
	Query        *QueryV1     `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	Fields       []string     `protobuf:"bytes,4,rep,name=fields,proto3" json:"fields,omitempty"`
	Sort         []*SortingV1 `protobuf:"bytes,5,rep,name=sort,proto3" json:"sort,omitempty"`
	Source       bool         `protobuf:"varint,6,opt,name=source,proto3" json:"source,omitempty"`
	From         int64        `protobuf:"varint,7,opt,name=from,proto3" json:"from,omitempty"`
	Size         int64        `protobuf:"varint,8,opt,name=size,proto3" json:"size,omitempty"`
	SearchAfter  []string     `protobuf:"bytes,9,rep,name=search_after,json=searchAfter,proto3" json:"search_after,omitempty"`
	// LoadDocument will load the current version of the document from the
	// repository and include it with the search response.
	LoadDocument bool `protobuf:"varint,10,opt,name=load_document,json=loadDocument,proto3" json:"load_document,omitempty"`
	// Subscribe starts a subscription for the query.
	Subscribe bool `protobuf:"varint,11,opt,name=subscribe,proto3" json:"subscribe,omitempty"`
	// Shared performs the query without the identity of the user, allows for
	// better query caching and shared subscriptions.
	Shared bool `protobuf:"varint,12,opt,name=shared,proto3" json:"shared,omitempty"`
	// contains filtered or unexported fields
}

type QueryResponseV1 struct {
	Took     int64     `protobuf:"varint,1,opt,name=took,proto3" json:"took,omitempty"`
	TimedOut bool      `protobuf:"varint,2,opt,name=timed_out,json=timedOut,proto3" json:"timed_out,omitempty"`
	Shards   *ShardsV1 `protobuf:"bytes,3,opt,name=shards,proto3" json:"shards,omitempty"`
	Hits     *HitsV1   `protobuf:"bytes,4,opt,name=hits,proto3" json:"hits,omitempty"`
	// Subsciption for search results, if any was started.
	Subscription *SubscriptionReference `protobuf:"bytes,5,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// contains filtered or unexported fields
}

type QueryV1 struct {

	// Types that are valid to be assigned to Conditions:
	//
	//	*QueryV1_Bool
	//	*QueryV1_Range
	//	*QueryV1_Exists
	//	*QueryV1_MatchAll
	//	*QueryV1_Term
	//	*QueryV1_Terms
	//	*QueryV1_Match
	//	*QueryV1_MatchPhrase
	//	*QueryV1_QueryString
	//	*QueryV1_Prefix
	//	*QueryV1_MultiMatch
	Conditions isQueryV1_Conditions `protobuf_oneof:"conditions"`
	// contains filtered or unexported fields
}

type QueryV1_Bool struct {
	Bool *BoolQueryV1 `protobuf:"bytes,1,opt,name=bool,proto3,oneof"`
}

type QueryV1_Exists struct {
	Exists string `protobuf:"bytes,3,opt,name=exists,proto3,oneof"`
}

type QueryV1_Match struct {
	Match *MatchQueryV1 `protobuf:"bytes,7,opt,name=match,proto3,oneof"`
}

type QueryV1_MatchAll struct {
	MatchAll *MatchAllQueryV1 `protobuf:"bytes,4,opt,name=match_all,json=matchAll,proto3,oneof"`
}

type QueryV1_MatchPhrase struct {
	MatchPhrase *MatchPhraseQueryV1 `protobuf:"bytes,8,opt,name=match_phrase,json=matchPhrase,proto3,oneof"`
}

type QueryV1_MultiMatch struct {
	MultiMatch *MultiMatchQueryV1 `protobuf:"bytes,11,opt,name=multi_match,json=multiMatch,proto3,oneof"`
}

type QueryV1_Prefix struct {
	Prefix *PrefixQueryV1 `protobuf:"bytes,10,opt,name=prefix,proto3,oneof"`
}

type QueryV1_QueryString struct {
	QueryString string `protobuf:"bytes,9,opt,name=query_string,json=queryString,proto3,oneof"`
}

type QueryV1_Range struct {
	Range *RangeQueryV1 `protobuf:"bytes,2,opt,name=range,proto3,oneof"`
}

type QueryV1_Term struct {
	Term *TermQueryV1 `protobuf:"bytes,5,opt,name=term,proto3,oneof"`
}

type QueryV1_Terms struct {
	Terms *TermsQueryV1 `protobuf:"bytes,6,opt,name=terms,proto3,oneof"`
}

type RangeQueryV1 struct {
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Gt    string `protobuf:"bytes,2,opt,name=gt,proto3" json:"gt,omitempty"`
	Gte   string `protobuf:"bytes,3,opt,name=gte,proto3" json:"gte,omitempty"`
	Lt    string `protobuf:"bytes,4,opt,name=lt,proto3" json:"lt,omitempty"`
	Lte   string `protobuf:"bytes,5,opt,name=lte,proto3" json:"lte,omitempty"`
	// contains filtered or unexported fields
}

type RegisterClusterAuth struct {

	// IAM authentication.
	Iam bool `protobuf:"varint,1,opt,name=iam,proto3" json:"iam,omitempty"`
	// contains filtered or unexported fields
}

type RegisterClusterRequest struct {

	// Name used to identify the cluster.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Endpoint for the cluster.
	Endpoint string `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Auth is used to specify the authentication method.
	Auth *RegisterClusterAuth `protobuf:"bytes,3,opt,name=auth,proto3" json:"auth,omitempty"`
	// contains filtered or unexported fields
}

type RegisterClusterResponse struct {
	// contains filtered or unexported fields
}

type ReindexRequest struct {

	// Cluster that we should re-index set to.
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

type ReindexResponse struct {

	// Name of the new index set.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type SearchV1 interface {
	Query(context.Context, *QueryRequestV1) (*QueryResponseV1, error)

	MultiSearch(context.Context, *MultiSearchRequest) (*MultiSearchResponse, error)

	GetMappings(context.Context, *GetMappingsRequestV1) (*GetMappingsResponseV1, error)

	PollSubscription(context.Context, *PollSubscriptionRequest) (*PollSubscriptionResponse, error)

	EndSubscription(context.Context, *EndSubscriptionRequest) (*EndSubscriptionResponse, error)
}

type SetIndexSetStatusRequest struct {

	// Name of the index set to set the status of.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Active means that search requests are being routed to this index set. There
	// is always exactly one active index set at a time. Setting an index set to
	// active will deactivate but not disable the currently active index set.
	Active bool `protobuf:"varint,2,opt,name=active,proto3" json:"active,omitempty"`
	// ForceActive is used to force the activation of an index set that lags more
	// than 10 events behind the currently active set.
	ForceActive bool `protobuf:"varint,3,opt,name=force_active,json=forceActive,proto3" json:"force_active,omitempty"`
	// Enabled means that documents should index to the index set. Disabling an
	// index set will only pause index seting, and it can later be
	// resumed. Disabling an index set does not deactivate it.
	Enabled bool `protobuf:"varint,4,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

type SetIndexSetStatusResponse struct {
	// contains filtered or unexported fields
}

type ShardsV1 struct {
	Total      int32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Successful int32 `protobuf:"varint,2,opt,name=successful,proto3" json:"successful,omitempty"`
	Skipped    int32 `protobuf:"varint,3,opt,name=skipped,proto3" json:"skipped,omitempty"`
	Failed     int32 `protobuf:"varint,4,opt,name=failed,proto3" json:"failed,omitempty"`
	// contains filtered or unexported fields
}

type SortingV1 struct {
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Desc  bool   `protobuf:"varint,2,opt,name=desc,proto3" json:"desc,omitempty"`
	// contains filtered or unexported fields
}

type SubscriptionItem struct {
	Id       string                    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Match    bool                      `protobuf:"varint,2,opt,name=match,proto3" json:"match,omitempty"`
	Fields   map[string]*FieldValuesV1 `` /* 139-byte string literal not displayed */
	Source   map[string]*FieldValuesV1 `` /* 139-byte string literal not displayed */
	Document *newsdoc.Document         `protobuf:"bytes,5,opt,name=document,proto3" json:"document,omitempty"`
	// contains filtered or unexported fields
}

type SubscriptionPollResult struct {

	// Subscription with current cursor position.
	Subscription *SubscriptionReference `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// Items that matched or stopped matching the subscription.
	Items []*SubscriptionItem `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

type SubscriptionReference struct {

	// ID of the subscription.
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Cursor for current subscription position.
	Cursor int64 `protobuf:"varint,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

type TermQueryV1 struct {
	Field string  `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Value string  `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Boost float64 `protobuf:"fixed64,3,opt,name=boost,proto3" json:"boost,omitempty"`
	// contains filtered or unexported fields
}

type TermsQueryV1 struct {
	Field  string   `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Values []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	Boost  float64  `protobuf:"fixed64,3,opt,name=boost,proto3" json:"boost,omitempty"`
	// contains filtered or unexported fields
}

type TwirpServer interface {
	http.Handler

	// ServiceDescriptor returns gzipped bytes describing the .proto file that
	// this service was generated from. Once unzipped, the bytes can be
	// unmarshalled as a
	// google.golang.org/protobuf/types/descriptorpb.FileDescriptorProto.
	//
	// The returned integer is the index of this particular service within that
	// FileDescriptorProto's 'Service' slice of ServiceDescriptorProtos. This is a
	// low-level field, expected to be used for reflection.
	ServiceDescriptor() ([]byte, int)

	// ProtocGenTwirpVersion is the semantic version string of the version of
	// twirp used to generate this file.
	ProtocGenTwirpVersion() string

	// PathPrefix returns the HTTP URL path prefix for all methods handled by this
	// service. This can be used with an HTTP mux to route Twirp requests.
	// The path prefix is in the form: "/<prefix>/<package>.<Service>/"
	// that is, everything in a Twirp route except for the <Method> at the end.
	PathPrefix() string
}