Documentation
¶
Index ¶
- Constants
- Variables
- func WriteError(resp http.ResponseWriter, err error)
- type BoolQueryV1
- func (*BoolQueryV1) Descriptor() ([]byte, []int)deprecated
- func (x *BoolQueryV1) GetFilter() []*QueryV1
- func (x *BoolQueryV1) GetMust() []*QueryV1
- func (x *BoolQueryV1) GetMustNot() []*QueryV1
- func (x *BoolQueryV1) GetShould() []*QueryV1
- func (*BoolQueryV1) ProtoMessage()
- func (x *BoolQueryV1) ProtoReflect() protoreflect.Message
- func (x *BoolQueryV1) Reset()
- func (x *BoolQueryV1) String() string
- type Cluster
- func (*Cluster) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster) GetAuth() *ClusterAuth
- func (x *Cluster) GetEndpoint() string
- func (x *Cluster) GetIndexSetCount() int64
- func (x *Cluster) GetName() string
- func (*Cluster) ProtoMessage()
- func (x *Cluster) ProtoReflect() protoreflect.Message
- func (x *Cluster) Reset()
- func (x *Cluster) String() string
- type ClusterAuth
- type DeleteClusterRequest
- func (*DeleteClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteClusterRequest) GetName() string
- func (*DeleteClusterRequest) ProtoMessage()
- func (x *DeleteClusterRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteClusterRequest) Reset()
- func (x *DeleteClusterRequest) String() string
- type DeleteClusterResponse
- type DeleteIndexSetRequest
- func (*DeleteIndexSetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteIndexSetRequest) GetName() string
- func (*DeleteIndexSetRequest) ProtoMessage()
- func (x *DeleteIndexSetRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteIndexSetRequest) Reset()
- func (x *DeleteIndexSetRequest) String() string
- type DeleteIndexSetResponse
- type EnabledFilter
- func (EnabledFilter) Descriptor() protoreflect.EnumDescriptor
- func (x EnabledFilter) Enum() *EnabledFilter
- func (EnabledFilter) EnumDescriptor() ([]byte, []int)deprecated
- func (x EnabledFilter) Number() protoreflect.EnumNumber
- func (x EnabledFilter) String() string
- func (EnabledFilter) Type() protoreflect.EnumType
- type EndSubscriptionRequest
- func (*EndSubscriptionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EndSubscriptionRequest) GetId() int64
- func (*EndSubscriptionRequest) ProtoMessage()
- func (x *EndSubscriptionRequest) ProtoReflect() protoreflect.Message
- func (x *EndSubscriptionRequest) Reset()
- func (x *EndSubscriptionRequest) String() string
- type EndSubscriptionResponse
- type FieldValuesV1
- type Fuzziness
- type GetMappingsRequestV1
- func (*GetMappingsRequestV1) Descriptor() ([]byte, []int)deprecated
- func (x *GetMappingsRequestV1) GetDocumentType() string
- func (*GetMappingsRequestV1) ProtoMessage()
- func (x *GetMappingsRequestV1) ProtoReflect() protoreflect.Message
- func (x *GetMappingsRequestV1) Reset()
- func (x *GetMappingsRequestV1) String() string
- type GetMappingsResponseV1
- func (*GetMappingsResponseV1) Descriptor() ([]byte, []int)deprecated
- func (x *GetMappingsResponseV1) GetProperties() []*MappingPropertyV1
- func (*GetMappingsResponseV1) ProtoMessage()
- func (x *GetMappingsResponseV1) ProtoReflect() protoreflect.Message
- func (x *GetMappingsResponseV1) Reset()
- func (x *GetMappingsResponseV1) String() string
- type HTTPClient
- type HitV1
- func (*HitV1) Descriptor() ([]byte, []int)deprecated
- func (x *HitV1) GetDocument() *newsdoc.Document
- func (x *HitV1) GetField(name string) string
- func (x *HitV1) GetFieldValues(name string) []string
- func (x *HitV1) GetFields() map[string]*FieldValuesV1
- func (x *HitV1) GetId() string
- func (x *HitV1) GetScore() float32
- func (x *HitV1) GetSort() []string
- func (x *HitV1) GetSource() map[string]*FieldValuesV1
- func (*HitV1) ProtoMessage()
- func (x *HitV1) ProtoReflect() protoreflect.Message
- func (x *HitV1) Reset()
- func (x *HitV1) String() string
- type HitsTotalV1
- func (*HitsTotalV1) Descriptor() ([]byte, []int)deprecated
- func (x *HitsTotalV1) GetRelation() string
- func (x *HitsTotalV1) GetValue() int64
- func (*HitsTotalV1) ProtoMessage()
- func (x *HitsTotalV1) ProtoReflect() protoreflect.Message
- func (x *HitsTotalV1) Reset()
- func (x *HitsTotalV1) String() string
- type HitsV1
- func (*HitsV1) Descriptor() ([]byte, []int)deprecated
- func (x *HitsV1) GetHits() []*HitV1
- func (x *HitsV1) GetMaxScore() float32
- func (x *HitsV1) GetTotal() *HitsTotalV1
- func (*HitsV1) ProtoMessage()
- func (x *HitsV1) ProtoReflect() protoreflect.Message
- func (x *HitsV1) Reset()
- func (x *HitsV1) String() string
- type IndexSet
- func (*IndexSet) Descriptor() ([]byte, []int)deprecated
- func (x *IndexSet) GetActive() bool
- func (x *IndexSet) GetCluster() string
- func (x *IndexSet) GetEnabled() bool
- func (x *IndexSet) GetName() string
- func (x *IndexSet) GetPosition() int64
- func (*IndexSet) ProtoMessage()
- func (x *IndexSet) ProtoReflect() protoreflect.Message
- func (x *IndexSet) Reset()
- func (x *IndexSet) String() string
- type ListClustersRequest
- type ListClustersResponse
- func (*ListClustersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListClustersResponse) GetClusters() []*Cluster
- func (*ListClustersResponse) ProtoMessage()
- func (x *ListClustersResponse) ProtoReflect() protoreflect.Message
- func (x *ListClustersResponse) Reset()
- func (x *ListClustersResponse) String() string
- type ListIndexSetsRequest
- func (*ListIndexSetsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListIndexSetsRequest) GetCluster() string
- func (x *ListIndexSetsRequest) GetCursor() string
- func (x *ListIndexSetsRequest) GetOnlyActive() bool
- func (x *ListIndexSetsRequest) GetStatus() EnabledFilter
- func (*ListIndexSetsRequest) ProtoMessage()
- func (x *ListIndexSetsRequest) ProtoReflect() protoreflect.Message
- func (x *ListIndexSetsRequest) Reset()
- func (x *ListIndexSetsRequest) String() string
- type ListIndexSetsResponse
- func (*ListIndexSetsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListIndexSetsResponse) GetIndexSets() []*IndexSet
- func (x *ListIndexSetsResponse) GetNextPage() string
- func (*ListIndexSetsResponse) ProtoMessage()
- func (x *ListIndexSetsResponse) ProtoReflect() protoreflect.Message
- func (x *ListIndexSetsResponse) Reset()
- func (x *ListIndexSetsResponse) String() string
- type Management
- type MappingFieldV1
- func (*MappingFieldV1) Descriptor() ([]byte, []int)deprecated
- func (x *MappingFieldV1) GetName() string
- func (x *MappingFieldV1) GetType() string
- func (*MappingFieldV1) ProtoMessage()
- func (x *MappingFieldV1) ProtoReflect() protoreflect.Message
- func (x *MappingFieldV1) Reset()
- func (x *MappingFieldV1) String() string
- type MappingPropertyV1
- func (*MappingPropertyV1) Descriptor() ([]byte, []int)deprecated
- func (x *MappingPropertyV1) GetFields() []*MappingFieldV1
- func (x *MappingPropertyV1) GetName() string
- func (x *MappingPropertyV1) GetPath() string
- func (x *MappingPropertyV1) GetType() string
- func (*MappingPropertyV1) ProtoMessage()
- func (x *MappingPropertyV1) ProtoReflect() protoreflect.Message
- func (x *MappingPropertyV1) Reset()
- func (x *MappingPropertyV1) String() string
- type MatchAllQueryV1
- type MatchPhraseQueryV1
- func (*MatchPhraseQueryV1) Descriptor() ([]byte, []int)deprecated
- func (x *MatchPhraseQueryV1) GetField() string
- func (x *MatchPhraseQueryV1) GetValue() string
- func (*MatchPhraseQueryV1) ProtoMessage()
- func (x *MatchPhraseQueryV1) ProtoReflect() protoreflect.Message
- func (x *MatchPhraseQueryV1) Reset()
- func (x *MatchPhraseQueryV1) String() string
- type MatchQueryV1
- func (*MatchQueryV1) Descriptor() ([]byte, []int)deprecated
- func (x *MatchQueryV1) GetBoost() float64
- func (x *MatchQueryV1) GetField() string
- func (x *MatchQueryV1) GetValue() string
- func (*MatchQueryV1) ProtoMessage()
- func (x *MatchQueryV1) ProtoReflect() protoreflect.Message
- func (x *MatchQueryV1) Reset()
- func (x *MatchQueryV1) String() string
- type MultiMatchQueryV1
- func (*MultiMatchQueryV1) Descriptor() ([]byte, []int)deprecated
- func (x *MultiMatchQueryV1) GetBooleanAnd() bool
- func (x *MultiMatchQueryV1) GetBoost() float64
- func (x *MultiMatchQueryV1) GetFields() []string
- func (x *MultiMatchQueryV1) GetFuzziness() *Fuzziness
- func (x *MultiMatchQueryV1) GetMinimumShouldMatch() string
- func (x *MultiMatchQueryV1) GetPrefixLength() int64
- func (x *MultiMatchQueryV1) GetQuery() string
- func (x *MultiMatchQueryV1) GetTieBreaker() float32
- func (x *MultiMatchQueryV1) GetType() string
- func (*MultiMatchQueryV1) ProtoMessage()
- func (x *MultiMatchQueryV1) ProtoReflect() protoreflect.Message
- func (x *MultiMatchQueryV1) Reset()
- func (x *MultiMatchQueryV1) String() string
- type MultiSearchRequest
- func (*MultiSearchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MultiSearchRequest) GetQueries() []*QueryRequestV1
- func (*MultiSearchRequest) ProtoMessage()
- func (x *MultiSearchRequest) ProtoReflect() protoreflect.Message
- func (x *MultiSearchRequest) Reset()
- func (x *MultiSearchRequest) String() string
- type MultiSearchResponse
- func (*MultiSearchResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MultiSearchResponse) GetResults() []*QueryResponseV1
- func (*MultiSearchResponse) ProtoMessage()
- func (x *MultiSearchResponse) ProtoReflect() protoreflect.Message
- func (x *MultiSearchResponse) Reset()
- func (x *MultiSearchResponse) String() string
- type PartialReindexRequest
- func (*PartialReindexRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PartialReindexRequest) GetIndexSet() string
- func (x *PartialReindexRequest) GetPosition() int64
- func (*PartialReindexRequest) ProtoMessage()
- func (x *PartialReindexRequest) ProtoReflect() protoreflect.Message
- func (x *PartialReindexRequest) Reset()
- func (x *PartialReindexRequest) String() string
- type PartialReindexResponse
- type PollSubscriptionRequest
- func (*PollSubscriptionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PollSubscriptionRequest) GetBatchDelayMs() int64
- func (x *PollSubscriptionRequest) GetMaxWaitMs() int64
- func (x *PollSubscriptionRequest) GetSubscriptions() []*SubscriptionReference
- func (*PollSubscriptionRequest) ProtoMessage()
- func (x *PollSubscriptionRequest) ProtoReflect() protoreflect.Message
- func (x *PollSubscriptionRequest) Reset()
- func (x *PollSubscriptionRequest) String() string
- type PollSubscriptionResponse
- func (*PollSubscriptionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PollSubscriptionResponse) GetResult() []*SubscriptionPollResult
- func (x *PollSubscriptionResponse) GetUnknownSubscriptions() []int64
- func (*PollSubscriptionResponse) ProtoMessage()
- func (x *PollSubscriptionResponse) ProtoReflect() protoreflect.Message
- func (x *PollSubscriptionResponse) Reset()
- func (x *PollSubscriptionResponse) String() string
- type PrefixQueryV1
- func (*PrefixQueryV1) Descriptor() ([]byte, []int)deprecated
- func (x *PrefixQueryV1) GetBoost() float64
- func (x *PrefixQueryV1) GetCaseInsensitive() bool
- func (x *PrefixQueryV1) GetField() string
- func (x *PrefixQueryV1) GetValue() string
- func (*PrefixQueryV1) ProtoMessage()
- func (x *PrefixQueryV1) ProtoReflect() protoreflect.Message
- func (x *PrefixQueryV1) Reset()
- func (x *PrefixQueryV1) String() string
- type QueryRequestV1
- func (*QueryRequestV1) Descriptor() ([]byte, []int)deprecated
- func (x *QueryRequestV1) GetDocumentType() string
- func (x *QueryRequestV1) GetFields() []string
- func (x *QueryRequestV1) GetFrom() int64
- func (x *QueryRequestV1) GetLanguage() string
- func (x *QueryRequestV1) GetLoadDocument() bool
- func (x *QueryRequestV1) GetQuery() *QueryV1
- func (x *QueryRequestV1) GetSearchAfter() []string
- func (x *QueryRequestV1) GetShared() bool
- func (x *QueryRequestV1) GetSize() int64
- func (x *QueryRequestV1) GetSort() []*SortingV1
- func (x *QueryRequestV1) GetSource() bool
- func (x *QueryRequestV1) GetSubscribe() bool
- func (*QueryRequestV1) ProtoMessage()
- func (x *QueryRequestV1) ProtoReflect() protoreflect.Message
- func (x *QueryRequestV1) Reset()
- func (x *QueryRequestV1) String() string
- type QueryResponseV1
- func (*QueryResponseV1) Descriptor() ([]byte, []int)deprecated
- func (x *QueryResponseV1) GetHits() *HitsV1
- func (x *QueryResponseV1) GetShards() *ShardsV1
- func (x *QueryResponseV1) GetSubscription() *SubscriptionReference
- func (x *QueryResponseV1) GetTimedOut() bool
- func (x *QueryResponseV1) GetTook() int64
- func (*QueryResponseV1) ProtoMessage()
- func (x *QueryResponseV1) ProtoReflect() protoreflect.Message
- func (x *QueryResponseV1) Reset()
- func (x *QueryResponseV1) String() string
- type QueryV1
- func BoolQuery(q *BoolQueryV1) *QueryV1
- func ExistsQuery(field string) *QueryV1
- func MatchAllQuery() *QueryV1
- func MatchPhraseQuery(q *MatchPhraseQueryV1) *QueryV1
- func MatchQuery(q *MatchQueryV1) *QueryV1
- func MultiMatchQuery(q *MultiMatchQueryV1) *QueryV1
- func PrefixQuery(q *PrefixQueryV1) *QueryV1
- func QueryStringQuery(q string) *QueryV1
- func RangeQuery(q *RangeQueryV1) *QueryV1
- func TermQuery(q *TermQueryV1) *QueryV1
- func TermsQuery(q *TermsQueryV1) *QueryV1
- func (*QueryV1) Descriptor() ([]byte, []int)deprecated
- func (x *QueryV1) GetBool() *BoolQueryV1
- func (x *QueryV1) GetConditions() isQueryV1_Conditions
- func (x *QueryV1) GetExists() string
- func (x *QueryV1) GetMatch() *MatchQueryV1
- func (x *QueryV1) GetMatchAll() *MatchAllQueryV1
- func (x *QueryV1) GetMatchPhrase() *MatchPhraseQueryV1
- func (x *QueryV1) GetMultiMatch() *MultiMatchQueryV1
- func (x *QueryV1) GetPrefix() *PrefixQueryV1
- func (x *QueryV1) GetQueryString() string
- func (x *QueryV1) GetRange() *RangeQueryV1
- func (x *QueryV1) GetTerm() *TermQueryV1
- func (x *QueryV1) GetTerms() *TermsQueryV1
- func (*QueryV1) ProtoMessage()
- func (x *QueryV1) ProtoReflect() protoreflect.Message
- func (x *QueryV1) Reset()
- func (x *QueryV1) String() string
- type QueryV1_Bool
- type QueryV1_Exists
- type QueryV1_Match
- type QueryV1_MatchAll
- type QueryV1_MatchPhrase
- type QueryV1_MultiMatch
- type QueryV1_Prefix
- type QueryV1_QueryString
- type QueryV1_Range
- type QueryV1_Term
- type QueryV1_Terms
- type RangeQueryV1
- func (*RangeQueryV1) Descriptor() ([]byte, []int)deprecated
- func (x *RangeQueryV1) GetField() string
- func (x *RangeQueryV1) GetGt() string
- func (x *RangeQueryV1) GetGte() string
- func (x *RangeQueryV1) GetLt() string
- func (x *RangeQueryV1) GetLte() string
- func (*RangeQueryV1) ProtoMessage()
- func (x *RangeQueryV1) ProtoReflect() protoreflect.Message
- func (x *RangeQueryV1) Reset()
- func (x *RangeQueryV1) String() string
- type RegisterClusterAuth
- func (*RegisterClusterAuth) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterClusterAuth) GetIam() bool
- func (*RegisterClusterAuth) ProtoMessage()
- func (x *RegisterClusterAuth) ProtoReflect() protoreflect.Message
- func (x *RegisterClusterAuth) Reset()
- func (x *RegisterClusterAuth) String() string
- type RegisterClusterRequest
- func (*RegisterClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterClusterRequest) GetAuth() *RegisterClusterAuth
- func (x *RegisterClusterRequest) GetEndpoint() string
- func (x *RegisterClusterRequest) GetName() string
- func (*RegisterClusterRequest) ProtoMessage()
- func (x *RegisterClusterRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterClusterRequest) Reset()
- func (x *RegisterClusterRequest) String() string
- type RegisterClusterResponse
- type ReindexRequest
- type ReindexResponse
- type SearchV1
- type SetIndexSetStatusRequest
- func (*SetIndexSetStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetIndexSetStatusRequest) GetActive() bool
- func (x *SetIndexSetStatusRequest) GetEnabled() bool
- func (x *SetIndexSetStatusRequest) GetForceActive() bool
- func (x *SetIndexSetStatusRequest) GetName() string
- func (*SetIndexSetStatusRequest) ProtoMessage()
- func (x *SetIndexSetStatusRequest) ProtoReflect() protoreflect.Message
- func (x *SetIndexSetStatusRequest) Reset()
- func (x *SetIndexSetStatusRequest) String() string
- type SetIndexSetStatusResponse
- type ShardsV1
- func (*ShardsV1) Descriptor() ([]byte, []int)deprecated
- func (x *ShardsV1) GetFailed() int32
- func (x *ShardsV1) GetSkipped() int32
- func (x *ShardsV1) GetSuccessful() int32
- func (x *ShardsV1) GetTotal() int32
- func (*ShardsV1) ProtoMessage()
- func (x *ShardsV1) ProtoReflect() protoreflect.Message
- func (x *ShardsV1) Reset()
- func (x *ShardsV1) String() string
- type SortingV1
- type SubscriptionItem
- func (*SubscriptionItem) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriptionItem) GetDocument() *newsdoc.Document
- func (x *SubscriptionItem) GetFields() map[string]*FieldValuesV1
- func (x *SubscriptionItem) GetId() string
- func (x *SubscriptionItem) GetMatch() bool
- func (x *SubscriptionItem) GetSource() map[string]*FieldValuesV1
- func (*SubscriptionItem) ProtoMessage()
- func (x *SubscriptionItem) ProtoReflect() protoreflect.Message
- func (x *SubscriptionItem) Reset()
- func (x *SubscriptionItem) String() string
- type SubscriptionPollResult
- func (*SubscriptionPollResult) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriptionPollResult) GetItems() []*SubscriptionItem
- func (x *SubscriptionPollResult) GetSubscription() *SubscriptionReference
- func (*SubscriptionPollResult) ProtoMessage()
- func (x *SubscriptionPollResult) ProtoReflect() protoreflect.Message
- func (x *SubscriptionPollResult) Reset()
- func (x *SubscriptionPollResult) String() string
- type SubscriptionReference
- func (*SubscriptionReference) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriptionReference) GetCursor() int64
- func (x *SubscriptionReference) GetId() int64
- func (*SubscriptionReference) ProtoMessage()
- func (x *SubscriptionReference) ProtoReflect() protoreflect.Message
- func (x *SubscriptionReference) Reset()
- func (x *SubscriptionReference) String() string
- type TermQueryV1
- func (*TermQueryV1) Descriptor() ([]byte, []int)deprecated
- func (x *TermQueryV1) GetBoost() float64
- func (x *TermQueryV1) GetField() string
- func (x *TermQueryV1) GetValue() string
- func (*TermQueryV1) ProtoMessage()
- func (x *TermQueryV1) ProtoReflect() protoreflect.Message
- func (x *TermQueryV1) Reset()
- func (x *TermQueryV1) String() string
- type TermsQueryV1
- func (*TermsQueryV1) Descriptor() ([]byte, []int)deprecated
- func (x *TermsQueryV1) GetBoost() float64
- func (x *TermsQueryV1) GetField() string
- func (x *TermsQueryV1) GetValues() []string
- func (*TermsQueryV1) ProtoMessage()
- func (x *TermsQueryV1) ProtoReflect() protoreflect.Message
- func (x *TermsQueryV1) Reset()
- func (x *TermsQueryV1) String() string
- type TwirpServer
Constants ¶
const ManagementPathPrefix = "/twirp/elephant.index.Management/"
ManagementPathPrefix is a convenience constant that may identify URL paths. Should be used with caution, it only matches routes generated by Twirp Go clients, with the default "/twirp" prefix and default CamelCase service and method names. More info: https://twitchtv.github.io/twirp/docs/routing.html
const SearchV1PathPrefix = "/twirp/elephant.index.SearchV1/"
SearchV1PathPrefix is a convenience constant that may identify URL paths. Should be used with caution, it only matches routes generated by Twirp Go clients, with the default "/twirp" prefix and default CamelCase service and method names. More info: https://twitchtv.github.io/twirp/docs/routing.html
Variables ¶
var ( EnabledFilter_name = map[int32]string{ 0: "STATUS_UNSPECIFIED", 1: "STATUS_ENABLED", 3: "STATUS_DISABLED", } EnabledFilter_value = map[string]int32{ "STATUS_UNSPECIFIED": 0, "STATUS_ENABLED": 1, "STATUS_DISABLED": 3, } )
Enum value maps for EnabledFilter.
var File_index_service_proto protoreflect.FileDescriptor
Functions ¶
func WriteError ¶
func WriteError(resp http.ResponseWriter, err error)
WriteError writes an HTTP response with a valid Twirp error format (code, msg, meta). Useful outside of the Twirp server (e.g. http middleware), but does not trigger hooks. If err is not a twirp.Error, it will get wrapped with twirp.InternalErrorWith(err)
Types ¶
type BoolQueryV1 ¶ added in v0.14.0
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"`
// contains filtered or unexported fields
}
func (*BoolQueryV1) Descriptor
deprecated
added in
v0.14.0
func (*BoolQueryV1) Descriptor() ([]byte, []int)
Deprecated: Use BoolQueryV1.ProtoReflect.Descriptor instead.
func (*BoolQueryV1) GetFilter ¶ added in v0.14.0
func (x *BoolQueryV1) GetFilter() []*QueryV1
func (*BoolQueryV1) GetMust ¶ added in v0.14.0
func (x *BoolQueryV1) GetMust() []*QueryV1
func (*BoolQueryV1) GetMustNot ¶ added in v0.14.0
func (x *BoolQueryV1) GetMustNot() []*QueryV1
func (*BoolQueryV1) GetShould ¶ added in v0.14.0
func (x *BoolQueryV1) GetShould() []*QueryV1
func (*BoolQueryV1) ProtoMessage ¶ added in v0.14.0
func (*BoolQueryV1) ProtoMessage()
func (*BoolQueryV1) ProtoReflect ¶ added in v0.14.0
func (x *BoolQueryV1) ProtoReflect() protoreflect.Message
func (*BoolQueryV1) Reset ¶ added in v0.14.0
func (x *BoolQueryV1) Reset()
func (*BoolQueryV1) String ¶ added in v0.14.0
func (x *BoolQueryV1) String() string
type Cluster ¶
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
}
func (*Cluster) Descriptor
deprecated
func (*Cluster) GetAuth ¶
func (x *Cluster) GetAuth() *ClusterAuth
func (*Cluster) GetEndpoint ¶
func (*Cluster) GetIndexSetCount ¶
func (*Cluster) ProtoMessage ¶
func (*Cluster) ProtoMessage()
func (*Cluster) ProtoReflect ¶
func (x *Cluster) ProtoReflect() protoreflect.Message
type ClusterAuth ¶
type ClusterAuth struct {
// IAM authentication.
Iam bool `protobuf:"varint,1,opt,name=iam,proto3" json:"iam,omitempty"`
// contains filtered or unexported fields
}
func (*ClusterAuth) Descriptor
deprecated
func (*ClusterAuth) Descriptor() ([]byte, []int)
Deprecated: Use ClusterAuth.ProtoReflect.Descriptor instead.
func (*ClusterAuth) GetIam ¶
func (x *ClusterAuth) GetIam() bool
func (*ClusterAuth) ProtoMessage ¶
func (*ClusterAuth) ProtoMessage()
func (*ClusterAuth) ProtoReflect ¶
func (x *ClusterAuth) ProtoReflect() protoreflect.Message
func (*ClusterAuth) Reset ¶
func (x *ClusterAuth) Reset()
func (*ClusterAuth) String ¶
func (x *ClusterAuth) String() string
type DeleteClusterRequest ¶
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
}
func (*DeleteClusterRequest) Descriptor
deprecated
func (*DeleteClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteClusterRequest.ProtoReflect.Descriptor instead.
func (*DeleteClusterRequest) GetName ¶
func (x *DeleteClusterRequest) GetName() string
func (*DeleteClusterRequest) ProtoMessage ¶
func (*DeleteClusterRequest) ProtoMessage()
func (*DeleteClusterRequest) ProtoReflect ¶
func (x *DeleteClusterRequest) ProtoReflect() protoreflect.Message
func (*DeleteClusterRequest) Reset ¶
func (x *DeleteClusterRequest) Reset()
func (*DeleteClusterRequest) String ¶
func (x *DeleteClusterRequest) String() string
type DeleteClusterResponse ¶
type DeleteClusterResponse struct {
// contains filtered or unexported fields
}
func (*DeleteClusterResponse) Descriptor
deprecated
func (*DeleteClusterResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteClusterResponse.ProtoReflect.Descriptor instead.
func (*DeleteClusterResponse) ProtoMessage ¶
func (*DeleteClusterResponse) ProtoMessage()
func (*DeleteClusterResponse) ProtoReflect ¶
func (x *DeleteClusterResponse) ProtoReflect() protoreflect.Message
func (*DeleteClusterResponse) Reset ¶
func (x *DeleteClusterResponse) Reset()
func (*DeleteClusterResponse) String ¶
func (x *DeleteClusterResponse) String() string
type DeleteIndexSetRequest ¶
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
}
func (*DeleteIndexSetRequest) Descriptor
deprecated
func (*DeleteIndexSetRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteIndexSetRequest.ProtoReflect.Descriptor instead.
func (*DeleteIndexSetRequest) GetName ¶
func (x *DeleteIndexSetRequest) GetName() string
func (*DeleteIndexSetRequest) ProtoMessage ¶
func (*DeleteIndexSetRequest) ProtoMessage()
func (*DeleteIndexSetRequest) ProtoReflect ¶
func (x *DeleteIndexSetRequest) ProtoReflect() protoreflect.Message
func (*DeleteIndexSetRequest) Reset ¶
func (x *DeleteIndexSetRequest) Reset()
func (*DeleteIndexSetRequest) String ¶
func (x *DeleteIndexSetRequest) String() string
type DeleteIndexSetResponse ¶
type DeleteIndexSetResponse struct {
// contains filtered or unexported fields
}
func (*DeleteIndexSetResponse) Descriptor
deprecated
func (*DeleteIndexSetResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteIndexSetResponse.ProtoReflect.Descriptor instead.
func (*DeleteIndexSetResponse) ProtoMessage ¶
func (*DeleteIndexSetResponse) ProtoMessage()
func (*DeleteIndexSetResponse) ProtoReflect ¶
func (x *DeleteIndexSetResponse) ProtoReflect() protoreflect.Message
func (*DeleteIndexSetResponse) Reset ¶
func (x *DeleteIndexSetResponse) Reset()
func (*DeleteIndexSetResponse) String ¶
func (x *DeleteIndexSetResponse) String() string
type EnabledFilter ¶
type EnabledFilter int32
const ( EnabledFilter_STATUS_UNSPECIFIED EnabledFilter = 0 // STATUS_ENABLED means that documents are currently being indexed to the // index set. EnabledFilter_STATUS_ENABLED EnabledFilter = 1 // STATUS_DISABLED means that no documents are being indexed to the index set. EnabledFilter_STATUS_DISABLED EnabledFilter = 3 )
func (EnabledFilter) Descriptor ¶
func (EnabledFilter) Descriptor() protoreflect.EnumDescriptor
func (EnabledFilter) Enum ¶
func (x EnabledFilter) Enum() *EnabledFilter
func (EnabledFilter) EnumDescriptor
deprecated
func (EnabledFilter) EnumDescriptor() ([]byte, []int)
Deprecated: Use EnabledFilter.Descriptor instead.
func (EnabledFilter) Number ¶
func (x EnabledFilter) Number() protoreflect.EnumNumber
func (EnabledFilter) String ¶
func (x EnabledFilter) String() string
func (EnabledFilter) Type ¶
func (EnabledFilter) Type() protoreflect.EnumType
type EndSubscriptionRequest ¶ added in v0.17.8
type EndSubscriptionRequest struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func (*EndSubscriptionRequest) Descriptor
deprecated
added in
v0.17.8
func (*EndSubscriptionRequest) Descriptor() ([]byte, []int)
Deprecated: Use EndSubscriptionRequest.ProtoReflect.Descriptor instead.
func (*EndSubscriptionRequest) GetId ¶ added in v0.17.8
func (x *EndSubscriptionRequest) GetId() int64
func (*EndSubscriptionRequest) ProtoMessage ¶ added in v0.17.8
func (*EndSubscriptionRequest) ProtoMessage()
func (*EndSubscriptionRequest) ProtoReflect ¶ added in v0.17.8
func (x *EndSubscriptionRequest) ProtoReflect() protoreflect.Message
func (*EndSubscriptionRequest) Reset ¶ added in v0.17.8
func (x *EndSubscriptionRequest) Reset()
func (*EndSubscriptionRequest) String ¶ added in v0.17.8
func (x *EndSubscriptionRequest) String() string
type EndSubscriptionResponse ¶ added in v0.17.8
type EndSubscriptionResponse struct {
// contains filtered or unexported fields
}
func (*EndSubscriptionResponse) Descriptor
deprecated
added in
v0.17.8
func (*EndSubscriptionResponse) Descriptor() ([]byte, []int)
Deprecated: Use EndSubscriptionResponse.ProtoReflect.Descriptor instead.
func (*EndSubscriptionResponse) ProtoMessage ¶ added in v0.17.8
func (*EndSubscriptionResponse) ProtoMessage()
func (*EndSubscriptionResponse) ProtoReflect ¶ added in v0.17.8
func (x *EndSubscriptionResponse) ProtoReflect() protoreflect.Message
func (*EndSubscriptionResponse) Reset ¶ added in v0.17.8
func (x *EndSubscriptionResponse) Reset()
func (*EndSubscriptionResponse) String ¶ added in v0.17.8
func (x *EndSubscriptionResponse) String() string
type FieldValuesV1 ¶ added in v0.14.0
type FieldValuesV1 struct {
Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
// contains filtered or unexported fields
}
func (*FieldValuesV1) Descriptor
deprecated
added in
v0.14.0
func (*FieldValuesV1) Descriptor() ([]byte, []int)
Deprecated: Use FieldValuesV1.ProtoReflect.Descriptor instead.
func (*FieldValuesV1) GetValues ¶ added in v0.14.0
func (x *FieldValuesV1) GetValues() []string
func (*FieldValuesV1) ProtoMessage ¶ added in v0.14.0
func (*FieldValuesV1) ProtoMessage()
func (*FieldValuesV1) ProtoReflect ¶ added in v0.14.0
func (x *FieldValuesV1) ProtoReflect() protoreflect.Message
func (*FieldValuesV1) Reset ¶ added in v0.14.0
func (x *FieldValuesV1) Reset()
func (*FieldValuesV1) String ¶ added in v0.14.0
func (x *FieldValuesV1) String() string
type Fuzziness ¶ added in v0.17.23
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
}
Fuzziness has more ways to be specified, implementing that when we need it.
func (*Fuzziness) Descriptor
deprecated
added in
v0.17.23
func (*Fuzziness) ProtoMessage ¶ added in v0.17.23
func (*Fuzziness) ProtoMessage()
func (*Fuzziness) ProtoReflect ¶ added in v0.17.23
func (x *Fuzziness) ProtoReflect() protoreflect.Message
type GetMappingsRequestV1 ¶ added in v0.17.3
type GetMappingsRequestV1 struct {
DocumentType string `protobuf:"bytes,1,opt,name=document_type,json=documentType,proto3" json:"document_type,omitempty"`
// contains filtered or unexported fields
}
func (*GetMappingsRequestV1) Descriptor
deprecated
added in
v0.17.3
func (*GetMappingsRequestV1) Descriptor() ([]byte, []int)
Deprecated: Use GetMappingsRequestV1.ProtoReflect.Descriptor instead.
func (*GetMappingsRequestV1) GetDocumentType ¶ added in v0.17.3
func (x *GetMappingsRequestV1) GetDocumentType() string
func (*GetMappingsRequestV1) ProtoMessage ¶ added in v0.17.3
func (*GetMappingsRequestV1) ProtoMessage()
func (*GetMappingsRequestV1) ProtoReflect ¶ added in v0.17.3
func (x *GetMappingsRequestV1) ProtoReflect() protoreflect.Message
func (*GetMappingsRequestV1) Reset ¶ added in v0.17.3
func (x *GetMappingsRequestV1) Reset()
func (*GetMappingsRequestV1) String ¶ added in v0.17.3
func (x *GetMappingsRequestV1) String() string
type GetMappingsResponseV1 ¶ added in v0.17.3
type GetMappingsResponseV1 struct {
Properties []*MappingPropertyV1 `protobuf:"bytes,1,rep,name=properties,proto3" json:"properties,omitempty"`
// contains filtered or unexported fields
}
func (*GetMappingsResponseV1) Descriptor
deprecated
added in
v0.17.3
func (*GetMappingsResponseV1) Descriptor() ([]byte, []int)
Deprecated: Use GetMappingsResponseV1.ProtoReflect.Descriptor instead.
func (*GetMappingsResponseV1) GetProperties ¶ added in v0.17.3
func (x *GetMappingsResponseV1) GetProperties() []*MappingPropertyV1
func (*GetMappingsResponseV1) ProtoMessage ¶ added in v0.17.3
func (*GetMappingsResponseV1) ProtoMessage()
func (*GetMappingsResponseV1) ProtoReflect ¶ added in v0.17.3
func (x *GetMappingsResponseV1) ProtoReflect() protoreflect.Message
func (*GetMappingsResponseV1) Reset ¶ added in v0.17.3
func (x *GetMappingsResponseV1) Reset()
func (*GetMappingsResponseV1) String ¶ added in v0.17.3
func (x *GetMappingsResponseV1) String() string
type HTTPClient ¶
HTTPClient is the interface used by generated clients to send HTTP requests. It is fulfilled by *(net/http).Client, which is sufficient for most users. Users can provide their own implementation for special retry policies.
HTTPClient implementations should not follow redirects. Redirects are automatically disabled if *(net/http).Client is passed to client constructors. See the withoutRedirects function in this file for more details.
type HitV1 ¶ added in v0.14.0
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
}
func (*HitV1) Descriptor
deprecated
added in
v0.14.0
func (*HitV1) GetDocument ¶ added in v0.15.0
func (*HitV1) GetFieldValues ¶ added in v0.17.23
func (*HitV1) GetFields ¶ added in v0.14.0
func (x *HitV1) GetFields() map[string]*FieldValuesV1
func (*HitV1) GetSource ¶ added in v0.14.0
func (x *HitV1) GetSource() map[string]*FieldValuesV1
func (*HitV1) ProtoMessage ¶ added in v0.14.0
func (*HitV1) ProtoMessage()
func (*HitV1) ProtoReflect ¶ added in v0.14.0
func (x *HitV1) ProtoReflect() protoreflect.Message
type HitsTotalV1 ¶ added in v0.14.0
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
}
func (*HitsTotalV1) Descriptor
deprecated
added in
v0.14.0
func (*HitsTotalV1) Descriptor() ([]byte, []int)
Deprecated: Use HitsTotalV1.ProtoReflect.Descriptor instead.
func (*HitsTotalV1) GetRelation ¶ added in v0.14.0
func (x *HitsTotalV1) GetRelation() string
func (*HitsTotalV1) GetValue ¶ added in v0.14.0
func (x *HitsTotalV1) GetValue() int64
func (*HitsTotalV1) ProtoMessage ¶ added in v0.14.0
func (*HitsTotalV1) ProtoMessage()
func (*HitsTotalV1) ProtoReflect ¶ added in v0.14.0
func (x *HitsTotalV1) ProtoReflect() protoreflect.Message
func (*HitsTotalV1) Reset ¶ added in v0.14.0
func (x *HitsTotalV1) Reset()
func (*HitsTotalV1) String ¶ added in v0.14.0
func (x *HitsTotalV1) String() string
type HitsV1 ¶ added in v0.14.0
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
}
func (*HitsV1) Descriptor
deprecated
added in
v0.14.0
func (*HitsV1) GetMaxScore ¶ added in v0.14.0
func (*HitsV1) GetTotal ¶ added in v0.14.0
func (x *HitsV1) GetTotal() *HitsTotalV1
func (*HitsV1) ProtoMessage ¶ added in v0.14.0
func (*HitsV1) ProtoMessage()
func (*HitsV1) ProtoReflect ¶ added in v0.14.0
func (x *HitsV1) ProtoReflect() protoreflect.Message
type IndexSet ¶
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
}
func (*IndexSet) Descriptor
deprecated
func (*IndexSet) GetCluster ¶
func (*IndexSet) GetEnabled ¶
func (*IndexSet) GetPosition ¶
func (*IndexSet) ProtoMessage ¶
func (*IndexSet) ProtoMessage()
func (*IndexSet) ProtoReflect ¶
func (x *IndexSet) ProtoReflect() protoreflect.Message
type ListClustersRequest ¶
type ListClustersRequest struct {
// contains filtered or unexported fields
}
func (*ListClustersRequest) Descriptor
deprecated
func (*ListClustersRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.
func (*ListClustersRequest) ProtoMessage ¶
func (*ListClustersRequest) ProtoMessage()
func (*ListClustersRequest) ProtoReflect ¶
func (x *ListClustersRequest) ProtoReflect() protoreflect.Message
func (*ListClustersRequest) Reset ¶
func (x *ListClustersRequest) Reset()
func (*ListClustersRequest) String ¶
func (x *ListClustersRequest) String() string
type ListClustersResponse ¶
type ListClustersResponse struct {
Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
// contains filtered or unexported fields
}
func (*ListClustersResponse) Descriptor
deprecated
func (*ListClustersResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.
func (*ListClustersResponse) GetClusters ¶
func (x *ListClustersResponse) GetClusters() []*Cluster
func (*ListClustersResponse) ProtoMessage ¶
func (*ListClustersResponse) ProtoMessage()
func (*ListClustersResponse) ProtoReflect ¶
func (x *ListClustersResponse) ProtoReflect() protoreflect.Message
func (*ListClustersResponse) Reset ¶
func (x *ListClustersResponse) Reset()
func (*ListClustersResponse) String ¶
func (x *ListClustersResponse) String() string
type ListIndexSetsRequest ¶
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
}
func (*ListIndexSetsRequest) Descriptor
deprecated
func (*ListIndexSetsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListIndexSetsRequest.ProtoReflect.Descriptor instead.
func (*ListIndexSetsRequest) GetCluster ¶
func (x *ListIndexSetsRequest) GetCluster() string
func (*ListIndexSetsRequest) GetCursor ¶
func (x *ListIndexSetsRequest) GetCursor() string
func (*ListIndexSetsRequest) GetOnlyActive ¶
func (x *ListIndexSetsRequest) GetOnlyActive() bool
func (*ListIndexSetsRequest) GetStatus ¶
func (x *ListIndexSetsRequest) GetStatus() EnabledFilter
func (*ListIndexSetsRequest) ProtoMessage ¶
func (*ListIndexSetsRequest) ProtoMessage()
func (*ListIndexSetsRequest) ProtoReflect ¶
func (x *ListIndexSetsRequest) ProtoReflect() protoreflect.Message
func (*ListIndexSetsRequest) Reset ¶
func (x *ListIndexSetsRequest) Reset()
func (*ListIndexSetsRequest) String ¶
func (x *ListIndexSetsRequest) String() string
type ListIndexSetsResponse ¶
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
}
func (*ListIndexSetsResponse) Descriptor
deprecated
func (*ListIndexSetsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListIndexSetsResponse.ProtoReflect.Descriptor instead.
func (*ListIndexSetsResponse) GetIndexSets ¶
func (x *ListIndexSetsResponse) GetIndexSets() []*IndexSet
func (*ListIndexSetsResponse) GetNextPage ¶
func (x *ListIndexSetsResponse) GetNextPage() string
func (*ListIndexSetsResponse) ProtoMessage ¶
func (*ListIndexSetsResponse) ProtoMessage()
func (*ListIndexSetsResponse) ProtoReflect ¶
func (x *ListIndexSetsResponse) ProtoReflect() protoreflect.Message
func (*ListIndexSetsResponse) Reset ¶
func (x *ListIndexSetsResponse) Reset()
func (*ListIndexSetsResponse) String ¶
func (x *ListIndexSetsResponse) String() string
type Management ¶
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)
}
func NewManagementJSONClient ¶
func NewManagementJSONClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) Management
NewManagementJSONClient creates a JSON client that implements the Management interface. It communicates using JSON and can be configured with a custom HTTPClient.
func NewManagementProtobufClient ¶
func NewManagementProtobufClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) Management
NewManagementProtobufClient creates a Protobuf client that implements the Management interface. It communicates using Protobuf and can be configured with a custom HTTPClient.
type MappingFieldV1 ¶ added in v0.17.3
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
}
func (*MappingFieldV1) Descriptor
deprecated
added in
v0.17.3
func (*MappingFieldV1) Descriptor() ([]byte, []int)
Deprecated: Use MappingFieldV1.ProtoReflect.Descriptor instead.
func (*MappingFieldV1) GetName ¶ added in v0.17.3
func (x *MappingFieldV1) GetName() string
func (*MappingFieldV1) GetType ¶ added in v0.17.3
func (x *MappingFieldV1) GetType() string
func (*MappingFieldV1) ProtoMessage ¶ added in v0.17.3
func (*MappingFieldV1) ProtoMessage()
func (*MappingFieldV1) ProtoReflect ¶ added in v0.17.3
func (x *MappingFieldV1) ProtoReflect() protoreflect.Message
func (*MappingFieldV1) Reset ¶ added in v0.17.3
func (x *MappingFieldV1) Reset()
func (*MappingFieldV1) String ¶ added in v0.17.3
func (x *MappingFieldV1) String() string
type MappingPropertyV1 ¶ added in v0.17.3
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
}
func (*MappingPropertyV1) Descriptor
deprecated
added in
v0.17.3
func (*MappingPropertyV1) Descriptor() ([]byte, []int)
Deprecated: Use MappingPropertyV1.ProtoReflect.Descriptor instead.
func (*MappingPropertyV1) GetFields ¶ added in v0.17.3
func (x *MappingPropertyV1) GetFields() []*MappingFieldV1
func (*MappingPropertyV1) GetName ¶ added in v0.17.3
func (x *MappingPropertyV1) GetName() string
func (*MappingPropertyV1) GetPath ¶ added in v0.17.3
func (x *MappingPropertyV1) GetPath() string
func (*MappingPropertyV1) GetType ¶ added in v0.17.3
func (x *MappingPropertyV1) GetType() string
func (*MappingPropertyV1) ProtoMessage ¶ added in v0.17.3
func (*MappingPropertyV1) ProtoMessage()
func (*MappingPropertyV1) ProtoReflect ¶ added in v0.17.3
func (x *MappingPropertyV1) ProtoReflect() protoreflect.Message
func (*MappingPropertyV1) Reset ¶ added in v0.17.3
func (x *MappingPropertyV1) Reset()
func (*MappingPropertyV1) String ¶ added in v0.17.3
func (x *MappingPropertyV1) String() string
type MatchAllQueryV1 ¶ added in v0.14.0
type MatchAllQueryV1 struct {
// contains filtered or unexported fields
}
func (*MatchAllQueryV1) Descriptor
deprecated
added in
v0.14.0
func (*MatchAllQueryV1) Descriptor() ([]byte, []int)
Deprecated: Use MatchAllQueryV1.ProtoReflect.Descriptor instead.
func (*MatchAllQueryV1) ProtoMessage ¶ added in v0.14.0
func (*MatchAllQueryV1) ProtoMessage()
func (*MatchAllQueryV1) ProtoReflect ¶ added in v0.14.0
func (x *MatchAllQueryV1) ProtoReflect() protoreflect.Message
func (*MatchAllQueryV1) Reset ¶ added in v0.14.0
func (x *MatchAllQueryV1) Reset()
func (*MatchAllQueryV1) String ¶ added in v0.14.0
func (x *MatchAllQueryV1) String() string
type MatchPhraseQueryV1 ¶ added in v0.14.0
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
}
func (*MatchPhraseQueryV1) Descriptor
deprecated
added in
v0.14.0
func (*MatchPhraseQueryV1) Descriptor() ([]byte, []int)
Deprecated: Use MatchPhraseQueryV1.ProtoReflect.Descriptor instead.
func (*MatchPhraseQueryV1) GetField ¶ added in v0.14.0
func (x *MatchPhraseQueryV1) GetField() string
func (*MatchPhraseQueryV1) GetValue ¶ added in v0.14.0
func (x *MatchPhraseQueryV1) GetValue() string
func (*MatchPhraseQueryV1) ProtoMessage ¶ added in v0.14.0
func (*MatchPhraseQueryV1) ProtoMessage()
func (*MatchPhraseQueryV1) ProtoReflect ¶ added in v0.14.0
func (x *MatchPhraseQueryV1) ProtoReflect() protoreflect.Message
func (*MatchPhraseQueryV1) Reset ¶ added in v0.14.0
func (x *MatchPhraseQueryV1) Reset()
func (*MatchPhraseQueryV1) String ¶ added in v0.14.0
func (x *MatchPhraseQueryV1) String() string
type MatchQueryV1 ¶ added in v0.14.0
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
}
func (*MatchQueryV1) Descriptor
deprecated
added in
v0.14.0
func (*MatchQueryV1) Descriptor() ([]byte, []int)
Deprecated: Use MatchQueryV1.ProtoReflect.Descriptor instead.
func (*MatchQueryV1) GetBoost ¶ added in v0.17.8
func (x *MatchQueryV1) GetBoost() float64
func (*MatchQueryV1) GetField ¶ added in v0.14.0
func (x *MatchQueryV1) GetField() string
func (*MatchQueryV1) GetValue ¶ added in v0.14.0
func (x *MatchQueryV1) GetValue() string
func (*MatchQueryV1) ProtoMessage ¶ added in v0.14.0
func (*MatchQueryV1) ProtoMessage()
func (*MatchQueryV1) ProtoReflect ¶ added in v0.14.0
func (x *MatchQueryV1) ProtoReflect() protoreflect.Message
func (*MatchQueryV1) Reset ¶ added in v0.14.0
func (x *MatchQueryV1) Reset()
func (*MatchQueryV1) String ¶ added in v0.14.0
func (x *MatchQueryV1) String() string
type MultiMatchQueryV1 ¶ added in v0.17.10
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
}
func (*MultiMatchQueryV1) Descriptor
deprecated
added in
v0.17.10
func (*MultiMatchQueryV1) Descriptor() ([]byte, []int)
Deprecated: Use MultiMatchQueryV1.ProtoReflect.Descriptor instead.
func (*MultiMatchQueryV1) GetBooleanAnd ¶ added in v0.17.10
func (x *MultiMatchQueryV1) GetBooleanAnd() bool
func (*MultiMatchQueryV1) GetBoost ¶ added in v0.17.10
func (x *MultiMatchQueryV1) GetBoost() float64
func (*MultiMatchQueryV1) GetFields ¶ added in v0.17.10
func (x *MultiMatchQueryV1) GetFields() []string
func (*MultiMatchQueryV1) GetFuzziness ¶ added in v0.17.23
func (x *MultiMatchQueryV1) GetFuzziness() *Fuzziness
func (*MultiMatchQueryV1) GetMinimumShouldMatch ¶ added in v0.17.10
func (x *MultiMatchQueryV1) GetMinimumShouldMatch() string
func (*MultiMatchQueryV1) GetPrefixLength ¶ added in v0.17.23
func (x *MultiMatchQueryV1) GetPrefixLength() int64
func (*MultiMatchQueryV1) GetQuery ¶ added in v0.17.10
func (x *MultiMatchQueryV1) GetQuery() string
func (*MultiMatchQueryV1) GetTieBreaker ¶ added in v0.17.10
func (x *MultiMatchQueryV1) GetTieBreaker() float32
func (*MultiMatchQueryV1) GetType ¶ added in v0.17.10
func (x *MultiMatchQueryV1) GetType() string
func (*MultiMatchQueryV1) ProtoMessage ¶ added in v0.17.10
func (*MultiMatchQueryV1) ProtoMessage()
func (*MultiMatchQueryV1) ProtoReflect ¶ added in v0.17.10
func (x *MultiMatchQueryV1) ProtoReflect() protoreflect.Message
func (*MultiMatchQueryV1) Reset ¶ added in v0.17.10
func (x *MultiMatchQueryV1) Reset()
func (*MultiMatchQueryV1) String ¶ added in v0.17.10
func (x *MultiMatchQueryV1) String() string
type MultiSearchRequest ¶ added in v0.17.23
type MultiSearchRequest struct {
Queries []*QueryRequestV1 `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
// contains filtered or unexported fields
}
func (*MultiSearchRequest) Descriptor
deprecated
added in
v0.17.23
func (*MultiSearchRequest) Descriptor() ([]byte, []int)
Deprecated: Use MultiSearchRequest.ProtoReflect.Descriptor instead.
func (*MultiSearchRequest) GetQueries ¶ added in v0.17.23
func (x *MultiSearchRequest) GetQueries() []*QueryRequestV1
func (*MultiSearchRequest) ProtoMessage ¶ added in v0.17.23
func (*MultiSearchRequest) ProtoMessage()
func (*MultiSearchRequest) ProtoReflect ¶ added in v0.17.23
func (x *MultiSearchRequest) ProtoReflect() protoreflect.Message
func (*MultiSearchRequest) Reset ¶ added in v0.17.23
func (x *MultiSearchRequest) Reset()
func (*MultiSearchRequest) String ¶ added in v0.17.23
func (x *MultiSearchRequest) String() string
type MultiSearchResponse ¶ added in v0.17.23
type MultiSearchResponse struct {
Results []*QueryResponseV1 `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
// contains filtered or unexported fields
}
func (*MultiSearchResponse) Descriptor
deprecated
added in
v0.17.23
func (*MultiSearchResponse) Descriptor() ([]byte, []int)
Deprecated: Use MultiSearchResponse.ProtoReflect.Descriptor instead.
func (*MultiSearchResponse) GetResults ¶ added in v0.17.23
func (x *MultiSearchResponse) GetResults() []*QueryResponseV1
func (*MultiSearchResponse) ProtoMessage ¶ added in v0.17.23
func (*MultiSearchResponse) ProtoMessage()
func (*MultiSearchResponse) ProtoReflect ¶ added in v0.17.23
func (x *MultiSearchResponse) ProtoReflect() protoreflect.Message
func (*MultiSearchResponse) Reset ¶ added in v0.17.23
func (x *MultiSearchResponse) Reset()
func (*MultiSearchResponse) String ¶ added in v0.17.23
func (x *MultiSearchResponse) String() string
type PartialReindexRequest ¶
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
}
func (*PartialReindexRequest) Descriptor
deprecated
func (*PartialReindexRequest) Descriptor() ([]byte, []int)
Deprecated: Use PartialReindexRequest.ProtoReflect.Descriptor instead.
func (*PartialReindexRequest) GetIndexSet ¶
func (x *PartialReindexRequest) GetIndexSet() string
func (*PartialReindexRequest) GetPosition ¶
func (x *PartialReindexRequest) GetPosition() int64
func (*PartialReindexRequest) ProtoMessage ¶
func (*PartialReindexRequest) ProtoMessage()
func (*PartialReindexRequest) ProtoReflect ¶
func (x *PartialReindexRequest) ProtoReflect() protoreflect.Message
func (*PartialReindexRequest) Reset ¶
func (x *PartialReindexRequest) Reset()
func (*PartialReindexRequest) String ¶
func (x *PartialReindexRequest) String() string
type PartialReindexResponse ¶
type PartialReindexResponse struct {
// contains filtered or unexported fields
}
func (*PartialReindexResponse) Descriptor
deprecated
func (*PartialReindexResponse) Descriptor() ([]byte, []int)
Deprecated: Use PartialReindexResponse.ProtoReflect.Descriptor instead.
func (*PartialReindexResponse) ProtoMessage ¶
func (*PartialReindexResponse) ProtoMessage()
func (*PartialReindexResponse) ProtoReflect ¶
func (x *PartialReindexResponse) ProtoReflect() protoreflect.Message
func (*PartialReindexResponse) Reset ¶
func (x *PartialReindexResponse) Reset()
func (*PartialReindexResponse) String ¶
func (x *PartialReindexResponse) String() string
type PollSubscriptionRequest ¶ added in v0.17.8
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"`
// contains filtered or unexported fields
}
func (*PollSubscriptionRequest) Descriptor
deprecated
added in
v0.17.8
func (*PollSubscriptionRequest) Descriptor() ([]byte, []int)
Deprecated: Use PollSubscriptionRequest.ProtoReflect.Descriptor instead.
func (*PollSubscriptionRequest) GetBatchDelayMs ¶ added in v0.17.8
func (x *PollSubscriptionRequest) GetBatchDelayMs() int64
func (*PollSubscriptionRequest) GetMaxWaitMs ¶ added in v0.17.8
func (x *PollSubscriptionRequest) GetMaxWaitMs() int64
func (*PollSubscriptionRequest) GetSubscriptions ¶ added in v0.17.8
func (x *PollSubscriptionRequest) GetSubscriptions() []*SubscriptionReference
func (*PollSubscriptionRequest) ProtoMessage ¶ added in v0.17.8
func (*PollSubscriptionRequest) ProtoMessage()
func (*PollSubscriptionRequest) ProtoReflect ¶ added in v0.17.8
func (x *PollSubscriptionRequest) ProtoReflect() protoreflect.Message
func (*PollSubscriptionRequest) Reset ¶ added in v0.17.8
func (x *PollSubscriptionRequest) Reset()
func (*PollSubscriptionRequest) String ¶ added in v0.17.8
func (x *PollSubscriptionRequest) String() string
type PollSubscriptionResponse ¶ added in v0.17.8
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
}
func (*PollSubscriptionResponse) Descriptor
deprecated
added in
v0.17.8
func (*PollSubscriptionResponse) Descriptor() ([]byte, []int)
Deprecated: Use PollSubscriptionResponse.ProtoReflect.Descriptor instead.
func (*PollSubscriptionResponse) GetResult ¶ added in v0.17.8
func (x *PollSubscriptionResponse) GetResult() []*SubscriptionPollResult
func (*PollSubscriptionResponse) GetUnknownSubscriptions ¶ added in v0.17.12
func (x *PollSubscriptionResponse) GetUnknownSubscriptions() []int64
func (*PollSubscriptionResponse) ProtoMessage ¶ added in v0.17.8
func (*PollSubscriptionResponse) ProtoMessage()
func (*PollSubscriptionResponse) ProtoReflect ¶ added in v0.17.8
func (x *PollSubscriptionResponse) ProtoReflect() protoreflect.Message
func (*PollSubscriptionResponse) Reset ¶ added in v0.17.8
func (x *PollSubscriptionResponse) Reset()
func (*PollSubscriptionResponse) String ¶ added in v0.17.8
func (x *PollSubscriptionResponse) String() string
type PrefixQueryV1 ¶ added in v0.14.0
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
}
func (*PrefixQueryV1) Descriptor
deprecated
added in
v0.14.0
func (*PrefixQueryV1) Descriptor() ([]byte, []int)
Deprecated: Use PrefixQueryV1.ProtoReflect.Descriptor instead.
func (*PrefixQueryV1) GetBoost ¶ added in v0.17.8
func (x *PrefixQueryV1) GetBoost() float64
func (*PrefixQueryV1) GetCaseInsensitive ¶ added in v0.17.8
func (x *PrefixQueryV1) GetCaseInsensitive() bool
func (*PrefixQueryV1) GetField ¶ added in v0.14.0
func (x *PrefixQueryV1) GetField() string
func (*PrefixQueryV1) GetValue ¶ added in v0.14.0
func (x *PrefixQueryV1) GetValue() string
func (*PrefixQueryV1) ProtoMessage ¶ added in v0.14.0
func (*PrefixQueryV1) ProtoMessage()
func (*PrefixQueryV1) ProtoReflect ¶ added in v0.14.0
func (x *PrefixQueryV1) ProtoReflect() protoreflect.Message
func (*PrefixQueryV1) Reset ¶ added in v0.14.0
func (x *PrefixQueryV1) Reset()
func (*PrefixQueryV1) String ¶ added in v0.14.0
func (x *PrefixQueryV1) String() string
type QueryRequestV1 ¶ added in v0.14.0
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"`
// better query caching and shared subscriptions.
Shared bool `protobuf:"varint,12,opt,name=shared,proto3" json:"shared,omitempty"`
// contains filtered or unexported fields
}
func (*QueryRequestV1) Descriptor
deprecated
added in
v0.14.0
func (*QueryRequestV1) Descriptor() ([]byte, []int)
Deprecated: Use QueryRequestV1.ProtoReflect.Descriptor instead.
func (*QueryRequestV1) GetDocumentType ¶ added in v0.14.0
func (x *QueryRequestV1) GetDocumentType() string
func (*QueryRequestV1) GetFields ¶ added in v0.14.0
func (x *QueryRequestV1) GetFields() []string
func (*QueryRequestV1) GetFrom ¶ added in v0.14.0
func (x *QueryRequestV1) GetFrom() int64
func (*QueryRequestV1) GetLanguage ¶ added in v0.14.0
func (x *QueryRequestV1) GetLanguage() string
func (*QueryRequestV1) GetLoadDocument ¶ added in v0.15.0
func (x *QueryRequestV1) GetLoadDocument() bool
func (*QueryRequestV1) GetQuery ¶ added in v0.14.0
func (x *QueryRequestV1) GetQuery() *QueryV1
func (*QueryRequestV1) GetSearchAfter ¶ added in v0.14.0
func (x *QueryRequestV1) GetSearchAfter() []string
func (*QueryRequestV1) GetShared ¶ added in v0.17.8
func (x *QueryRequestV1) GetShared() bool
func (*QueryRequestV1) GetSize ¶ added in v0.14.0
func (x *QueryRequestV1) GetSize() int64
func (*QueryRequestV1) GetSort ¶ added in v0.14.0
func (x *QueryRequestV1) GetSort() []*SortingV1
func (*QueryRequestV1) GetSource ¶ added in v0.14.0
func (x *QueryRequestV1) GetSource() bool
func (*QueryRequestV1) GetSubscribe ¶ added in v0.17.8
func (x *QueryRequestV1) GetSubscribe() bool
func (*QueryRequestV1) ProtoMessage ¶ added in v0.14.0
func (*QueryRequestV1) ProtoMessage()
func (*QueryRequestV1) ProtoReflect ¶ added in v0.14.0
func (x *QueryRequestV1) ProtoReflect() protoreflect.Message
func (*QueryRequestV1) Reset ¶ added in v0.14.0
func (x *QueryRequestV1) Reset()
func (*QueryRequestV1) String ¶ added in v0.14.0
func (x *QueryRequestV1) String() string
type QueryResponseV1 ¶ added in v0.14.0
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
}
func (*QueryResponseV1) Descriptor
deprecated
added in
v0.14.0
func (*QueryResponseV1) Descriptor() ([]byte, []int)
Deprecated: Use QueryResponseV1.ProtoReflect.Descriptor instead.
func (*QueryResponseV1) GetHits ¶ added in v0.14.0
func (x *QueryResponseV1) GetHits() *HitsV1
func (*QueryResponseV1) GetShards ¶ added in v0.14.0
func (x *QueryResponseV1) GetShards() *ShardsV1
func (*QueryResponseV1) GetSubscription ¶ added in v0.17.8
func (x *QueryResponseV1) GetSubscription() *SubscriptionReference
func (*QueryResponseV1) GetTimedOut ¶ added in v0.14.0
func (x *QueryResponseV1) GetTimedOut() bool
func (*QueryResponseV1) GetTook ¶ added in v0.14.0
func (x *QueryResponseV1) GetTook() int64
func (*QueryResponseV1) ProtoMessage ¶ added in v0.14.0
func (*QueryResponseV1) ProtoMessage()
func (*QueryResponseV1) ProtoReflect ¶ added in v0.14.0
func (x *QueryResponseV1) ProtoReflect() protoreflect.Message
func (*QueryResponseV1) Reset ¶ added in v0.14.0
func (x *QueryResponseV1) Reset()
func (*QueryResponseV1) String ¶ added in v0.14.0
func (x *QueryResponseV1) String() string
type QueryV1 ¶ added in v0.14.0
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
}
func BoolQuery ¶ added in v0.17.23
func BoolQuery(q *BoolQueryV1) *QueryV1
func ExistsQuery ¶ added in v0.17.23
func MatchAllQuery ¶ added in v0.17.23
func MatchAllQuery() *QueryV1
func MatchPhraseQuery ¶ added in v0.17.23
func MatchPhraseQuery(q *MatchPhraseQueryV1) *QueryV1
func MatchQuery ¶ added in v0.17.23
func MatchQuery(q *MatchQueryV1) *QueryV1
func MultiMatchQuery ¶ added in v0.17.23
func MultiMatchQuery(q *MultiMatchQueryV1) *QueryV1
func PrefixQuery ¶ added in v0.17.23
func PrefixQuery(q *PrefixQueryV1) *QueryV1
func QueryStringQuery ¶ added in v0.17.23
func RangeQuery ¶ added in v0.17.23
func RangeQuery(q *RangeQueryV1) *QueryV1
func TermQuery ¶ added in v0.17.23
func TermQuery(q *TermQueryV1) *QueryV1
func TermsQuery ¶ added in v0.17.23
func TermsQuery(q *TermsQueryV1) *QueryV1
func (*QueryV1) Descriptor
deprecated
added in
v0.14.0
func (*QueryV1) GetBool ¶ added in v0.14.0
func (x *QueryV1) GetBool() *BoolQueryV1
func (*QueryV1) GetConditions ¶ added in v0.14.0
func (x *QueryV1) GetConditions() isQueryV1_Conditions
func (*QueryV1) GetMatch ¶ added in v0.14.0
func (x *QueryV1) GetMatch() *MatchQueryV1
func (*QueryV1) GetMatchAll ¶ added in v0.14.0
func (x *QueryV1) GetMatchAll() *MatchAllQueryV1
func (*QueryV1) GetMatchPhrase ¶ added in v0.14.0
func (x *QueryV1) GetMatchPhrase() *MatchPhraseQueryV1
func (*QueryV1) GetMultiMatch ¶ added in v0.17.10
func (x *QueryV1) GetMultiMatch() *MultiMatchQueryV1
func (*QueryV1) GetPrefix ¶ added in v0.14.0
func (x *QueryV1) GetPrefix() *PrefixQueryV1
func (*QueryV1) GetQueryString ¶ added in v0.14.0
func (*QueryV1) GetRange ¶ added in v0.14.0
func (x *QueryV1) GetRange() *RangeQueryV1
func (*QueryV1) GetTerm ¶ added in v0.14.0
func (x *QueryV1) GetTerm() *TermQueryV1
func (*QueryV1) GetTerms ¶ added in v0.14.0
func (x *QueryV1) GetTerms() *TermsQueryV1
func (*QueryV1) ProtoMessage ¶ added in v0.14.0
func (*QueryV1) ProtoMessage()
func (*QueryV1) ProtoReflect ¶ added in v0.14.0
func (x *QueryV1) ProtoReflect() protoreflect.Message
type QueryV1_Bool ¶ added in v0.14.0
type QueryV1_Bool struct {
Bool *BoolQueryV1 `protobuf:"bytes,1,opt,name=bool,proto3,oneof"`
}
type QueryV1_Exists ¶ added in v0.14.0
type QueryV1_Exists struct {
Exists string `protobuf:"bytes,3,opt,name=exists,proto3,oneof"`
}
type QueryV1_Match ¶ added in v0.14.0
type QueryV1_Match struct {
Match *MatchQueryV1 `protobuf:"bytes,7,opt,name=match,proto3,oneof"`
}
type QueryV1_MatchAll ¶ added in v0.14.0
type QueryV1_MatchAll struct {
MatchAll *MatchAllQueryV1 `protobuf:"bytes,4,opt,name=match_all,json=matchAll,proto3,oneof"`
}
type QueryV1_MatchPhrase ¶ added in v0.14.0
type QueryV1_MatchPhrase struct {
MatchPhrase *MatchPhraseQueryV1 `protobuf:"bytes,8,opt,name=match_phrase,json=matchPhrase,proto3,oneof"`
}
type QueryV1_MultiMatch ¶ added in v0.17.10
type QueryV1_MultiMatch struct {
MultiMatch *MultiMatchQueryV1 `protobuf:"bytes,11,opt,name=multi_match,json=multiMatch,proto3,oneof"`
}
type QueryV1_Prefix ¶ added in v0.14.0
type QueryV1_Prefix struct {
Prefix *PrefixQueryV1 `protobuf:"bytes,10,opt,name=prefix,proto3,oneof"`
}
type QueryV1_QueryString ¶ added in v0.14.0
type QueryV1_QueryString struct {
QueryString string `protobuf:"bytes,9,opt,name=query_string,json=queryString,proto3,oneof"`
}
type QueryV1_Range ¶ added in v0.14.0
type QueryV1_Range struct {
Range *RangeQueryV1 `protobuf:"bytes,2,opt,name=range,proto3,oneof"`
}
type QueryV1_Term ¶ added in v0.14.0
type QueryV1_Term struct {
Term *TermQueryV1 `protobuf:"bytes,5,opt,name=term,proto3,oneof"`
}
type QueryV1_Terms ¶ added in v0.14.0
type QueryV1_Terms struct {
Terms *TermsQueryV1 `protobuf:"bytes,6,opt,name=terms,proto3,oneof"`
}
type RangeQueryV1 ¶ added in v0.14.0
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
}
func (*RangeQueryV1) Descriptor
deprecated
added in
v0.14.0
func (*RangeQueryV1) Descriptor() ([]byte, []int)
Deprecated: Use RangeQueryV1.ProtoReflect.Descriptor instead.
func (*RangeQueryV1) GetField ¶ added in v0.14.0
func (x *RangeQueryV1) GetField() string
func (*RangeQueryV1) GetGt ¶ added in v0.14.0
func (x *RangeQueryV1) GetGt() string
func (*RangeQueryV1) GetGte ¶ added in v0.14.0
func (x *RangeQueryV1) GetGte() string
func (*RangeQueryV1) GetLt ¶ added in v0.14.0
func (x *RangeQueryV1) GetLt() string
func (*RangeQueryV1) GetLte ¶ added in v0.14.0
func (x *RangeQueryV1) GetLte() string
func (*RangeQueryV1) ProtoMessage ¶ added in v0.14.0
func (*RangeQueryV1) ProtoMessage()
func (*RangeQueryV1) ProtoReflect ¶ added in v0.14.0
func (x *RangeQueryV1) ProtoReflect() protoreflect.Message
func (*RangeQueryV1) Reset ¶ added in v0.14.0
func (x *RangeQueryV1) Reset()
func (*RangeQueryV1) String ¶ added in v0.14.0
func (x *RangeQueryV1) String() string
type RegisterClusterAuth ¶
type RegisterClusterAuth struct {
// IAM authentication.
Iam bool `protobuf:"varint,1,opt,name=iam,proto3" json:"iam,omitempty"`
// contains filtered or unexported fields
}
func (*RegisterClusterAuth) Descriptor
deprecated
func (*RegisterClusterAuth) Descriptor() ([]byte, []int)
Deprecated: Use RegisterClusterAuth.ProtoReflect.Descriptor instead.
func (*RegisterClusterAuth) GetIam ¶
func (x *RegisterClusterAuth) GetIam() bool
func (*RegisterClusterAuth) ProtoMessage ¶
func (*RegisterClusterAuth) ProtoMessage()
func (*RegisterClusterAuth) ProtoReflect ¶
func (x *RegisterClusterAuth) ProtoReflect() protoreflect.Message
func (*RegisterClusterAuth) Reset ¶
func (x *RegisterClusterAuth) Reset()
func (*RegisterClusterAuth) String ¶
func (x *RegisterClusterAuth) String() string
type RegisterClusterRequest ¶
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
}
func (*RegisterClusterRequest) Descriptor
deprecated
func (*RegisterClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterClusterRequest.ProtoReflect.Descriptor instead.
func (*RegisterClusterRequest) GetAuth ¶
func (x *RegisterClusterRequest) GetAuth() *RegisterClusterAuth
func (*RegisterClusterRequest) GetEndpoint ¶
func (x *RegisterClusterRequest) GetEndpoint() string
func (*RegisterClusterRequest) GetName ¶
func (x *RegisterClusterRequest) GetName() string
func (*RegisterClusterRequest) ProtoMessage ¶
func (*RegisterClusterRequest) ProtoMessage()
func (*RegisterClusterRequest) ProtoReflect ¶
func (x *RegisterClusterRequest) ProtoReflect() protoreflect.Message
func (*RegisterClusterRequest) Reset ¶
func (x *RegisterClusterRequest) Reset()
func (*RegisterClusterRequest) String ¶
func (x *RegisterClusterRequest) String() string
type RegisterClusterResponse ¶
type RegisterClusterResponse struct {
// contains filtered or unexported fields
}
func (*RegisterClusterResponse) Descriptor
deprecated
func (*RegisterClusterResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterClusterResponse.ProtoReflect.Descriptor instead.
func (*RegisterClusterResponse) ProtoMessage ¶
func (*RegisterClusterResponse) ProtoMessage()
func (*RegisterClusterResponse) ProtoReflect ¶
func (x *RegisterClusterResponse) ProtoReflect() protoreflect.Message
func (*RegisterClusterResponse) Reset ¶
func (x *RegisterClusterResponse) Reset()
func (*RegisterClusterResponse) String ¶
func (x *RegisterClusterResponse) String() string
type ReindexRequest ¶
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
}
func (*ReindexRequest) Descriptor
deprecated
func (*ReindexRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReindexRequest.ProtoReflect.Descriptor instead.
func (*ReindexRequest) GetCluster ¶
func (x *ReindexRequest) GetCluster() string
func (*ReindexRequest) ProtoMessage ¶
func (*ReindexRequest) ProtoMessage()
func (*ReindexRequest) ProtoReflect ¶
func (x *ReindexRequest) ProtoReflect() protoreflect.Message
func (*ReindexRequest) Reset ¶
func (x *ReindexRequest) Reset()
func (*ReindexRequest) String ¶
func (x *ReindexRequest) String() string
type ReindexResponse ¶
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
}
func (*ReindexResponse) Descriptor
deprecated
func (*ReindexResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReindexResponse.ProtoReflect.Descriptor instead.
func (*ReindexResponse) GetName ¶
func (x *ReindexResponse) GetName() string
func (*ReindexResponse) ProtoMessage ¶
func (*ReindexResponse) ProtoMessage()
func (*ReindexResponse) ProtoReflect ¶
func (x *ReindexResponse) ProtoReflect() protoreflect.Message
func (*ReindexResponse) Reset ¶
func (x *ReindexResponse) Reset()
func (*ReindexResponse) String ¶
func (x *ReindexResponse) String() string
type SearchV1 ¶ added in v0.14.0
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)
}
func NewSearchV1JSONClient ¶ added in v0.14.0
func NewSearchV1JSONClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) SearchV1
NewSearchV1JSONClient creates a JSON client that implements the SearchV1 interface. It communicates using JSON and can be configured with a custom HTTPClient.
func NewSearchV1ProtobufClient ¶ added in v0.14.0
func NewSearchV1ProtobufClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) SearchV1
NewSearchV1ProtobufClient creates a Protobuf client that implements the SearchV1 interface. It communicates using Protobuf and can be configured with a custom HTTPClient.
type SetIndexSetStatusRequest ¶
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
}
func (*SetIndexSetStatusRequest) Descriptor
deprecated
func (*SetIndexSetStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetIndexSetStatusRequest.ProtoReflect.Descriptor instead.
func (*SetIndexSetStatusRequest) GetActive ¶
func (x *SetIndexSetStatusRequest) GetActive() bool
func (*SetIndexSetStatusRequest) GetEnabled ¶
func (x *SetIndexSetStatusRequest) GetEnabled() bool
func (*SetIndexSetStatusRequest) GetForceActive ¶
func (x *SetIndexSetStatusRequest) GetForceActive() bool
func (*SetIndexSetStatusRequest) GetName ¶
func (x *SetIndexSetStatusRequest) GetName() string
func (*SetIndexSetStatusRequest) ProtoMessage ¶
func (*SetIndexSetStatusRequest) ProtoMessage()
func (*SetIndexSetStatusRequest) ProtoReflect ¶
func (x *SetIndexSetStatusRequest) ProtoReflect() protoreflect.Message
func (*SetIndexSetStatusRequest) Reset ¶
func (x *SetIndexSetStatusRequest) Reset()
func (*SetIndexSetStatusRequest) String ¶
func (x *SetIndexSetStatusRequest) String() string
type SetIndexSetStatusResponse ¶
type SetIndexSetStatusResponse struct {
// contains filtered or unexported fields
}
func (*SetIndexSetStatusResponse) Descriptor
deprecated
func (*SetIndexSetStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetIndexSetStatusResponse.ProtoReflect.Descriptor instead.
func (*SetIndexSetStatusResponse) ProtoMessage ¶
func (*SetIndexSetStatusResponse) ProtoMessage()
func (*SetIndexSetStatusResponse) ProtoReflect ¶
func (x *SetIndexSetStatusResponse) ProtoReflect() protoreflect.Message
func (*SetIndexSetStatusResponse) Reset ¶
func (x *SetIndexSetStatusResponse) Reset()
func (*SetIndexSetStatusResponse) String ¶
func (x *SetIndexSetStatusResponse) String() string
type ShardsV1 ¶ added in v0.14.0
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
}
func (*ShardsV1) Descriptor
deprecated
added in
v0.14.0
func (*ShardsV1) GetSkipped ¶ added in v0.14.0
func (*ShardsV1) GetSuccessful ¶ added in v0.14.0
func (*ShardsV1) ProtoMessage ¶ added in v0.14.0
func (*ShardsV1) ProtoMessage()
func (*ShardsV1) ProtoReflect ¶ added in v0.14.0
func (x *ShardsV1) ProtoReflect() protoreflect.Message
type SortingV1 ¶ added in v0.14.0
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
}
func (*SortingV1) Descriptor
deprecated
added in
v0.14.0
func (*SortingV1) ProtoMessage ¶ added in v0.14.0
func (*SortingV1) ProtoMessage()
func (*SortingV1) ProtoReflect ¶ added in v0.14.0
func (x *SortingV1) ProtoReflect() protoreflect.Message
type SubscriptionItem ¶ added in v0.17.12
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
}
func (*SubscriptionItem) Descriptor
deprecated
added in
v0.17.12
func (*SubscriptionItem) Descriptor() ([]byte, []int)
Deprecated: Use SubscriptionItem.ProtoReflect.Descriptor instead.
func (*SubscriptionItem) GetDocument ¶ added in v0.17.12
func (x *SubscriptionItem) GetDocument() *newsdoc.Document
func (*SubscriptionItem) GetFields ¶ added in v0.17.12
func (x *SubscriptionItem) GetFields() map[string]*FieldValuesV1
func (*SubscriptionItem) GetId ¶ added in v0.17.12
func (x *SubscriptionItem) GetId() string
func (*SubscriptionItem) GetMatch ¶ added in v0.17.12
func (x *SubscriptionItem) GetMatch() bool
func (*SubscriptionItem) GetSource ¶ added in v0.17.12
func (x *SubscriptionItem) GetSource() map[string]*FieldValuesV1
func (*SubscriptionItem) ProtoMessage ¶ added in v0.17.12
func (*SubscriptionItem) ProtoMessage()
func (*SubscriptionItem) ProtoReflect ¶ added in v0.17.12
func (x *SubscriptionItem) ProtoReflect() protoreflect.Message
func (*SubscriptionItem) Reset ¶ added in v0.17.12
func (x *SubscriptionItem) Reset()
func (*SubscriptionItem) String ¶ added in v0.17.12
func (x *SubscriptionItem) String() string
type SubscriptionPollResult ¶ added in v0.17.8
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
}
func (*SubscriptionPollResult) Descriptor
deprecated
added in
v0.17.8
func (*SubscriptionPollResult) Descriptor() ([]byte, []int)
Deprecated: Use SubscriptionPollResult.ProtoReflect.Descriptor instead.
func (*SubscriptionPollResult) GetItems ¶ added in v0.17.8
func (x *SubscriptionPollResult) GetItems() []*SubscriptionItem
func (*SubscriptionPollResult) GetSubscription ¶ added in v0.17.8
func (x *SubscriptionPollResult) GetSubscription() *SubscriptionReference
func (*SubscriptionPollResult) ProtoMessage ¶ added in v0.17.8
func (*SubscriptionPollResult) ProtoMessage()
func (*SubscriptionPollResult) ProtoReflect ¶ added in v0.17.8
func (x *SubscriptionPollResult) ProtoReflect() protoreflect.Message
func (*SubscriptionPollResult) Reset ¶ added in v0.17.8
func (x *SubscriptionPollResult) Reset()
func (*SubscriptionPollResult) String ¶ added in v0.17.8
func (x *SubscriptionPollResult) String() string
type SubscriptionReference ¶ added in v0.17.8
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
}
func (*SubscriptionReference) Descriptor
deprecated
added in
v0.17.8
func (*SubscriptionReference) Descriptor() ([]byte, []int)
Deprecated: Use SubscriptionReference.ProtoReflect.Descriptor instead.
func (*SubscriptionReference) GetCursor ¶ added in v0.17.8
func (x *SubscriptionReference) GetCursor() int64
func (*SubscriptionReference) GetId ¶ added in v0.17.8
func (x *SubscriptionReference) GetId() int64
func (*SubscriptionReference) ProtoMessage ¶ added in v0.17.8
func (*SubscriptionReference) ProtoMessage()
func (*SubscriptionReference) ProtoReflect ¶ added in v0.17.8
func (x *SubscriptionReference) ProtoReflect() protoreflect.Message
func (*SubscriptionReference) Reset ¶ added in v0.17.8
func (x *SubscriptionReference) Reset()
func (*SubscriptionReference) String ¶ added in v0.17.8
func (x *SubscriptionReference) String() string
type TermQueryV1 ¶ added in v0.14.0
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
}
func (*TermQueryV1) Descriptor
deprecated
added in
v0.14.0
func (*TermQueryV1) Descriptor() ([]byte, []int)
Deprecated: Use TermQueryV1.ProtoReflect.Descriptor instead.
func (*TermQueryV1) GetBoost ¶ added in v0.17.8
func (x *TermQueryV1) GetBoost() float64
func (*TermQueryV1) GetField ¶ added in v0.14.0
func (x *TermQueryV1) GetField() string
func (*TermQueryV1) GetValue ¶ added in v0.14.0
func (x *TermQueryV1) GetValue() string
func (*TermQueryV1) ProtoMessage ¶ added in v0.14.0
func (*TermQueryV1) ProtoMessage()
func (*TermQueryV1) ProtoReflect ¶ added in v0.14.0
func (x *TermQueryV1) ProtoReflect() protoreflect.Message
func (*TermQueryV1) Reset ¶ added in v0.14.0
func (x *TermQueryV1) Reset()
func (*TermQueryV1) String ¶ added in v0.14.0
func (x *TermQueryV1) String() string
type TermsQueryV1 ¶ added in v0.14.0
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
}
func (*TermsQueryV1) Descriptor
deprecated
added in
v0.14.0
func (*TermsQueryV1) Descriptor() ([]byte, []int)
Deprecated: Use TermsQueryV1.ProtoReflect.Descriptor instead.
func (*TermsQueryV1) GetBoost ¶ added in v0.17.8
func (x *TermsQueryV1) GetBoost() float64
func (*TermsQueryV1) GetField ¶ added in v0.14.0
func (x *TermsQueryV1) GetField() string
func (*TermsQueryV1) GetValues ¶ added in v0.14.0
func (x *TermsQueryV1) GetValues() []string
func (*TermsQueryV1) ProtoMessage ¶ added in v0.14.0
func (*TermsQueryV1) ProtoMessage()
func (*TermsQueryV1) ProtoReflect ¶ added in v0.14.0
func (x *TermsQueryV1) ProtoReflect() protoreflect.Message
func (*TermsQueryV1) Reset ¶ added in v0.14.0
func (x *TermsQueryV1) Reset()
func (*TermsQueryV1) String ¶ added in v0.14.0
func (x *TermsQueryV1) String() string
type TwirpServer ¶
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
}
TwirpServer is the interface generated server structs will support: they're HTTP handlers with additional methods for accessing metadata about the service. Those accessors are a low-level API for building reflection tools. Most people can think of TwirpServers as just http.Handlers.
func NewManagementServer ¶
func NewManagementServer(svc Management, opts ...interface{}) TwirpServer
NewManagementServer builds a TwirpServer that can be used as an http.Handler to handle HTTP requests that are routed to the right method in the provided svc implementation. The opts are twirp.ServerOption modifiers, for example twirp.WithServerHooks(hooks).
func NewSearchV1Server ¶ added in v0.14.0
func NewSearchV1Server(svc SearchV1, opts ...interface{}) TwirpServer
NewSearchV1Server builds a TwirpServer that can be used as an http.Handler to handle HTTP requests that are routed to the right method in the provided svc implementation. The opts are twirp.ServerOption modifiers, for example twirp.WithServerHooks(hooks).