index

package
v0.17.6 Latest Latest
Warning

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

 Go to latest Published: Jan 10, 2025 License: MIT Imports: 20 Imported by: 1

Documentation

Index

Constants

View Source 
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

View Source 
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

View Source 
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.

View Source 
var File_index_search_v1_proto protoreflect.FileDescriptor
View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetAuth 

func (x *Cluster) GetAuth() *ClusterAuth

func (*Cluster) GetEndpoint 

func (x *Cluster) GetEndpoint() string

func (*Cluster) GetIndexSetCount 

func (x *Cluster) GetIndexSetCount() int64

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

func (x *Cluster) ProtoReflect() protoreflect.Message

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) String 

func (x *Cluster) String() string

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 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 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 

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

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

Deprecated: Use HitV1.ProtoReflect.Descriptor instead.

func (*HitV1) GetDocument added in v0.15.0 

func (x *HitV1) GetDocument() *newsdoc.Document

func (*HitV1) GetFields added in v0.14.0 

func (x *HitV1) GetFields() map[string]*FieldValuesV1

func (*HitV1) GetId added in v0.14.0 

func (x *HitV1) GetId() string

func (*HitV1) GetScore added in v0.14.0 

func (x *HitV1) GetScore() float32

func (*HitV1) GetSort added in v0.14.0 

func (x *HitV1) GetSort() []string

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

func (*HitV1) Reset added in v0.14.0 

func (x *HitV1) Reset()

func (*HitV1) String added in v0.14.0 

func (x *HitV1) String() string

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

Deprecated: Use HitsV1.ProtoReflect.Descriptor instead.

func (*HitsV1) GetHits added in v0.14.0 

func (x *HitsV1) GetHits() []*HitV1

func (*HitsV1) GetMaxScore added in v0.14.0 

func (x *HitsV1) GetMaxScore() float32

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

func (*HitsV1) Reset added in v0.14.0 

func (x *HitsV1) Reset()

func (*HitsV1) String added in v0.14.0 

func (x *HitsV1) String() string

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

Deprecated: Use IndexSet.ProtoReflect.Descriptor instead.

func (*IndexSet) GetActive 

func (x *IndexSet) GetActive() bool

func (*IndexSet) GetCluster 

func (x *IndexSet) GetCluster() string

func (*IndexSet) GetEnabled 

func (x *IndexSet) GetEnabled() bool

func (*IndexSet) GetName 

func (x *IndexSet) GetName() string

func (*IndexSet) GetPosition 

func (x *IndexSet) GetPosition() int64

func (*IndexSet) ProtoMessage 

func (*IndexSet) ProtoMessage()

func (*IndexSet) ProtoReflect 

func (x *IndexSet) ProtoReflect() protoreflect.Message

func (*IndexSet) Reset 

func (x *IndexSet) Reset()

func (*IndexSet) String 

func (x *IndexSet) String() string

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"`
	// 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) 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 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 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"`
	// 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) 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"`
	// 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) 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) 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"`
	// 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) 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
	Conditions isQueryV1_Conditions `protobuf_oneof:"conditions"`
	// contains filtered or unexported fields
}

func (*QueryV1) Descriptor deprecated added in v0.14.0 

func (*QueryV1) Descriptor() ([]byte, []int)

Deprecated: Use QueryV1.ProtoReflect.Descriptor instead.

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) GetExists added in v0.14.0 

func (x *QueryV1) GetExists() string

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) GetPrefix added in v0.14.0 

func (x *QueryV1) GetPrefix() *PrefixQueryV1

func (*QueryV1) GetQueryString added in v0.14.0 

func (x *QueryV1) GetQueryString() string

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

func (*QueryV1) Reset added in v0.14.0 

func (x *QueryV1) Reset()

func (*QueryV1) String added in v0.14.0 

func (x *QueryV1) String() string

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_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)

	GetMappings(context.Context, *GetMappingsRequestV1) (*GetMappingsResponseV1, 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) Descriptor() ([]byte, []int)

Deprecated: Use ShardsV1.ProtoReflect.Descriptor instead.

func (*ShardsV1) GetFailed added in v0.14.0 

func (x *ShardsV1) GetFailed() int32

func (*ShardsV1) GetSkipped added in v0.14.0 

func (x *ShardsV1) GetSkipped() int32

func (*ShardsV1) GetSuccessful added in v0.14.0 

func (x *ShardsV1) GetSuccessful() int32

func (*ShardsV1) GetTotal added in v0.14.0 

func (x *ShardsV1) GetTotal() int32

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

func (*ShardsV1) Reset added in v0.14.0 

func (x *ShardsV1) Reset()

func (*ShardsV1) String added in v0.14.0 

func (x *ShardsV1) String() string

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

Deprecated: Use SortingV1.ProtoReflect.Descriptor instead.

func (*SortingV1) GetDesc added in v0.14.0 

func (x *SortingV1) GetDesc() bool

func (*SortingV1) GetField added in v0.14.0 

func (x *SortingV1) GetField() string

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

func (*SortingV1) Reset added in v0.14.0 

func (x *SortingV1) Reset()

func (*SortingV1) String added in v0.14.0 

func (x *SortingV1) 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"`
	// 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) 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"`
	// 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) 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).

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.