storeapi

package
v0.62.1 Latest Latest
Warning

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

 Go to latest Published: Oct 13, 2025 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Overview

Package storeapi is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	AggFunc_name = map[int32]string{
		0: "AGG_FUNC_COUNT",
		1: "AGG_FUNC_SUM",
		2: "AGG_FUNC_MIN",
		3: "AGG_FUNC_MAX",
		4: "AGG_FUNC_AVG",
		5: "AGG_FUNC_QUANTILE",
		6: "AGG_FUNC_UNIQUE",
	}
	AggFunc_value = map[string]int32{
		"AGG_FUNC_COUNT":    0,
		"AGG_FUNC_SUM":      1,
		"AGG_FUNC_MIN":      2,
		"AGG_FUNC_MAX":      3,
		"AGG_FUNC_AVG":      4,
		"AGG_FUNC_QUANTILE": 5,
		"AGG_FUNC_UNIQUE":   6,
	}
)

Enum value maps for AggFunc.

View Source 
var (
	Order_name = map[int32]string{
		0: "ORDER_DESC",
		1: "ORDER_ASC",
	}
	Order_value = map[string]int32{
		"ORDER_DESC": 0,
		"ORDER_ASC":  1,
	}
)

Enum value maps for Order.

View Source 
var (
	SearchErrorCode_name = map[int32]string{
		0: "NO_ERROR",
		1: "INGESTOR_QUERY_WANTS_OLD_DATA",
		2: "TOO_MANY_UNIQ_VALUES",
		3: "TOO_MANY_FRACTIONS_HIT",
	}
	SearchErrorCode_value = map[string]int32{
		"NO_ERROR":                      0,
		"INGESTOR_QUERY_WANTS_OLD_DATA": 1,
		"TOO_MANY_UNIQ_VALUES":          2,
		"TOO_MANY_FRACTIONS_HIT":        3,
	}
)

Enum value maps for SearchErrorCode.

View Source 
var (
	AsyncSearchStatus_name = map[int32]string{
		0: "AsyncSearchStatusInProgress",
		1: "AsyncSearchStatusDone",
		2: "AsyncSearchStatusCanceled",
		3: "AsyncSearchStatusError",
	}
	AsyncSearchStatus_value = map[string]int32{
		"AsyncSearchStatusInProgress": 0,
		"AsyncSearchStatusDone":       1,
		"AsyncSearchStatusCanceled":   2,
		"AsyncSearchStatusError":      3,
	}
)

Enum value maps for AsyncSearchStatus.

View Source 
var File_storeapi_store_api_proto protoreflect.FileDescriptor
View Source 
var StoreApi_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.StoreApi",
	HandlerType: (*StoreApiServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Bulk",
			Handler:    _StoreApi_Bulk_Handler,
		},
		{
			MethodName: "Search",
			Handler:    _StoreApi_Search_Handler,
		},
		{
			MethodName: "StartAsyncSearch",
			Handler:    _StoreApi_StartAsyncSearch_Handler,
		},
		{
			MethodName: "FetchAsyncSearchResult",
			Handler:    _StoreApi_FetchAsyncSearchResult_Handler,
		},
		{
			MethodName: "CancelAsyncSearch",
			Handler:    _StoreApi_CancelAsyncSearch_Handler,
		},
		{
			MethodName: "DeleteAsyncSearch",
			Handler:    _StoreApi_DeleteAsyncSearch_Handler,
		},
		{
			MethodName: "GetAsyncSearchesList",
			Handler:    _StoreApi_GetAsyncSearchesList_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _StoreApi_Status_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Fetch",
			Handler:       _StoreApi_Fetch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "storeapi/store_api.proto",
}

StoreApi_ServiceDesc is the grpc.ServiceDesc for StoreApi service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterStoreApiHandler 

func RegisterStoreApiHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterStoreApiHandler registers the http handlers for service StoreApi to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterStoreApiHandlerClient 

func RegisterStoreApiHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StoreApiClient) error

RegisterStoreApiHandlerClient registers the http handlers for service StoreApi to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "StoreApiClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "StoreApiClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "StoreApiClient" to call the correct interceptors. This client ignores the HTTP middlewares.

func RegisterStoreApiHandlerFromEndpoint 

func RegisterStoreApiHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterStoreApiHandlerFromEndpoint is same as RegisterStoreApiHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterStoreApiHandlerServer 

func RegisterStoreApiHandlerServer(ctx context.Context, mux *runtime.ServeMux, server StoreApiServer) error

RegisterStoreApiHandlerServer registers the http handlers for service StoreApi to "mux". UnaryRPC :call StoreApiServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterStoreApiHandlerFromEndpoint instead. GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.

func RegisterStoreApiServer 

func RegisterStoreApiServer(s grpc.ServiceRegistrar, srv StoreApiServer)

Types

type AggFunc 

type AggFunc int32
const (
	AggFunc_AGG_FUNC_COUNT    AggFunc = 0
	AggFunc_AGG_FUNC_SUM      AggFunc = 1
	AggFunc_AGG_FUNC_MIN      AggFunc = 2
	AggFunc_AGG_FUNC_MAX      AggFunc = 3
	AggFunc_AGG_FUNC_AVG      AggFunc = 4
	AggFunc_AGG_FUNC_QUANTILE AggFunc = 5
	AggFunc_AGG_FUNC_UNIQUE   AggFunc = 6
)

func MustProtoAggFunc 

func MustProtoAggFunc(f seq.AggFunc) AggFunc

func ToProtoAggFunc 

func ToProtoAggFunc(f seq.AggFunc) (AggFunc, error)

func (AggFunc) Descriptor 

func (AggFunc) Descriptor() protoreflect.EnumDescriptor

func (AggFunc) Enum 

func (x AggFunc) Enum() *AggFunc

func (AggFunc) EnumDescriptor deprecated 

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

Deprecated: Use AggFunc.Descriptor instead.

func (AggFunc) MustAggFunc 

func (f AggFunc) MustAggFunc() seq.AggFunc

func (AggFunc) Number 

func (x AggFunc) Number() protoreflect.EnumNumber

func (AggFunc) String 

func (x AggFunc) String() string

func (AggFunc) ToAggFunc 

func (f AggFunc) ToAggFunc() (seq.AggFunc, error)

func (AggFunc) Type 

func (AggFunc) Type() protoreflect.EnumType

type AggQuery 

type AggQuery struct {
	Field     string    `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	GroupBy   string    `protobuf:"bytes,3,opt,name=group_by,json=groupBy,proto3" json:"group_by,omitempty"`
	Func      AggFunc   `protobuf:"varint,4,opt,name=func,proto3,enum=api.AggFunc" json:"func,omitempty"`
	Quantiles []float64 `protobuf:"fixed64,5,rep,packed,name=quantiles,proto3" json:"quantiles,omitempty"`
	Interval  int64     `protobuf:"varint,6,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*AggQuery) CloneMessageVT 

func (m *AggQuery) CloneMessageVT() proto.Message

func (*AggQuery) CloneVT 

func (m *AggQuery) CloneVT() *AggQuery

func (*AggQuery) Descriptor deprecated 

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

Deprecated: Use AggQuery.ProtoReflect.Descriptor instead.

func (*AggQuery) EqualMessageVT 

func (this *AggQuery) EqualMessageVT(thatMsg proto.Message) bool

func (*AggQuery) EqualVT 

func (this *AggQuery) EqualVT(that *AggQuery) bool

func (*AggQuery) GetField 

func (x *AggQuery) GetField() string

func (*AggQuery) GetFunc 

func (x *AggQuery) GetFunc() AggFunc

func (*AggQuery) GetGroupBy 

func (x *AggQuery) GetGroupBy() string

func (*AggQuery) GetInterval 

func (x *AggQuery) GetInterval() int64

func (*AggQuery) GetQuantiles 

func (x *AggQuery) GetQuantiles() []float64

func (*AggQuery) MarshalToSizedBufferVT 

func (m *AggQuery) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AggQuery) MarshalToSizedBufferVTStrict 

func (m *AggQuery) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*AggQuery) MarshalToVT 

func (m *AggQuery) MarshalToVT(dAtA []byte) (int, error)

func (*AggQuery) MarshalToVTStrict 

func (m *AggQuery) MarshalToVTStrict(dAtA []byte) (int, error)

func (*AggQuery) MarshalVT 

func (m *AggQuery) MarshalVT() (dAtA []byte, err error)

func (*AggQuery) MarshalVTStrict 

func (m *AggQuery) MarshalVTStrict() (dAtA []byte, err error)

func (*AggQuery) ProtoMessage 

func (*AggQuery) ProtoMessage()

func (*AggQuery) ProtoReflect 

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

func (*AggQuery) Reset 

func (x *AggQuery) Reset()

func (*AggQuery) SizeVT 

func (m *AggQuery) SizeVT() (n int)

func (*AggQuery) String 

func (x *AggQuery) String() string

func (*AggQuery) UnmarshalVT 

func (m *AggQuery) UnmarshalVT(dAtA []byte) error

func (*AggQuery) UnmarshalVTUnsafe 

func (m *AggQuery) UnmarshalVTUnsafe(dAtA []byte) error

type AsyncSearchStatus added in v0.59.0 

type AsyncSearchStatus int32
const (
	AsyncSearchStatus_AsyncSearchStatusInProgress AsyncSearchStatus = 0
	AsyncSearchStatus_AsyncSearchStatusDone       AsyncSearchStatus = 1
	AsyncSearchStatus_AsyncSearchStatusCanceled   AsyncSearchStatus = 2
	AsyncSearchStatus_AsyncSearchStatusError      AsyncSearchStatus = 3
)

func MustProtoAsyncSearchStatus added in v0.59.0 

func MustProtoAsyncSearchStatus(s fracmanager.AsyncSearchStatus) AsyncSearchStatus

func ToProtoAsyncSearchStatus added in v0.59.0 

func ToProtoAsyncSearchStatus(s fracmanager.AsyncSearchStatus) (AsyncSearchStatus, error)

func (AsyncSearchStatus) Descriptor added in v0.59.0 

func (AsyncSearchStatus) Descriptor() protoreflect.EnumDescriptor

func (AsyncSearchStatus) Enum added in v0.59.0 

func (x AsyncSearchStatus) Enum() *AsyncSearchStatus

func (AsyncSearchStatus) EnumDescriptor deprecated added in v0.59.0 

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

Deprecated: Use AsyncSearchStatus.Descriptor instead.

func (AsyncSearchStatus) MustAsyncSearchStatus added in v0.59.0 

func (s AsyncSearchStatus) MustAsyncSearchStatus() fracmanager.AsyncSearchStatus

func (AsyncSearchStatus) Number added in v0.59.0 

func (x AsyncSearchStatus) Number() protoreflect.EnumNumber

func (AsyncSearchStatus) String added in v0.59.0 

func (x AsyncSearchStatus) String() string

func (AsyncSearchStatus) ToAsyncSearchStatus added in v0.59.0 

func (s AsyncSearchStatus) ToAsyncSearchStatus() (fracmanager.AsyncSearchStatus, error)

func (AsyncSearchStatus) Type added in v0.59.0 

func (AsyncSearchStatus) Type() protoreflect.EnumType

type AsyncSearchesListItem added in v0.59.0 

type AsyncSearchesListItem struct {
	SearchId          string                 `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"`
	Status            AsyncSearchStatus      `protobuf:"varint,2,opt,name=status,proto3,enum=api.AsyncSearchStatus" json:"status,omitempty"`
	StartedAt         *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	ExpiresAt         *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	CanceledAt        *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=canceled_at,json=canceledAt,proto3,oneof" json:"canceled_at,omitempty"`
	FracsDone         uint64                 `protobuf:"varint,6,opt,name=fracs_done,json=fracsDone,proto3" json:"fracs_done,omitempty"`
	FracsQueue        uint64                 `protobuf:"varint,7,opt,name=fracs_queue,json=fracsQueue,proto3" json:"fracs_queue,omitempty"`
	DiskUsage         uint64                 `protobuf:"varint,8,opt,name=disk_usage,json=diskUsage,proto3" json:"disk_usage,omitempty"`
	Aggs              []*AggQuery            `protobuf:"bytes,9,rep,name=aggs,proto3" json:"aggs,omitempty"`
	HistogramInterval int64                  `protobuf:"varint,10,opt,name=histogram_interval,json=histogramInterval,proto3" json:"histogram_interval,omitempty"`
	Query             string                 `protobuf:"bytes,11,opt,name=query,proto3" json:"query,omitempty"`
	From              *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=from,proto3" json:"from,omitempty"`
	To                *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=to,proto3" json:"to,omitempty"`
	Retention         *durationpb.Duration   `protobuf:"bytes,14,opt,name=retention,proto3" json:"retention,omitempty"`
	WithDocs          bool                   `protobuf:"varint,15,opt,name=with_docs,json=withDocs,proto3" json:"with_docs,omitempty"`
	Size              int64                  `protobuf:"varint,16,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*AsyncSearchesListItem) CloneMessageVT added in v0.59.0 

func (m *AsyncSearchesListItem) CloneMessageVT() proto.Message

func (*AsyncSearchesListItem) CloneVT added in v0.59.0 

func (m *AsyncSearchesListItem) CloneVT() *AsyncSearchesListItem

func (*AsyncSearchesListItem) Descriptor deprecated added in v0.59.0 

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

Deprecated: Use AsyncSearchesListItem.ProtoReflect.Descriptor instead.

func (*AsyncSearchesListItem) EqualMessageVT added in v0.59.0 

func (this *AsyncSearchesListItem) EqualMessageVT(thatMsg proto.Message) bool

func (*AsyncSearchesListItem) EqualVT added in v0.59.0 

func (this *AsyncSearchesListItem) EqualVT(that *AsyncSearchesListItem) bool

func (*AsyncSearchesListItem) GetAggs added in v0.59.0 

func (x *AsyncSearchesListItem) GetAggs() []*AggQuery

func (*AsyncSearchesListItem) GetCanceledAt added in v0.59.0 

func (x *AsyncSearchesListItem) GetCanceledAt() *timestamppb.Timestamp

func (*AsyncSearchesListItem) GetDiskUsage added in v0.59.0 

func (x *AsyncSearchesListItem) GetDiskUsage() uint64

func (*AsyncSearchesListItem) GetExpiresAt added in v0.59.0 

func (x *AsyncSearchesListItem) GetExpiresAt() *timestamppb.Timestamp

func (*AsyncSearchesListItem) GetFracsDone added in v0.59.0 

func (x *AsyncSearchesListItem) GetFracsDone() uint64

func (*AsyncSearchesListItem) GetFracsQueue added in v0.59.0 

func (x *AsyncSearchesListItem) GetFracsQueue() uint64

func (*AsyncSearchesListItem) GetFrom added in v0.59.0 

func (x *AsyncSearchesListItem) GetFrom() *timestamppb.Timestamp

func (*AsyncSearchesListItem) GetHistogramInterval added in v0.59.0 

func (x *AsyncSearchesListItem) GetHistogramInterval() int64

func (*AsyncSearchesListItem) GetQuery added in v0.59.0 

func (x *AsyncSearchesListItem) GetQuery() string

func (*AsyncSearchesListItem) GetRetention added in v0.59.0 

func (x *AsyncSearchesListItem) GetRetention() *durationpb.Duration

func (*AsyncSearchesListItem) GetSearchId added in v0.59.0 

func (x *AsyncSearchesListItem) GetSearchId() string

func (*AsyncSearchesListItem) GetSize added in v0.61.2 

func (x *AsyncSearchesListItem) GetSize() int64

func (*AsyncSearchesListItem) GetStartedAt added in v0.59.0 

func (x *AsyncSearchesListItem) GetStartedAt() *timestamppb.Timestamp

func (*AsyncSearchesListItem) GetStatus added in v0.59.0 

func (x *AsyncSearchesListItem) GetStatus() AsyncSearchStatus

func (*AsyncSearchesListItem) GetTo added in v0.59.0 

func (x *AsyncSearchesListItem) GetTo() *timestamppb.Timestamp

func (*AsyncSearchesListItem) GetWithDocs added in v0.59.0 

func (x *AsyncSearchesListItem) GetWithDocs() bool

func (*AsyncSearchesListItem) MarshalToSizedBufferVT added in v0.59.0 

func (m *AsyncSearchesListItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AsyncSearchesListItem) MarshalToSizedBufferVTStrict added in v0.59.0 

func (m *AsyncSearchesListItem) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*AsyncSearchesListItem) MarshalToVT added in v0.59.0 

func (m *AsyncSearchesListItem) MarshalToVT(dAtA []byte) (int, error)

func (*AsyncSearchesListItem) MarshalToVTStrict added in v0.59.0 

func (m *AsyncSearchesListItem) MarshalToVTStrict(dAtA []byte) (int, error)

func (*AsyncSearchesListItem) MarshalVT added in v0.59.0 

func (m *AsyncSearchesListItem) MarshalVT() (dAtA []byte, err error)

func (*AsyncSearchesListItem) MarshalVTStrict added in v0.59.0 

func (m *AsyncSearchesListItem) MarshalVTStrict() (dAtA []byte, err error)

func (*AsyncSearchesListItem) ProtoMessage added in v0.59.0 

func (*AsyncSearchesListItem) ProtoMessage()

func (*AsyncSearchesListItem) ProtoReflect added in v0.59.0 

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

func (*AsyncSearchesListItem) Reset added in v0.59.0 

func (x *AsyncSearchesListItem) Reset()

func (*AsyncSearchesListItem) SizeVT added in v0.59.0 

func (m *AsyncSearchesListItem) SizeVT() (n int)

func (*AsyncSearchesListItem) String added in v0.59.0 

func (x *AsyncSearchesListItem) String() string

func (*AsyncSearchesListItem) UnmarshalVT added in v0.59.0 

func (m *AsyncSearchesListItem) UnmarshalVT(dAtA []byte) error

func (*AsyncSearchesListItem) UnmarshalVTUnsafe added in v0.59.0 

func (m *AsyncSearchesListItem) UnmarshalVTUnsafe(dAtA []byte) error

type BinaryData 

type BinaryData struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*BinaryData) CloneMessageVT 

func (m *BinaryData) CloneMessageVT() proto.Message

func (*BinaryData) CloneVT 

func (m *BinaryData) CloneVT() *BinaryData

func (*BinaryData) Descriptor deprecated 

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

Deprecated: Use BinaryData.ProtoReflect.Descriptor instead.

func (*BinaryData) EqualMessageVT 

func (this *BinaryData) EqualMessageVT(thatMsg proto.Message) bool

func (*BinaryData) EqualVT 

func (this *BinaryData) EqualVT(that *BinaryData) bool

func (*BinaryData) GetData 

func (x *BinaryData) GetData() []byte

func (*BinaryData) MarshalToSizedBufferVT 

func (m *BinaryData) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BinaryData) MarshalToSizedBufferVTStrict 

func (m *BinaryData) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*BinaryData) MarshalToVT 

func (m *BinaryData) MarshalToVT(dAtA []byte) (int, error)

func (*BinaryData) MarshalToVTStrict 

func (m *BinaryData) MarshalToVTStrict(dAtA []byte) (int, error)

func (*BinaryData) MarshalVT 

func (m *BinaryData) MarshalVT() (dAtA []byte, err error)

func (*BinaryData) MarshalVTStrict 

func (m *BinaryData) MarshalVTStrict() (dAtA []byte, err error)

func (*BinaryData) ProtoMessage 

func (*BinaryData) ProtoMessage()

func (*BinaryData) ProtoReflect 

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

func (*BinaryData) Reset 

func (x *BinaryData) Reset()

func (*BinaryData) SizeVT 

func (m *BinaryData) SizeVT() (n int)

func (*BinaryData) String 

func (x *BinaryData) String() string

func (*BinaryData) UnmarshalVT 

func (m *BinaryData) UnmarshalVT(dAtA []byte) error

func (*BinaryData) UnmarshalVTUnsafe 

func (m *BinaryData) UnmarshalVTUnsafe(dAtA []byte) error

type BulkRequest 

type BulkRequest struct {
	Count int64  `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Docs  []byte `protobuf:"bytes,2,opt,name=docs,proto3" json:"docs,omitempty"`
	Metas []byte `protobuf:"bytes,3,opt,name=metas,proto3" json:"metas,omitempty"`
	// contains filtered or unexported fields
}

func (*BulkRequest) CloneMessageVT 

func (m *BulkRequest) CloneMessageVT() proto.Message

func (*BulkRequest) CloneVT 

func (m *BulkRequest) CloneVT() *BulkRequest

func (*BulkRequest) Descriptor deprecated 

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

Deprecated: Use BulkRequest.ProtoReflect.Descriptor instead.

func (*BulkRequest) EqualMessageVT 

func (this *BulkRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*BulkRequest) EqualVT 

func (this *BulkRequest) EqualVT(that *BulkRequest) bool

func (*BulkRequest) GetCount 

func (x *BulkRequest) GetCount() int64

func (*BulkRequest) GetDocs 

func (x *BulkRequest) GetDocs() []byte

func (*BulkRequest) GetMetas 

func (x *BulkRequest) GetMetas() []byte

func (*BulkRequest) MarshalToSizedBufferVT 

func (m *BulkRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BulkRequest) MarshalToSizedBufferVTStrict 

func (m *BulkRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*BulkRequest) MarshalToVT 

func (m *BulkRequest) MarshalToVT(dAtA []byte) (int, error)

func (*BulkRequest) MarshalToVTStrict 

func (m *BulkRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*BulkRequest) MarshalVT 

func (m *BulkRequest) MarshalVT() (dAtA []byte, err error)

func (*BulkRequest) MarshalVTStrict 

func (m *BulkRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*BulkRequest) ProtoMessage 

func (*BulkRequest) ProtoMessage()

func (*BulkRequest) ProtoReflect 

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

func (*BulkRequest) Reset 

func (x *BulkRequest) Reset()

func (*BulkRequest) SizeVT 

func (m *BulkRequest) SizeVT() (n int)

func (*BulkRequest) String 

func (x *BulkRequest) String() string

func (*BulkRequest) UnmarshalVT 

func (m *BulkRequest) UnmarshalVT(dAtA []byte) error

func (*BulkRequest) UnmarshalVTUnsafe 

func (m *BulkRequest) UnmarshalVTUnsafe(dAtA []byte) error

type CancelAsyncSearchRequest added in v0.59.0 

type CancelAsyncSearchRequest struct {
	SearchId string `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelAsyncSearchRequest) CloneMessageVT added in v0.59.0 

func (m *CancelAsyncSearchRequest) CloneMessageVT() proto.Message

func (*CancelAsyncSearchRequest) CloneVT added in v0.59.0 

func (m *CancelAsyncSearchRequest) CloneVT() *CancelAsyncSearchRequest

func (*CancelAsyncSearchRequest) Descriptor deprecated added in v0.59.0 

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

Deprecated: Use CancelAsyncSearchRequest.ProtoReflect.Descriptor instead.

func (*CancelAsyncSearchRequest) EqualMessageVT added in v0.59.0 

func (this *CancelAsyncSearchRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*CancelAsyncSearchRequest) EqualVT added in v0.59.0 

func (this *CancelAsyncSearchRequest) EqualVT(that *CancelAsyncSearchRequest) bool

func (*CancelAsyncSearchRequest) GetSearchId added in v0.59.0 

func (x *CancelAsyncSearchRequest) GetSearchId() string

func (*CancelAsyncSearchRequest) MarshalToSizedBufferVT added in v0.59.0 

func (m *CancelAsyncSearchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CancelAsyncSearchRequest) MarshalToSizedBufferVTStrict added in v0.59.0 

func (m *CancelAsyncSearchRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*CancelAsyncSearchRequest) MarshalToVT added in v0.59.0 

func (m *CancelAsyncSearchRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CancelAsyncSearchRequest) MarshalToVTStrict added in v0.59.0 

func (m *CancelAsyncSearchRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*CancelAsyncSearchRequest) MarshalVT added in v0.59.0 

func (m *CancelAsyncSearchRequest) MarshalVT() (dAtA []byte, err error)

func (*CancelAsyncSearchRequest) MarshalVTStrict added in v0.59.0 

func (m *CancelAsyncSearchRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*CancelAsyncSearchRequest) ProtoMessage added in v0.59.0 

func (*CancelAsyncSearchRequest) ProtoMessage()

func (*CancelAsyncSearchRequest) ProtoReflect added in v0.59.0 

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

func (*CancelAsyncSearchRequest) Reset added in v0.59.0 

func (x *CancelAsyncSearchRequest) Reset()

func (*CancelAsyncSearchRequest) SizeVT added in v0.59.0 

func (m *CancelAsyncSearchRequest) SizeVT() (n int)

func (*CancelAsyncSearchRequest) String added in v0.59.0 

func (x *CancelAsyncSearchRequest) String() string

func (*CancelAsyncSearchRequest) UnmarshalVT added in v0.59.0 

func (m *CancelAsyncSearchRequest) UnmarshalVT(dAtA []byte) error

func (*CancelAsyncSearchRequest) UnmarshalVTUnsafe added in v0.59.0 

func (m *CancelAsyncSearchRequest) UnmarshalVTUnsafe(dAtA []byte) error

type CancelAsyncSearchResponse added in v0.59.0 

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

func (*CancelAsyncSearchResponse) CloneMessageVT added in v0.59.0 

func (m *CancelAsyncSearchResponse) CloneMessageVT() proto.Message

func (*CancelAsyncSearchResponse) CloneVT added in v0.59.0 

func (m *CancelAsyncSearchResponse) CloneVT() *CancelAsyncSearchResponse

func (*CancelAsyncSearchResponse) Descriptor deprecated added in v0.59.0 

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

Deprecated: Use CancelAsyncSearchResponse.ProtoReflect.Descriptor instead.

func (*CancelAsyncSearchResponse) EqualMessageVT added in v0.59.0 

func (this *CancelAsyncSearchResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*CancelAsyncSearchResponse) EqualVT added in v0.59.0 

func (this *CancelAsyncSearchResponse) EqualVT(that *CancelAsyncSearchResponse) bool

func (*CancelAsyncSearchResponse) MarshalToSizedBufferVT added in v0.59.0 

func (m *CancelAsyncSearchResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CancelAsyncSearchResponse) MarshalToSizedBufferVTStrict added in v0.59.0 

func (m *CancelAsyncSearchResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*CancelAsyncSearchResponse) MarshalToVT added in v0.59.0 

func (m *CancelAsyncSearchResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CancelAsyncSearchResponse) MarshalToVTStrict added in v0.59.0 

func (m *CancelAsyncSearchResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*CancelAsyncSearchResponse) MarshalVT added in v0.59.0 

func (m *CancelAsyncSearchResponse) MarshalVT() (dAtA []byte, err error)

func (*CancelAsyncSearchResponse) MarshalVTStrict added in v0.59.0 

func (m *CancelAsyncSearchResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*CancelAsyncSearchResponse) ProtoMessage added in v0.59.0 

func (*CancelAsyncSearchResponse) ProtoMessage()

func (*CancelAsyncSearchResponse) ProtoReflect added in v0.59.0 

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

func (*CancelAsyncSearchResponse) Reset added in v0.59.0 

func (x *CancelAsyncSearchResponse) Reset()

func (*CancelAsyncSearchResponse) SizeVT added in v0.59.0 

func (m *CancelAsyncSearchResponse) SizeVT() (n int)

func (*CancelAsyncSearchResponse) String added in v0.59.0 

func (x *CancelAsyncSearchResponse) String() string

func (*CancelAsyncSearchResponse) UnmarshalVT added in v0.59.0 

func (m *CancelAsyncSearchResponse) UnmarshalVT(dAtA []byte) error

func (*CancelAsyncSearchResponse) UnmarshalVTUnsafe added in v0.59.0 

func (m *CancelAsyncSearchResponse) UnmarshalVTUnsafe(dAtA []byte) error

type DeleteAsyncSearchRequest added in v0.59.0 

type DeleteAsyncSearchRequest struct {
	SearchId string `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteAsyncSearchRequest) CloneMessageVT added in v0.59.0 

func (m *DeleteAsyncSearchRequest) CloneMessageVT() proto.Message

func (*DeleteAsyncSearchRequest) CloneVT added in v0.59.0 

func (m *DeleteAsyncSearchRequest) CloneVT() *DeleteAsyncSearchRequest

func (*DeleteAsyncSearchRequest) Descriptor deprecated added in v0.59.0 

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

Deprecated: Use DeleteAsyncSearchRequest.ProtoReflect.Descriptor instead.

func (*DeleteAsyncSearchRequest) EqualMessageVT added in v0.59.0 

func (this *DeleteAsyncSearchRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*DeleteAsyncSearchRequest) EqualVT added in v0.59.0 

func (this *DeleteAsyncSearchRequest) EqualVT(that *DeleteAsyncSearchRequest) bool

func (*DeleteAsyncSearchRequest) GetSearchId added in v0.59.0 

func (x *DeleteAsyncSearchRequest) GetSearchId() string

func (*DeleteAsyncSearchRequest) MarshalToSizedBufferVT added in v0.59.0 

func (m *DeleteAsyncSearchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteAsyncSearchRequest) MarshalToSizedBufferVTStrict added in v0.59.0 

func (m *DeleteAsyncSearchRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*DeleteAsyncSearchRequest) MarshalToVT added in v0.59.0 

func (m *DeleteAsyncSearchRequest) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteAsyncSearchRequest) MarshalToVTStrict added in v0.59.0 

func (m *DeleteAsyncSearchRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*DeleteAsyncSearchRequest) MarshalVT added in v0.59.0 

func (m *DeleteAsyncSearchRequest) MarshalVT() (dAtA []byte, err error)

func (*DeleteAsyncSearchRequest) MarshalVTStrict added in v0.59.0 

func (m *DeleteAsyncSearchRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*DeleteAsyncSearchRequest) ProtoMessage added in v0.59.0 

func (*DeleteAsyncSearchRequest) ProtoMessage()

func (*DeleteAsyncSearchRequest) ProtoReflect added in v0.59.0 

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

func (*DeleteAsyncSearchRequest) Reset added in v0.59.0 

func (x *DeleteAsyncSearchRequest) Reset()

func (*DeleteAsyncSearchRequest) SizeVT added in v0.59.0 

func (m *DeleteAsyncSearchRequest) SizeVT() (n int)

func (*DeleteAsyncSearchRequest) String added in v0.59.0 

func (x *DeleteAsyncSearchRequest) String() string

func (*DeleteAsyncSearchRequest) UnmarshalVT added in v0.59.0 

func (m *DeleteAsyncSearchRequest) UnmarshalVT(dAtA []byte) error

func (*DeleteAsyncSearchRequest) UnmarshalVTUnsafe added in v0.59.0 

func (m *DeleteAsyncSearchRequest) UnmarshalVTUnsafe(dAtA []byte) error

type DeleteAsyncSearchResponse added in v0.59.0 

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

func (*DeleteAsyncSearchResponse) CloneMessageVT added in v0.59.0 

func (m *DeleteAsyncSearchResponse) CloneMessageVT() proto.Message

func (*DeleteAsyncSearchResponse) CloneVT added in v0.59.0 

func (m *DeleteAsyncSearchResponse) CloneVT() *DeleteAsyncSearchResponse

func (*DeleteAsyncSearchResponse) Descriptor deprecated added in v0.59.0 

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

Deprecated: Use DeleteAsyncSearchResponse.ProtoReflect.Descriptor instead.

func (*DeleteAsyncSearchResponse) EqualMessageVT added in v0.59.0 

func (this *DeleteAsyncSearchResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*DeleteAsyncSearchResponse) EqualVT added in v0.59.0 

func (this *DeleteAsyncSearchResponse) EqualVT(that *DeleteAsyncSearchResponse) bool

func (*DeleteAsyncSearchResponse) MarshalToSizedBufferVT added in v0.59.0 

func (m *DeleteAsyncSearchResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteAsyncSearchResponse) MarshalToSizedBufferVTStrict added in v0.59.0 

func (m *DeleteAsyncSearchResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*DeleteAsyncSearchResponse) MarshalToVT added in v0.59.0 

func (m *DeleteAsyncSearchResponse) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteAsyncSearchResponse) MarshalToVTStrict added in v0.59.0 

func (m *DeleteAsyncSearchResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*DeleteAsyncSearchResponse) MarshalVT added in v0.59.0 

func (m *DeleteAsyncSearchResponse) MarshalVT() (dAtA []byte, err error)

func (*DeleteAsyncSearchResponse) MarshalVTStrict added in v0.59.0 

func (m *DeleteAsyncSearchResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*DeleteAsyncSearchResponse) ProtoMessage added in v0.59.0 

func (*DeleteAsyncSearchResponse) ProtoMessage()

func (*DeleteAsyncSearchResponse) ProtoReflect added in v0.59.0 

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

func (*DeleteAsyncSearchResponse) Reset added in v0.59.0 

func (x *DeleteAsyncSearchResponse) Reset()

func (*DeleteAsyncSearchResponse) SizeVT added in v0.59.0 

func (m *DeleteAsyncSearchResponse) SizeVT() (n int)

func (*DeleteAsyncSearchResponse) String added in v0.59.0 

func (x *DeleteAsyncSearchResponse) String() string

func (*DeleteAsyncSearchResponse) UnmarshalVT added in v0.59.0 

func (m *DeleteAsyncSearchResponse) UnmarshalVT(dAtA []byte) error

func (*DeleteAsyncSearchResponse) UnmarshalVTUnsafe added in v0.59.0 

func (m *DeleteAsyncSearchResponse) UnmarshalVTUnsafe(dAtA []byte) error

type ExplainEntry 

type ExplainEntry struct {
	Message  string               `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Duration *durationpb.Duration `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"`
	Children []*ExplainEntry      `protobuf:"bytes,3,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainEntry) CloneMessageVT 

func (m *ExplainEntry) CloneMessageVT() proto.Message

func (*ExplainEntry) CloneVT 

func (m *ExplainEntry) CloneVT() *ExplainEntry

func (*ExplainEntry) Descriptor deprecated 

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

Deprecated: Use ExplainEntry.ProtoReflect.Descriptor instead.

func (*ExplainEntry) EqualMessageVT 

func (this *ExplainEntry) EqualMessageVT(thatMsg proto.Message) bool

func (*ExplainEntry) EqualVT 

func (this *ExplainEntry) EqualVT(that *ExplainEntry) bool

func (*ExplainEntry) GetChildren 

func (x *ExplainEntry) GetChildren() []*ExplainEntry

func (*ExplainEntry) GetDuration 

func (x *ExplainEntry) GetDuration() *durationpb.Duration

func (*ExplainEntry) GetMessage 

func (x *ExplainEntry) GetMessage() string

func (*ExplainEntry) MarshalToSizedBufferVT 

func (m *ExplainEntry) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ExplainEntry) MarshalToSizedBufferVTStrict 

func (m *ExplainEntry) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*ExplainEntry) MarshalToVT 

func (m *ExplainEntry) MarshalToVT(dAtA []byte) (int, error)

func (*ExplainEntry) MarshalToVTStrict 

func (m *ExplainEntry) MarshalToVTStrict(dAtA []byte) (int, error)

func (*ExplainEntry) MarshalVT 

func (m *ExplainEntry) MarshalVT() (dAtA []byte, err error)

func (*ExplainEntry) MarshalVTStrict 

func (m *ExplainEntry) MarshalVTStrict() (dAtA []byte, err error)

func (*ExplainEntry) ProtoMessage 

func (*ExplainEntry) ProtoMessage()

func (*ExplainEntry) ProtoReflect 

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

func (*ExplainEntry) Reset 

func (x *ExplainEntry) Reset()

func (*ExplainEntry) SizeVT 

func (m *ExplainEntry) SizeVT() (n int)

func (*ExplainEntry) String 

func (x *ExplainEntry) String() string

func (*ExplainEntry) UnmarshalVT 

func (m *ExplainEntry) UnmarshalVT(dAtA []byte) error

func (*ExplainEntry) UnmarshalVTUnsafe 

func (m *ExplainEntry) UnmarshalVTUnsafe(dAtA []byte) error

type FetchAsyncSearchResultRequest 

type FetchAsyncSearchResultRequest struct {
	SearchId string `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"`
	Size     int32  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Offset   int32  `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	Order    Order  `protobuf:"varint,4,opt,name=order,proto3,enum=api.Order" json:"order,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchAsyncSearchResultRequest) CloneMessageVT 

func (m *FetchAsyncSearchResultRequest) CloneMessageVT() proto.Message

func (*FetchAsyncSearchResultRequest) CloneVT 

func (m *FetchAsyncSearchResultRequest) CloneVT() *FetchAsyncSearchResultRequest

func (*FetchAsyncSearchResultRequest) Descriptor deprecated 

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

Deprecated: Use FetchAsyncSearchResultRequest.ProtoReflect.Descriptor instead.

func (*FetchAsyncSearchResultRequest) EqualMessageVT 

func (this *FetchAsyncSearchResultRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*FetchAsyncSearchResultRequest) EqualVT 

func (this *FetchAsyncSearchResultRequest) EqualVT(that *FetchAsyncSearchResultRequest) bool

func (*FetchAsyncSearchResultRequest) GetOffset 

func (x *FetchAsyncSearchResultRequest) GetOffset() int32

func (*FetchAsyncSearchResultRequest) GetOrder added in v0.59.0 

func (x *FetchAsyncSearchResultRequest) GetOrder() Order

func (*FetchAsyncSearchResultRequest) GetSearchId 

func (x *FetchAsyncSearchResultRequest) GetSearchId() string

func (*FetchAsyncSearchResultRequest) GetSize 

func (x *FetchAsyncSearchResultRequest) GetSize() int32

func (*FetchAsyncSearchResultRequest) MarshalToSizedBufferVT 

func (m *FetchAsyncSearchResultRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FetchAsyncSearchResultRequest) MarshalToSizedBufferVTStrict 

func (m *FetchAsyncSearchResultRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*FetchAsyncSearchResultRequest) MarshalToVT 

func (m *FetchAsyncSearchResultRequest) MarshalToVT(dAtA []byte) (int, error)

func (*FetchAsyncSearchResultRequest) MarshalToVTStrict 

func (m *FetchAsyncSearchResultRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*FetchAsyncSearchResultRequest) MarshalVT 

func (m *FetchAsyncSearchResultRequest) MarshalVT() (dAtA []byte, err error)

func (*FetchAsyncSearchResultRequest) MarshalVTStrict 

func (m *FetchAsyncSearchResultRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*FetchAsyncSearchResultRequest) ProtoMessage 

func (*FetchAsyncSearchResultRequest) ProtoMessage()

func (*FetchAsyncSearchResultRequest) ProtoReflect 

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

func (*FetchAsyncSearchResultRequest) Reset 

func (x *FetchAsyncSearchResultRequest) Reset()

func (*FetchAsyncSearchResultRequest) SizeVT 

func (m *FetchAsyncSearchResultRequest) SizeVT() (n int)

func (*FetchAsyncSearchResultRequest) String 

func (x *FetchAsyncSearchResultRequest) String() string

func (*FetchAsyncSearchResultRequest) UnmarshalVT 

func (m *FetchAsyncSearchResultRequest) UnmarshalVT(dAtA []byte) error

func (*FetchAsyncSearchResultRequest) UnmarshalVTUnsafe 

func (m *FetchAsyncSearchResultRequest) UnmarshalVTUnsafe(dAtA []byte) error

type FetchAsyncSearchResultResponse 

type FetchAsyncSearchResultResponse struct {
	Status            AsyncSearchStatus      `protobuf:"varint,1,opt,name=status,proto3,enum=api.AsyncSearchStatus" json:"status,omitempty"`
	Response          *SearchResponse        `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	StartedAt         *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	ExpiresAt         *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	CanceledAt        *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=canceled_at,json=canceledAt,proto3,oneof" json:"canceled_at,omitempty"`
	FracsDone         uint64                 `protobuf:"varint,6,opt,name=fracs_done,json=fracsDone,proto3" json:"fracs_done,omitempty"`
	FracsQueue        uint64                 `protobuf:"varint,7,opt,name=fracs_queue,json=fracsQueue,proto3" json:"fracs_queue,omitempty"`
	DiskUsage         uint64                 `protobuf:"varint,8,opt,name=disk_usage,json=diskUsage,proto3" json:"disk_usage,omitempty"`
	Aggs              []*AggQuery            `protobuf:"bytes,9,rep,name=aggs,proto3" json:"aggs,omitempty"`
	HistogramInterval int64                  `protobuf:"varint,10,opt,name=histogram_interval,json=histogramInterval,proto3" json:"histogram_interval,omitempty"`
	Query             string                 `protobuf:"bytes,11,opt,name=query,proto3" json:"query,omitempty"`
	From              *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=from,proto3" json:"from,omitempty"`
	To                *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=to,proto3" json:"to,omitempty"`
	Retention         *durationpb.Duration   `protobuf:"bytes,14,opt,name=retention,proto3" json:"retention,omitempty"`
	WithDocs          bool                   `protobuf:"varint,15,opt,name=with_docs,json=withDocs,proto3" json:"with_docs,omitempty"`
	Size              int64                  `protobuf:"varint,16,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchAsyncSearchResultResponse) CloneMessageVT 

func (m *FetchAsyncSearchResultResponse) CloneMessageVT() proto.Message

func (*FetchAsyncSearchResultResponse) CloneVT 

func (m *FetchAsyncSearchResultResponse) CloneVT() *FetchAsyncSearchResultResponse

func (*FetchAsyncSearchResultResponse) Descriptor deprecated 

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

Deprecated: Use FetchAsyncSearchResultResponse.ProtoReflect.Descriptor instead.

func (*FetchAsyncSearchResultResponse) EqualMessageVT 

func (this *FetchAsyncSearchResultResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*FetchAsyncSearchResultResponse) EqualVT 

func (this *FetchAsyncSearchResultResponse) EqualVT(that *FetchAsyncSearchResultResponse) bool

func (*FetchAsyncSearchResultResponse) GetAggs 

func (x *FetchAsyncSearchResultResponse) GetAggs() []*AggQuery

func (*FetchAsyncSearchResultResponse) GetCanceledAt added in v0.59.0 

func (x *FetchAsyncSearchResultResponse) GetCanceledAt() *timestamppb.Timestamp

func (*FetchAsyncSearchResultResponse) GetDiskUsage added in v0.59.0 

func (x *FetchAsyncSearchResultResponse) GetDiskUsage() uint64

func (*FetchAsyncSearchResultResponse) GetExpiresAt added in v0.59.0 

func (x *FetchAsyncSearchResultResponse) GetExpiresAt() *timestamppb.Timestamp

func (*FetchAsyncSearchResultResponse) GetFracsDone added in v0.59.0 

func (x *FetchAsyncSearchResultResponse) GetFracsDone() uint64

func (*FetchAsyncSearchResultResponse) GetFracsQueue added in v0.59.0 

func (x *FetchAsyncSearchResultResponse) GetFracsQueue() uint64

func (*FetchAsyncSearchResultResponse) GetFrom added in v0.59.0 

func (x *FetchAsyncSearchResultResponse) GetFrom() *timestamppb.Timestamp

func (*FetchAsyncSearchResultResponse) GetHistogramInterval 

func (x *FetchAsyncSearchResultResponse) GetHistogramInterval() int64

func (*FetchAsyncSearchResultResponse) GetQuery added in v0.59.0 

func (x *FetchAsyncSearchResultResponse) GetQuery() string

func (*FetchAsyncSearchResultResponse) GetResponse 

func (x *FetchAsyncSearchResultResponse) GetResponse() *SearchResponse

func (*FetchAsyncSearchResultResponse) GetRetention added in v0.59.0 

func (x *FetchAsyncSearchResultResponse) GetRetention() *durationpb.Duration

func (*FetchAsyncSearchResultResponse) GetSize added in v0.61.2 

func (x *FetchAsyncSearchResultResponse) GetSize() int64

func (*FetchAsyncSearchResultResponse) GetStartedAt added in v0.59.0 

func (x *FetchAsyncSearchResultResponse) GetStartedAt() *timestamppb.Timestamp

func (*FetchAsyncSearchResultResponse) GetStatus added in v0.59.0 

func (x *FetchAsyncSearchResultResponse) GetStatus() AsyncSearchStatus

func (*FetchAsyncSearchResultResponse) GetTo added in v0.59.0 

func (x *FetchAsyncSearchResultResponse) GetTo() *timestamppb.Timestamp

func (*FetchAsyncSearchResultResponse) GetWithDocs added in v0.59.0 

func (x *FetchAsyncSearchResultResponse) GetWithDocs() bool

func (*FetchAsyncSearchResultResponse) MarshalToSizedBufferVT 

func (m *FetchAsyncSearchResultResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FetchAsyncSearchResultResponse) MarshalToSizedBufferVTStrict 

func (m *FetchAsyncSearchResultResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*FetchAsyncSearchResultResponse) MarshalToVT 

func (m *FetchAsyncSearchResultResponse) MarshalToVT(dAtA []byte) (int, error)

func (*FetchAsyncSearchResultResponse) MarshalToVTStrict 

func (m *FetchAsyncSearchResultResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*FetchAsyncSearchResultResponse) MarshalVT 

func (m *FetchAsyncSearchResultResponse) MarshalVT() (dAtA []byte, err error)

func (*FetchAsyncSearchResultResponse) MarshalVTStrict 

func (m *FetchAsyncSearchResultResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*FetchAsyncSearchResultResponse) ProtoMessage 

func (*FetchAsyncSearchResultResponse) ProtoMessage()

func (*FetchAsyncSearchResultResponse) ProtoReflect 

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

func (*FetchAsyncSearchResultResponse) Reset 

func (x *FetchAsyncSearchResultResponse) Reset()

func (*FetchAsyncSearchResultResponse) SizeVT 

func (m *FetchAsyncSearchResultResponse) SizeVT() (n int)

func (*FetchAsyncSearchResultResponse) String 

func (x *FetchAsyncSearchResultResponse) String() string

func (*FetchAsyncSearchResultResponse) UnmarshalVT 

func (m *FetchAsyncSearchResultResponse) UnmarshalVT(dAtA []byte) error

func (*FetchAsyncSearchResultResponse) UnmarshalVTUnsafe 

func (m *FetchAsyncSearchResultResponse) UnmarshalVTUnsafe(dAtA []byte) error

type FetchRequest 

type FetchRequest struct {
	Ids          []string                   `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Explain      bool                       `protobuf:"varint,3,opt,name=explain,proto3" json:"explain,omitempty"`
	IdsWithHints []*IdWithHint              `protobuf:"bytes,4,rep,name=ids_with_hints,json=idsWithHints,proto3" json:"ids_with_hints,omitempty"`
	FieldsFilter *FetchRequest_FieldsFilter `protobuf:"bytes,5,opt,name=fields_filter,json=fieldsFilter,proto3" json:"fields_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchRequest) CloneMessageVT 

func (m *FetchRequest) CloneMessageVT() proto.Message

func (*FetchRequest) CloneVT 

func (m *FetchRequest) CloneVT() *FetchRequest

func (*FetchRequest) Descriptor deprecated 

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

Deprecated: Use FetchRequest.ProtoReflect.Descriptor instead.

func (*FetchRequest) EqualMessageVT 

func (this *FetchRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*FetchRequest) EqualVT 

func (this *FetchRequest) EqualVT(that *FetchRequest) bool

func (*FetchRequest) GetExplain 

func (x *FetchRequest) GetExplain() bool

func (*FetchRequest) GetFieldsFilter 

func (x *FetchRequest) GetFieldsFilter() *FetchRequest_FieldsFilter

func (*FetchRequest) GetIds 

func (x *FetchRequest) GetIds() []string

func (*FetchRequest) GetIdsWithHints 

func (x *FetchRequest) GetIdsWithHints() []*IdWithHint

func (*FetchRequest) MarshalToSizedBufferVT 

func (m *FetchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FetchRequest) MarshalToSizedBufferVTStrict 

func (m *FetchRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*FetchRequest) MarshalToVT 

func (m *FetchRequest) MarshalToVT(dAtA []byte) (int, error)

func (*FetchRequest) MarshalToVTStrict 

func (m *FetchRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*FetchRequest) MarshalVT 

func (m *FetchRequest) MarshalVT() (dAtA []byte, err error)

func (*FetchRequest) MarshalVTStrict 

func (m *FetchRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*FetchRequest) ProtoMessage 

func (*FetchRequest) ProtoMessage()

func (*FetchRequest) ProtoReflect 

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

func (*FetchRequest) Reset 

func (x *FetchRequest) Reset()

func (*FetchRequest) SizeVT 

func (m *FetchRequest) SizeVT() (n int)

func (*FetchRequest) String 

func (x *FetchRequest) String() string

func (*FetchRequest) UnmarshalVT 

func (m *FetchRequest) UnmarshalVT(dAtA []byte) error

func (*FetchRequest) UnmarshalVTUnsafe 

func (m *FetchRequest) UnmarshalVTUnsafe(dAtA []byte) error

type FetchRequest_FieldsFilter 

type FetchRequest_FieldsFilter struct {
	Fields []string `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	// see seqproxyapi.FetchRequest.FieldsFilter.allow_list for details.
	AllowList bool `protobuf:"varint,2,opt,name=allow_list,json=allowList,proto3" json:"allow_list,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchRequest_FieldsFilter) CloneMessageVT 

func (m *FetchRequest_FieldsFilter) CloneMessageVT() proto.Message

func (*FetchRequest_FieldsFilter) CloneVT 

func (m *FetchRequest_FieldsFilter) CloneVT() *FetchRequest_FieldsFilter

func (*FetchRequest_FieldsFilter) Descriptor deprecated 

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

Deprecated: Use FetchRequest_FieldsFilter.ProtoReflect.Descriptor instead.

func (*FetchRequest_FieldsFilter) EqualMessageVT 

func (this *FetchRequest_FieldsFilter) EqualMessageVT(thatMsg proto.Message) bool

func (*FetchRequest_FieldsFilter) EqualVT 

func (this *FetchRequest_FieldsFilter) EqualVT(that *FetchRequest_FieldsFilter) bool

func (*FetchRequest_FieldsFilter) GetAllowList 

func (x *FetchRequest_FieldsFilter) GetAllowList() bool

func (*FetchRequest_FieldsFilter) GetFields 

func (x *FetchRequest_FieldsFilter) GetFields() []string

func (*FetchRequest_FieldsFilter) MarshalToSizedBufferVT 

func (m *FetchRequest_FieldsFilter) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FetchRequest_FieldsFilter) MarshalToSizedBufferVTStrict 

func (m *FetchRequest_FieldsFilter) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*FetchRequest_FieldsFilter) MarshalToVT 

func (m *FetchRequest_FieldsFilter) MarshalToVT(dAtA []byte) (int, error)

func (*FetchRequest_FieldsFilter) MarshalToVTStrict 

func (m *FetchRequest_FieldsFilter) MarshalToVTStrict(dAtA []byte) (int, error)

func (*FetchRequest_FieldsFilter) MarshalVT 

func (m *FetchRequest_FieldsFilter) MarshalVT() (dAtA []byte, err error)

func (*FetchRequest_FieldsFilter) MarshalVTStrict 

func (m *FetchRequest_FieldsFilter) MarshalVTStrict() (dAtA []byte, err error)

func (*FetchRequest_FieldsFilter) ProtoMessage 

func (*FetchRequest_FieldsFilter) ProtoMessage()

func (*FetchRequest_FieldsFilter) ProtoReflect 

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

func (*FetchRequest_FieldsFilter) Reset 

func (x *FetchRequest_FieldsFilter) Reset()

func (*FetchRequest_FieldsFilter) SizeVT 

func (m *FetchRequest_FieldsFilter) SizeVT() (n int)

func (*FetchRequest_FieldsFilter) String 

func (x *FetchRequest_FieldsFilter) String() string

func (*FetchRequest_FieldsFilter) UnmarshalVT 

func (m *FetchRequest_FieldsFilter) UnmarshalVT(dAtA []byte) error

func (*FetchRequest_FieldsFilter) UnmarshalVTUnsafe 

func (m *FetchRequest_FieldsFilter) UnmarshalVTUnsafe(dAtA []byte) error

type GetAsyncSearchesListRequest added in v0.59.0 

type GetAsyncSearchesListRequest struct {
	Status *AsyncSearchStatus `protobuf:"varint,1,opt,name=status,proto3,enum=api.AsyncSearchStatus,oneof" json:"status,omitempty"`
	Ids    []string           `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAsyncSearchesListRequest) CloneMessageVT added in v0.59.0 

func (m *GetAsyncSearchesListRequest) CloneMessageVT() proto.Message

func (*GetAsyncSearchesListRequest) CloneVT added in v0.59.0 

func (m *GetAsyncSearchesListRequest) CloneVT() *GetAsyncSearchesListRequest

func (*GetAsyncSearchesListRequest) Descriptor deprecated added in v0.59.0 

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

Deprecated: Use GetAsyncSearchesListRequest.ProtoReflect.Descriptor instead.

func (*GetAsyncSearchesListRequest) EqualMessageVT added in v0.59.0 

func (this *GetAsyncSearchesListRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*GetAsyncSearchesListRequest) EqualVT added in v0.59.0 

func (this *GetAsyncSearchesListRequest) EqualVT(that *GetAsyncSearchesListRequest) bool

func (*GetAsyncSearchesListRequest) GetIds added in v0.59.0 

func (x *GetAsyncSearchesListRequest) GetIds() []string

func (*GetAsyncSearchesListRequest) GetStatus added in v0.59.0 

func (x *GetAsyncSearchesListRequest) GetStatus() AsyncSearchStatus

func (*GetAsyncSearchesListRequest) MarshalToSizedBufferVT added in v0.59.0 

func (m *GetAsyncSearchesListRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetAsyncSearchesListRequest) MarshalToSizedBufferVTStrict added in v0.59.0 

func (m *GetAsyncSearchesListRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*GetAsyncSearchesListRequest) MarshalToVT added in v0.59.0 

func (m *GetAsyncSearchesListRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetAsyncSearchesListRequest) MarshalToVTStrict added in v0.59.0 

func (m *GetAsyncSearchesListRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*GetAsyncSearchesListRequest) MarshalVT added in v0.59.0 

func (m *GetAsyncSearchesListRequest) MarshalVT() (dAtA []byte, err error)

func (*GetAsyncSearchesListRequest) MarshalVTStrict added in v0.59.0 

func (m *GetAsyncSearchesListRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*GetAsyncSearchesListRequest) ProtoMessage added in v0.59.0 

func (*GetAsyncSearchesListRequest) ProtoMessage()

func (*GetAsyncSearchesListRequest) ProtoReflect added in v0.59.0 

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

func (*GetAsyncSearchesListRequest) Reset added in v0.59.0 

func (x *GetAsyncSearchesListRequest) Reset()

func (*GetAsyncSearchesListRequest) SizeVT added in v0.59.0 

func (m *GetAsyncSearchesListRequest) SizeVT() (n int)

func (*GetAsyncSearchesListRequest) String added in v0.59.0 

func (x *GetAsyncSearchesListRequest) String() string

func (*GetAsyncSearchesListRequest) UnmarshalVT added in v0.59.0 

func (m *GetAsyncSearchesListRequest) UnmarshalVT(dAtA []byte) error

func (*GetAsyncSearchesListRequest) UnmarshalVTUnsafe added in v0.59.0 

func (m *GetAsyncSearchesListRequest) UnmarshalVTUnsafe(dAtA []byte) error

type GetAsyncSearchesListResponse added in v0.59.0 

type GetAsyncSearchesListResponse struct {
	Searches []*AsyncSearchesListItem `protobuf:"bytes,1,rep,name=searches,proto3" json:"searches,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAsyncSearchesListResponse) CloneMessageVT added in v0.59.0 

func (m *GetAsyncSearchesListResponse) CloneMessageVT() proto.Message

func (*GetAsyncSearchesListResponse) CloneVT added in v0.59.0 

func (m *GetAsyncSearchesListResponse) CloneVT() *GetAsyncSearchesListResponse

func (*GetAsyncSearchesListResponse) Descriptor deprecated added in v0.59.0 

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

Deprecated: Use GetAsyncSearchesListResponse.ProtoReflect.Descriptor instead.

func (*GetAsyncSearchesListResponse) EqualMessageVT added in v0.59.0 

func (this *GetAsyncSearchesListResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*GetAsyncSearchesListResponse) EqualVT added in v0.59.0 

func (this *GetAsyncSearchesListResponse) EqualVT(that *GetAsyncSearchesListResponse) bool

func (*GetAsyncSearchesListResponse) GetSearches added in v0.59.0 

func (x *GetAsyncSearchesListResponse) GetSearches() []*AsyncSearchesListItem

func (*GetAsyncSearchesListResponse) MarshalToSizedBufferVT added in v0.59.0 

func (m *GetAsyncSearchesListResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetAsyncSearchesListResponse) MarshalToSizedBufferVTStrict added in v0.59.0 

func (m *GetAsyncSearchesListResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*GetAsyncSearchesListResponse) MarshalToVT added in v0.59.0 

func (m *GetAsyncSearchesListResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetAsyncSearchesListResponse) MarshalToVTStrict added in v0.59.0 

func (m *GetAsyncSearchesListResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*GetAsyncSearchesListResponse) MarshalVT added in v0.59.0 

func (m *GetAsyncSearchesListResponse) MarshalVT() (dAtA []byte, err error)

func (*GetAsyncSearchesListResponse) MarshalVTStrict added in v0.59.0 

func (m *GetAsyncSearchesListResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*GetAsyncSearchesListResponse) ProtoMessage added in v0.59.0 

func (*GetAsyncSearchesListResponse) ProtoMessage()

func (*GetAsyncSearchesListResponse) ProtoReflect added in v0.59.0 

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

func (*GetAsyncSearchesListResponse) Reset added in v0.59.0 

func (x *GetAsyncSearchesListResponse) Reset()

func (*GetAsyncSearchesListResponse) SizeVT added in v0.59.0 

func (m *GetAsyncSearchesListResponse) SizeVT() (n int)

func (*GetAsyncSearchesListResponse) String added in v0.59.0 

func (x *GetAsyncSearchesListResponse) String() string

func (*GetAsyncSearchesListResponse) UnmarshalVT added in v0.59.0 

func (m *GetAsyncSearchesListResponse) UnmarshalVT(dAtA []byte) error

func (*GetAsyncSearchesListResponse) UnmarshalVTUnsafe added in v0.59.0 

func (m *GetAsyncSearchesListResponse) UnmarshalVTUnsafe(dAtA []byte) error

type IdWithHint 

type IdWithHint struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Hint string `protobuf:"bytes,2,opt,name=hint,proto3" json:"hint,omitempty"`
	// contains filtered or unexported fields
}

func (*IdWithHint) CloneMessageVT 

func (m *IdWithHint) CloneMessageVT() proto.Message

func (*IdWithHint) CloneVT 

func (m *IdWithHint) CloneVT() *IdWithHint

func (*IdWithHint) Descriptor deprecated 

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

Deprecated: Use IdWithHint.ProtoReflect.Descriptor instead.

func (*IdWithHint) EqualMessageVT 

func (this *IdWithHint) EqualMessageVT(thatMsg proto.Message) bool

func (*IdWithHint) EqualVT 

func (this *IdWithHint) EqualVT(that *IdWithHint) bool

func (*IdWithHint) GetHint 

func (x *IdWithHint) GetHint() string

func (*IdWithHint) GetId 

func (x *IdWithHint) GetId() string

func (*IdWithHint) MarshalToSizedBufferVT 

func (m *IdWithHint) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*IdWithHint) MarshalToSizedBufferVTStrict 

func (m *IdWithHint) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*IdWithHint) MarshalToVT 

func (m *IdWithHint) MarshalToVT(dAtA []byte) (int, error)

func (*IdWithHint) MarshalToVTStrict 

func (m *IdWithHint) MarshalToVTStrict(dAtA []byte) (int, error)

func (*IdWithHint) MarshalVT 

func (m *IdWithHint) MarshalVT() (dAtA []byte, err error)

func (*IdWithHint) MarshalVTStrict 

func (m *IdWithHint) MarshalVTStrict() (dAtA []byte, err error)

func (*IdWithHint) ProtoMessage 

func (*IdWithHint) ProtoMessage()

func (*IdWithHint) ProtoReflect 

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

func (*IdWithHint) Reset 

func (x *IdWithHint) Reset()

func (*IdWithHint) SizeVT 

func (m *IdWithHint) SizeVT() (n int)

func (*IdWithHint) String 

func (x *IdWithHint) String() string

func (*IdWithHint) UnmarshalVT 

func (m *IdWithHint) UnmarshalVT(dAtA []byte) error

func (*IdWithHint) UnmarshalVTUnsafe 

func (m *IdWithHint) UnmarshalVTUnsafe(dAtA []byte) error

type Order 

type Order int32
const (
	Order_ORDER_DESC Order = 0
	Order_ORDER_ASC  Order = 1
)

func MustProtoOrder 

func MustProtoOrder(o seq.DocsOrder) Order

func ToProtoOrder 

func ToProtoOrder(o seq.DocsOrder) (Order, error)

func (Order) Descriptor 

func (Order) Descriptor() protoreflect.EnumDescriptor

func (Order) Enum 

func (x Order) Enum() *Order

func (Order) EnumDescriptor deprecated 

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

Deprecated: Use Order.Descriptor instead.

func (Order) MustDocsOrder 

func (o Order) MustDocsOrder() seq.DocsOrder

func (Order) Number 

func (x Order) Number() protoreflect.EnumNumber

func (Order) String 

func (x Order) String() string

func (Order) ToDocsOrder 

func (o Order) ToDocsOrder() (seq.DocsOrder, error)

func (Order) Type 

func (Order) Type() protoreflect.EnumType

type SearchErrorCode 

type SearchErrorCode int32
const (
	SearchErrorCode_NO_ERROR                      SearchErrorCode = 0
	SearchErrorCode_INGESTOR_QUERY_WANTS_OLD_DATA SearchErrorCode = 1
	SearchErrorCode_TOO_MANY_UNIQ_VALUES          SearchErrorCode = 2
	SearchErrorCode_TOO_MANY_FRACTIONS_HIT        SearchErrorCode = 3
)

func (SearchErrorCode) Descriptor 

func (SearchErrorCode) Descriptor() protoreflect.EnumDescriptor

func (SearchErrorCode) Enum 

func (x SearchErrorCode) Enum() *SearchErrorCode

func (SearchErrorCode) EnumDescriptor deprecated 

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

Deprecated: Use SearchErrorCode.Descriptor instead.

func (SearchErrorCode) Number 

func (x SearchErrorCode) Number() protoreflect.EnumNumber

func (SearchErrorCode) String 

func (x SearchErrorCode) String() string

func (SearchErrorCode) Type 

func (SearchErrorCode) Type() protoreflect.EnumType

type SearchRequest 

type SearchRequest struct {
	Query    string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	From     int64  `protobuf:"varint,2,opt,name=from,proto3" json:"from,omitempty"`
	To       int64  `protobuf:"varint,3,opt,name=to,proto3" json:"to,omitempty"`
	Size     int64  `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	Offset   int64  `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
	Interval int64  `protobuf:"varint,6,opt,name=interval,proto3" json:"interval,omitempty"`
	// Deprecated: Marked as deprecated in storeapi/store_api.proto.
	Aggregation string `protobuf:"bytes,7,opt,name=aggregation,proto3" json:"aggregation,omitempty"`
	Explain     bool   `protobuf:"varint,8,opt,name=explain,proto3" json:"explain,omitempty"`
	WithTotal   bool   `protobuf:"varint,10,opt,name=with_total,json=withTotal,proto3" json:"with_total,omitempty"`
	// Deprecated: Marked as deprecated in storeapi/store_api.proto.
	AggregationFilter string      `protobuf:"bytes,11,opt,name=aggregation_filter,json=aggregationFilter,proto3" json:"aggregation_filter,omitempty"`
	Aggs              []*AggQuery `protobuf:"bytes,12,rep,name=aggs,proto3" json:"aggs,omitempty"`
	Order             Order       `protobuf:"varint,13,opt,name=order,proto3,enum=api.Order" json:"order,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchRequest) CloneMessageVT 

func (m *SearchRequest) CloneMessageVT() proto.Message

func (*SearchRequest) CloneVT 

func (m *SearchRequest) CloneVT() *SearchRequest

func (*SearchRequest) Descriptor deprecated 

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

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) EqualMessageVT 

func (this *SearchRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchRequest) EqualVT 

func (this *SearchRequest) EqualVT(that *SearchRequest) bool

func (*SearchRequest) GetAggregation deprecated 

func (x *SearchRequest) GetAggregation() string

Deprecated: Marked as deprecated in storeapi/store_api.proto.

func (*SearchRequest) GetAggregationFilter deprecated 

func (x *SearchRequest) GetAggregationFilter() string

Deprecated: Marked as deprecated in storeapi/store_api.proto.

func (*SearchRequest) GetAggs 

func (x *SearchRequest) GetAggs() []*AggQuery

func (*SearchRequest) GetExplain 

func (x *SearchRequest) GetExplain() bool

func (*SearchRequest) GetFrom 

func (x *SearchRequest) GetFrom() int64

func (*SearchRequest) GetInterval 

func (x *SearchRequest) GetInterval() int64

func (*SearchRequest) GetOffset 

func (x *SearchRequest) GetOffset() int64

func (*SearchRequest) GetOrder 

func (x *SearchRequest) GetOrder() Order

func (*SearchRequest) GetQuery 

func (x *SearchRequest) GetQuery() string

func (*SearchRequest) GetSize 

func (x *SearchRequest) GetSize() int64

func (*SearchRequest) GetTo 

func (x *SearchRequest) GetTo() int64

func (*SearchRequest) GetWithTotal 

func (x *SearchRequest) GetWithTotal() bool

func (*SearchRequest) MarshalToSizedBufferVT 

func (m *SearchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchRequest) MarshalToSizedBufferVTStrict 

func (m *SearchRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchRequest) MarshalToVT 

func (m *SearchRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SearchRequest) MarshalToVTStrict 

func (m *SearchRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchRequest) MarshalVT 

func (m *SearchRequest) MarshalVT() (dAtA []byte, err error)

func (*SearchRequest) MarshalVTStrict 

func (m *SearchRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect 

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

func (*SearchRequest) Reset 

func (x *SearchRequest) Reset()

func (*SearchRequest) SizeVT 

func (m *SearchRequest) SizeVT() (n int)

func (*SearchRequest) String 

func (x *SearchRequest) String() string

func (*SearchRequest) UnmarshalVT 

func (m *SearchRequest) UnmarshalVT(dAtA []byte) error

func (*SearchRequest) UnmarshalVTUnsafe 

func (m *SearchRequest) UnmarshalVTUnsafe(dAtA []byte) error

type SearchResponse 

type SearchResponse struct {

	// Deprecated: Marked as deprecated in storeapi/store_api.proto.
	Data      []byte                       `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	IdSources []*SearchResponse_IdWithHint `protobuf:"bytes,2,rep,name=id_sources,json=idSources,proto3" json:"id_sources,omitempty"`
	Histogram map[uint64]uint64            `` /* 147-byte string literal not displayed */
	Aggs      []*SearchResponse_Agg        `protobuf:"bytes,4,rep,name=aggs,proto3" json:"aggs,omitempty"`
	Total     uint64                       `protobuf:"varint,5,opt,name=total,proto3" json:"total,omitempty"`
	Errors    []string                     `protobuf:"bytes,6,rep,name=errors,proto3" json:"errors,omitempty"`
	Code      SearchErrorCode              `protobuf:"varint,7,opt,name=code,proto3,enum=api.SearchErrorCode" json:"code,omitempty"`
	Explain   *ExplainEntry                `protobuf:"bytes,8,opt,name=explain,proto3,oneof" json:"explain,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchResponse) CloneMessageVT 

func (m *SearchResponse) CloneMessageVT() proto.Message

func (*SearchResponse) CloneVT 

func (m *SearchResponse) CloneVT() *SearchResponse

func (*SearchResponse) Descriptor deprecated 

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

Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.

func (*SearchResponse) EqualMessageVT 

func (this *SearchResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchResponse) EqualVT 

func (this *SearchResponse) EqualVT(that *SearchResponse) bool

func (*SearchResponse) GetAggs 

func (x *SearchResponse) GetAggs() []*SearchResponse_Agg

func (*SearchResponse) GetCode 

func (x *SearchResponse) GetCode() SearchErrorCode

func (*SearchResponse) GetData deprecated 

func (x *SearchResponse) GetData() []byte

Deprecated: Marked as deprecated in storeapi/store_api.proto.

func (*SearchResponse) GetErrors 

func (x *SearchResponse) GetErrors() []string

func (*SearchResponse) GetExplain 

func (x *SearchResponse) GetExplain() *ExplainEntry

func (*SearchResponse) GetHistogram 

func (x *SearchResponse) GetHistogram() map[uint64]uint64

func (*SearchResponse) GetIdSources 

func (x *SearchResponse) GetIdSources() []*SearchResponse_IdWithHint

func (*SearchResponse) GetTotal 

func (x *SearchResponse) GetTotal() uint64

func (*SearchResponse) MarshalToSizedBufferVT 

func (m *SearchResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchResponse) MarshalToSizedBufferVTStrict 

func (m *SearchResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchResponse) MarshalToVT 

func (m *SearchResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SearchResponse) MarshalToVTStrict 

func (m *SearchResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchResponse) MarshalVT 

func (m *SearchResponse) MarshalVT() (dAtA []byte, err error)

func (*SearchResponse) MarshalVTStrict 

func (m *SearchResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) ProtoReflect 

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

func (*SearchResponse) Reset 

func (x *SearchResponse) Reset()

func (*SearchResponse) SizeVT 

func (m *SearchResponse) SizeVT() (n int)

func (*SearchResponse) String 

func (x *SearchResponse) String() string

func (*SearchResponse) UnmarshalVT 

func (m *SearchResponse) UnmarshalVT(dAtA []byte) error

func (*SearchResponse) UnmarshalVTUnsafe 

func (m *SearchResponse) UnmarshalVTUnsafe(dAtA []byte) error

type SearchResponse_Agg 

type SearchResponse_Agg struct {

	// Deprecated: Marked as deprecated in storeapi/store_api.proto.
	Agg          map[string]uint64                    `` /* 134-byte string literal not displayed */
	AggHistogram map[string]*SearchResponse_Histogram `` /* 171-byte string literal not displayed */
	NotExists    int64                                `protobuf:"varint,3,opt,name=not_exists,json=notExists,proto3" json:"not_exists,omitempty"`
	// Timeseries will be presented as:
	// [
	//
	//	{ (foo, ts1) -> (val) },
	//	{ (bar, ts1) -> (val) },
	//	{ (foo, ts2) -> (val) }
	//
	// ]
	Timeseries []*SearchResponse_Bin `protobuf:"bytes,4,rep,name=timeseries,proto3" json:"timeseries,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchResponse_Agg) CloneMessageVT 

func (m *SearchResponse_Agg) CloneMessageVT() proto.Message

func (*SearchResponse_Agg) CloneVT 

func (m *SearchResponse_Agg) CloneVT() *SearchResponse_Agg

func (*SearchResponse_Agg) Descriptor deprecated 

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

Deprecated: Use SearchResponse_Agg.ProtoReflect.Descriptor instead.

func (*SearchResponse_Agg) EqualMessageVT 

func (this *SearchResponse_Agg) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchResponse_Agg) EqualVT 

func (this *SearchResponse_Agg) EqualVT(that *SearchResponse_Agg) bool

func (*SearchResponse_Agg) GetAgg deprecated 

func (x *SearchResponse_Agg) GetAgg() map[string]uint64

Deprecated: Marked as deprecated in storeapi/store_api.proto.

func (*SearchResponse_Agg) GetAggHistogram 

func (x *SearchResponse_Agg) GetAggHistogram() map[string]*SearchResponse_Histogram

func (*SearchResponse_Agg) GetNotExists 

func (x *SearchResponse_Agg) GetNotExists() int64

func (*SearchResponse_Agg) GetTimeseries 

func (x *SearchResponse_Agg) GetTimeseries() []*SearchResponse_Bin

func (*SearchResponse_Agg) MarshalToSizedBufferVT 

func (m *SearchResponse_Agg) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchResponse_Agg) MarshalToSizedBufferVTStrict 

func (m *SearchResponse_Agg) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchResponse_Agg) MarshalToVT 

func (m *SearchResponse_Agg) MarshalToVT(dAtA []byte) (int, error)

func (*SearchResponse_Agg) MarshalToVTStrict 

func (m *SearchResponse_Agg) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchResponse_Agg) MarshalVT 

func (m *SearchResponse_Agg) MarshalVT() (dAtA []byte, err error)

func (*SearchResponse_Agg) MarshalVTStrict 

func (m *SearchResponse_Agg) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchResponse_Agg) ProtoMessage 

func (*SearchResponse_Agg) ProtoMessage()

func (*SearchResponse_Agg) ProtoReflect 

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

func (*SearchResponse_Agg) Reset 

func (x *SearchResponse_Agg) Reset()

func (*SearchResponse_Agg) SizeVT 

func (m *SearchResponse_Agg) SizeVT() (n int)

func (*SearchResponse_Agg) String 

func (x *SearchResponse_Agg) String() string

func (*SearchResponse_Agg) UnmarshalVT 

func (m *SearchResponse_Agg) UnmarshalVT(dAtA []byte) error

func (*SearchResponse_Agg) UnmarshalVTUnsafe 

func (m *SearchResponse_Agg) UnmarshalVTUnsafe(dAtA []byte) error

type SearchResponse_Bin 

type SearchResponse_Bin struct {
	Label string                    `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	Ts    *timestamppb.Timestamp    `protobuf:"bytes,2,opt,name=ts,proto3" json:"ts,omitempty"`
	Hist  *SearchResponse_Histogram `protobuf:"bytes,3,opt,name=hist,proto3" json:"hist,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchResponse_Bin) CloneMessageVT 

func (m *SearchResponse_Bin) CloneMessageVT() proto.Message

func (*SearchResponse_Bin) CloneVT 

func (m *SearchResponse_Bin) CloneVT() *SearchResponse_Bin

func (*SearchResponse_Bin) Descriptor deprecated 

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

Deprecated: Use SearchResponse_Bin.ProtoReflect.Descriptor instead.

func (*SearchResponse_Bin) EqualMessageVT 

func (this *SearchResponse_Bin) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchResponse_Bin) EqualVT 

func (this *SearchResponse_Bin) EqualVT(that *SearchResponse_Bin) bool

func (*SearchResponse_Bin) GetHist 

func (x *SearchResponse_Bin) GetHist() *SearchResponse_Histogram

func (*SearchResponse_Bin) GetLabel 

func (x *SearchResponse_Bin) GetLabel() string

func (*SearchResponse_Bin) GetTs 

func (x *SearchResponse_Bin) GetTs() *timestamppb.Timestamp

func (*SearchResponse_Bin) MarshalToSizedBufferVT 

func (m *SearchResponse_Bin) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchResponse_Bin) MarshalToSizedBufferVTStrict 

func (m *SearchResponse_Bin) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchResponse_Bin) MarshalToVT 

func (m *SearchResponse_Bin) MarshalToVT(dAtA []byte) (int, error)

func (*SearchResponse_Bin) MarshalToVTStrict 

func (m *SearchResponse_Bin) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchResponse_Bin) MarshalVT 

func (m *SearchResponse_Bin) MarshalVT() (dAtA []byte, err error)

func (*SearchResponse_Bin) MarshalVTStrict 

func (m *SearchResponse_Bin) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchResponse_Bin) ProtoMessage 

func (*SearchResponse_Bin) ProtoMessage()

func (*SearchResponse_Bin) ProtoReflect 

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

func (*SearchResponse_Bin) Reset 

func (x *SearchResponse_Bin) Reset()

func (*SearchResponse_Bin) SizeVT 

func (m *SearchResponse_Bin) SizeVT() (n int)

func (*SearchResponse_Bin) String 

func (x *SearchResponse_Bin) String() string

func (*SearchResponse_Bin) UnmarshalVT 

func (m *SearchResponse_Bin) UnmarshalVT(dAtA []byte) error

func (*SearchResponse_Bin) UnmarshalVTUnsafe 

func (m *SearchResponse_Bin) UnmarshalVTUnsafe(dAtA []byte) error

type SearchResponse_Histogram 

type SearchResponse_Histogram struct {
	Min       float64   `protobuf:"fixed64,1,opt,name=min,proto3" json:"min,omitempty"`
	Max       float64   `protobuf:"fixed64,2,opt,name=max,proto3" json:"max,omitempty"`
	Sum       float64   `protobuf:"fixed64,3,opt,name=sum,proto3" json:"sum,omitempty"`
	Total     int64     `protobuf:"varint,4,opt,name=total,proto3" json:"total,omitempty"`
	NotExists int64     `protobuf:"varint,5,opt,name=not_exists,json=notExists,proto3" json:"not_exists,omitempty"`
	Samples   []float64 `protobuf:"fixed64,6,rep,packed,name=samples,proto3" json:"samples,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchResponse_Histogram) CloneMessageVT 

func (m *SearchResponse_Histogram) CloneMessageVT() proto.Message

func (*SearchResponse_Histogram) CloneVT 

func (m *SearchResponse_Histogram) CloneVT() *SearchResponse_Histogram

func (*SearchResponse_Histogram) Descriptor deprecated 

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

Deprecated: Use SearchResponse_Histogram.ProtoReflect.Descriptor instead.

func (*SearchResponse_Histogram) EqualMessageVT 

func (this *SearchResponse_Histogram) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchResponse_Histogram) EqualVT 

func (this *SearchResponse_Histogram) EqualVT(that *SearchResponse_Histogram) bool

func (*SearchResponse_Histogram) GetMax 

func (x *SearchResponse_Histogram) GetMax() float64

func (*SearchResponse_Histogram) GetMin 

func (x *SearchResponse_Histogram) GetMin() float64

func (*SearchResponse_Histogram) GetNotExists 

func (x *SearchResponse_Histogram) GetNotExists() int64

func (*SearchResponse_Histogram) GetSamples 

func (x *SearchResponse_Histogram) GetSamples() []float64

func (*SearchResponse_Histogram) GetSum 

func (x *SearchResponse_Histogram) GetSum() float64

func (*SearchResponse_Histogram) GetTotal 

func (x *SearchResponse_Histogram) GetTotal() int64

func (*SearchResponse_Histogram) MarshalToSizedBufferVT 

func (m *SearchResponse_Histogram) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchResponse_Histogram) MarshalToSizedBufferVTStrict 

func (m *SearchResponse_Histogram) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchResponse_Histogram) MarshalToVT 

func (m *SearchResponse_Histogram) MarshalToVT(dAtA []byte) (int, error)

func (*SearchResponse_Histogram) MarshalToVTStrict 

func (m *SearchResponse_Histogram) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchResponse_Histogram) MarshalVT 

func (m *SearchResponse_Histogram) MarshalVT() (dAtA []byte, err error)

func (*SearchResponse_Histogram) MarshalVTStrict 

func (m *SearchResponse_Histogram) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchResponse_Histogram) ProtoMessage 

func (*SearchResponse_Histogram) ProtoMessage()

func (*SearchResponse_Histogram) ProtoReflect 

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

func (*SearchResponse_Histogram) Reset 

func (x *SearchResponse_Histogram) Reset()

func (*SearchResponse_Histogram) SizeVT 

func (m *SearchResponse_Histogram) SizeVT() (n int)

func (*SearchResponse_Histogram) String 

func (x *SearchResponse_Histogram) String() string

func (*SearchResponse_Histogram) UnmarshalVT 

func (m *SearchResponse_Histogram) UnmarshalVT(dAtA []byte) error

func (*SearchResponse_Histogram) UnmarshalVTUnsafe 

func (m *SearchResponse_Histogram) UnmarshalVTUnsafe(dAtA []byte) error

type SearchResponse_Id 

type SearchResponse_Id struct {
	Mid uint64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"`
	Rid uint64 `protobuf:"varint,2,opt,name=rid,proto3" json:"rid,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchResponse_Id) CloneMessageVT 

func (m *SearchResponse_Id) CloneMessageVT() proto.Message

func (*SearchResponse_Id) CloneVT 

func (m *SearchResponse_Id) CloneVT() *SearchResponse_Id

func (*SearchResponse_Id) Descriptor deprecated 

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

Deprecated: Use SearchResponse_Id.ProtoReflect.Descriptor instead.

func (*SearchResponse_Id) EqualMessageVT 

func (this *SearchResponse_Id) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchResponse_Id) EqualVT 

func (this *SearchResponse_Id) EqualVT(that *SearchResponse_Id) bool

func (*SearchResponse_Id) GetMid 

func (x *SearchResponse_Id) GetMid() uint64

func (*SearchResponse_Id) GetRid 

func (x *SearchResponse_Id) GetRid() uint64

func (*SearchResponse_Id) MarshalToSizedBufferVT 

func (m *SearchResponse_Id) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchResponse_Id) MarshalToSizedBufferVTStrict 

func (m *SearchResponse_Id) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchResponse_Id) MarshalToVT 

func (m *SearchResponse_Id) MarshalToVT(dAtA []byte) (int, error)

func (*SearchResponse_Id) MarshalToVTStrict 

func (m *SearchResponse_Id) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchResponse_Id) MarshalVT 

func (m *SearchResponse_Id) MarshalVT() (dAtA []byte, err error)

func (*SearchResponse_Id) MarshalVTStrict 

func (m *SearchResponse_Id) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchResponse_Id) ProtoMessage 

func (*SearchResponse_Id) ProtoMessage()

func (*SearchResponse_Id) ProtoReflect 

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

func (*SearchResponse_Id) Reset 

func (x *SearchResponse_Id) Reset()

func (*SearchResponse_Id) SizeVT 

func (m *SearchResponse_Id) SizeVT() (n int)

func (*SearchResponse_Id) String 

func (x *SearchResponse_Id) String() string

func (*SearchResponse_Id) UnmarshalVT 

func (m *SearchResponse_Id) UnmarshalVT(dAtA []byte) error

func (*SearchResponse_Id) UnmarshalVTUnsafe 

func (m *SearchResponse_Id) UnmarshalVTUnsafe(dAtA []byte) error

type SearchResponse_IdWithHint 

type SearchResponse_IdWithHint struct {
	Id   *SearchResponse_Id `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Hint string             `protobuf:"bytes,3,opt,name=hint,proto3" json:"hint,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchResponse_IdWithHint) CloneMessageVT 

func (m *SearchResponse_IdWithHint) CloneMessageVT() proto.Message

func (*SearchResponse_IdWithHint) CloneVT 

func (m *SearchResponse_IdWithHint) CloneVT() *SearchResponse_IdWithHint

func (*SearchResponse_IdWithHint) Descriptor deprecated 

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

Deprecated: Use SearchResponse_IdWithHint.ProtoReflect.Descriptor instead.

func (*SearchResponse_IdWithHint) EqualMessageVT 

func (this *SearchResponse_IdWithHint) EqualMessageVT(thatMsg proto.Message) bool

func (*SearchResponse_IdWithHint) EqualVT 

func (this *SearchResponse_IdWithHint) EqualVT(that *SearchResponse_IdWithHint) bool

func (*SearchResponse_IdWithHint) GetHint 

func (x *SearchResponse_IdWithHint) GetHint() string

func (*SearchResponse_IdWithHint) GetId 

func (x *SearchResponse_IdWithHint) GetId() *SearchResponse_Id

func (*SearchResponse_IdWithHint) MarshalToSizedBufferVT 

func (m *SearchResponse_IdWithHint) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SearchResponse_IdWithHint) MarshalToSizedBufferVTStrict 

func (m *SearchResponse_IdWithHint) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*SearchResponse_IdWithHint) MarshalToVT 

func (m *SearchResponse_IdWithHint) MarshalToVT(dAtA []byte) (int, error)

func (*SearchResponse_IdWithHint) MarshalToVTStrict 

func (m *SearchResponse_IdWithHint) MarshalToVTStrict(dAtA []byte) (int, error)

func (*SearchResponse_IdWithHint) MarshalVT 

func (m *SearchResponse_IdWithHint) MarshalVT() (dAtA []byte, err error)

func (*SearchResponse_IdWithHint) MarshalVTStrict 

func (m *SearchResponse_IdWithHint) MarshalVTStrict() (dAtA []byte, err error)

func (*SearchResponse_IdWithHint) ProtoMessage 

func (*SearchResponse_IdWithHint) ProtoMessage()

func (*SearchResponse_IdWithHint) ProtoReflect 

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

func (*SearchResponse_IdWithHint) Reset 

func (x *SearchResponse_IdWithHint) Reset()

func (*SearchResponse_IdWithHint) SizeVT 

func (m *SearchResponse_IdWithHint) SizeVT() (n int)

func (*SearchResponse_IdWithHint) String 

func (x *SearchResponse_IdWithHint) String() string

func (*SearchResponse_IdWithHint) UnmarshalVT 

func (m *SearchResponse_IdWithHint) UnmarshalVT(dAtA []byte) error

func (*SearchResponse_IdWithHint) UnmarshalVTUnsafe 

func (m *SearchResponse_IdWithHint) UnmarshalVTUnsafe(dAtA []byte) error

type StartAsyncSearchRequest 

type StartAsyncSearchRequest struct {
	SearchId          string               `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"`
	Retention         *durationpb.Duration `protobuf:"bytes,2,opt,name=retention,proto3" json:"retention,omitempty"`
	Query             string               `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	From              int64                `protobuf:"varint,4,opt,name=from,proto3" json:"from,omitempty"`
	To                int64                `protobuf:"varint,5,opt,name=to,proto3" json:"to,omitempty"`
	Aggs              []*AggQuery          `protobuf:"bytes,6,rep,name=aggs,proto3" json:"aggs,omitempty"`
	HistogramInterval int64                `protobuf:"varint,7,opt,name=histogram_interval,json=histogramInterval,proto3" json:"histogram_interval,omitempty"`
	WithDocs          bool                 `protobuf:"varint,8,opt,name=with_docs,json=withDocs,proto3" json:"with_docs,omitempty"`
	Size              int64                `protobuf:"varint,9,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*StartAsyncSearchRequest) CloneMessageVT 

func (m *StartAsyncSearchRequest) CloneMessageVT() proto.Message

func (*StartAsyncSearchRequest) CloneVT 

func (m *StartAsyncSearchRequest) CloneVT() *StartAsyncSearchRequest

func (*StartAsyncSearchRequest) Descriptor deprecated 

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

Deprecated: Use StartAsyncSearchRequest.ProtoReflect.Descriptor instead.

func (*StartAsyncSearchRequest) EqualMessageVT 

func (this *StartAsyncSearchRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*StartAsyncSearchRequest) EqualVT 

func (this *StartAsyncSearchRequest) EqualVT(that *StartAsyncSearchRequest) bool

func (*StartAsyncSearchRequest) GetAggs 

func (x *StartAsyncSearchRequest) GetAggs() []*AggQuery

func (*StartAsyncSearchRequest) GetFrom 

func (x *StartAsyncSearchRequest) GetFrom() int64

func (*StartAsyncSearchRequest) GetHistogramInterval 

func (x *StartAsyncSearchRequest) GetHistogramInterval() int64

func (*StartAsyncSearchRequest) GetQuery 

func (x *StartAsyncSearchRequest) GetQuery() string

func (*StartAsyncSearchRequest) GetRetention added in v0.59.0 

func (x *StartAsyncSearchRequest) GetRetention() *durationpb.Duration

func (*StartAsyncSearchRequest) GetSearchId 

func (x *StartAsyncSearchRequest) GetSearchId() string

func (*StartAsyncSearchRequest) GetSize added in v0.61.2 

func (x *StartAsyncSearchRequest) GetSize() int64

func (*StartAsyncSearchRequest) GetTo 

func (x *StartAsyncSearchRequest) GetTo() int64

func (*StartAsyncSearchRequest) GetWithDocs added in v0.59.0 

func (x *StartAsyncSearchRequest) GetWithDocs() bool

func (*StartAsyncSearchRequest) MarshalToSizedBufferVT 

func (m *StartAsyncSearchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StartAsyncSearchRequest) MarshalToSizedBufferVTStrict 

func (m *StartAsyncSearchRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*StartAsyncSearchRequest) MarshalToVT 

func (m *StartAsyncSearchRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StartAsyncSearchRequest) MarshalToVTStrict 

func (m *StartAsyncSearchRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*StartAsyncSearchRequest) MarshalVT 

func (m *StartAsyncSearchRequest) MarshalVT() (dAtA []byte, err error)

func (*StartAsyncSearchRequest) MarshalVTStrict 

func (m *StartAsyncSearchRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*StartAsyncSearchRequest) ProtoMessage 

func (*StartAsyncSearchRequest) ProtoMessage()

func (*StartAsyncSearchRequest) ProtoReflect 

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

func (*StartAsyncSearchRequest) Reset 

func (x *StartAsyncSearchRequest) Reset()

func (*StartAsyncSearchRequest) SizeVT 

func (m *StartAsyncSearchRequest) SizeVT() (n int)

func (*StartAsyncSearchRequest) String 

func (x *StartAsyncSearchRequest) String() string

func (*StartAsyncSearchRequest) UnmarshalVT 

func (m *StartAsyncSearchRequest) UnmarshalVT(dAtA []byte) error

func (*StartAsyncSearchRequest) UnmarshalVTUnsafe 

func (m *StartAsyncSearchRequest) UnmarshalVTUnsafe(dAtA []byte) error

type StartAsyncSearchResponse 

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

func (*StartAsyncSearchResponse) CloneMessageVT 

func (m *StartAsyncSearchResponse) CloneMessageVT() proto.Message

func (*StartAsyncSearchResponse) CloneVT 

func (m *StartAsyncSearchResponse) CloneVT() *StartAsyncSearchResponse

func (*StartAsyncSearchResponse) Descriptor deprecated 

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

Deprecated: Use StartAsyncSearchResponse.ProtoReflect.Descriptor instead.

func (*StartAsyncSearchResponse) EqualMessageVT 

func (this *StartAsyncSearchResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*StartAsyncSearchResponse) EqualVT 

func (this *StartAsyncSearchResponse) EqualVT(that *StartAsyncSearchResponse) bool

func (*StartAsyncSearchResponse) MarshalToSizedBufferVT 

func (m *StartAsyncSearchResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StartAsyncSearchResponse) MarshalToSizedBufferVTStrict 

func (m *StartAsyncSearchResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*StartAsyncSearchResponse) MarshalToVT 

func (m *StartAsyncSearchResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StartAsyncSearchResponse) MarshalToVTStrict 

func (m *StartAsyncSearchResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*StartAsyncSearchResponse) MarshalVT 

func (m *StartAsyncSearchResponse) MarshalVT() (dAtA []byte, err error)

func (*StartAsyncSearchResponse) MarshalVTStrict 

func (m *StartAsyncSearchResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*StartAsyncSearchResponse) ProtoMessage 

func (*StartAsyncSearchResponse) ProtoMessage()

func (*StartAsyncSearchResponse) ProtoReflect 

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

func (*StartAsyncSearchResponse) Reset 

func (x *StartAsyncSearchResponse) Reset()

func (*StartAsyncSearchResponse) SizeVT 

func (m *StartAsyncSearchResponse) SizeVT() (n int)

func (*StartAsyncSearchResponse) String 

func (x *StartAsyncSearchResponse) String() string

func (*StartAsyncSearchResponse) UnmarshalVT 

func (m *StartAsyncSearchResponse) UnmarshalVT(dAtA []byte) error

func (*StartAsyncSearchResponse) UnmarshalVTUnsafe 

func (m *StartAsyncSearchResponse) UnmarshalVTUnsafe(dAtA []byte) error

type StatusRequest 

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

func (*StatusRequest) CloneMessageVT 

func (m *StatusRequest) CloneMessageVT() proto.Message

func (*StatusRequest) CloneVT 

func (m *StatusRequest) CloneVT() *StatusRequest

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) EqualMessageVT 

func (this *StatusRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*StatusRequest) EqualVT 

func (this *StatusRequest) EqualVT(that *StatusRequest) bool

func (*StatusRequest) MarshalToSizedBufferVT 

func (m *StatusRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StatusRequest) MarshalToSizedBufferVTStrict 

func (m *StatusRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*StatusRequest) MarshalToVT 

func (m *StatusRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StatusRequest) MarshalToVTStrict 

func (m *StatusRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*StatusRequest) MarshalVT 

func (m *StatusRequest) MarshalVT() (dAtA []byte, err error)

func (*StatusRequest) MarshalVTStrict 

func (m *StatusRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

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

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) SizeVT 

func (m *StatusRequest) SizeVT() (n int)

func (*StatusRequest) String 

func (x *StatusRequest) String() string

func (*StatusRequest) UnmarshalVT 

func (m *StatusRequest) UnmarshalVT(dAtA []byte) error

func (*StatusRequest) UnmarshalVTUnsafe 

func (m *StatusRequest) UnmarshalVTUnsafe(dAtA []byte) error

type StatusResponse 

type StatusResponse struct {
	OldestTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=oldest_time,json=oldestTime,proto3" json:"oldest_time,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse) CloneMessageVT 

func (m *StatusResponse) CloneMessageVT() proto.Message

func (*StatusResponse) CloneVT 

func (m *StatusResponse) CloneVT() *StatusResponse

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) EqualMessageVT 

func (this *StatusResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*StatusResponse) EqualVT 

func (this *StatusResponse) EqualVT(that *StatusResponse) bool

func (*StatusResponse) GetOldestTime 

func (x *StatusResponse) GetOldestTime() *timestamppb.Timestamp

func (*StatusResponse) MarshalToSizedBufferVT 

func (m *StatusResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StatusResponse) MarshalToSizedBufferVTStrict 

func (m *StatusResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*StatusResponse) MarshalToVT 

func (m *StatusResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StatusResponse) MarshalToVTStrict 

func (m *StatusResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*StatusResponse) MarshalVT 

func (m *StatusResponse) MarshalVT() (dAtA []byte, err error)

func (*StatusResponse) MarshalVTStrict 

func (m *StatusResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) SizeVT 

func (m *StatusResponse) SizeVT() (n int)

func (*StatusResponse) String 

func (x *StatusResponse) String() string

func (*StatusResponse) UnmarshalVT 

func (m *StatusResponse) UnmarshalVT(dAtA []byte) error

func (*StatusResponse) UnmarshalVTUnsafe 

func (m *StatusResponse) UnmarshalVTUnsafe(dAtA []byte) error

type StoreApiClient 

type StoreApiClient interface {
	Bulk(ctx context.Context, in *BulkRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
	StartAsyncSearch(ctx context.Context, in *StartAsyncSearchRequest, opts ...grpc.CallOption) (*StartAsyncSearchResponse, error)
	FetchAsyncSearchResult(ctx context.Context, in *FetchAsyncSearchResultRequest, opts ...grpc.CallOption) (*FetchAsyncSearchResultResponse, error)
	CancelAsyncSearch(ctx context.Context, in *CancelAsyncSearchRequest, opts ...grpc.CallOption) (*CancelAsyncSearchResponse, error)
	DeleteAsyncSearch(ctx context.Context, in *DeleteAsyncSearchRequest, opts ...grpc.CallOption) (*DeleteAsyncSearchResponse, error)
	GetAsyncSearchesList(ctx context.Context, in *GetAsyncSearchesListRequest, opts ...grpc.CallOption) (*GetAsyncSearchesListResponse, error)
	Fetch(ctx context.Context, in *FetchRequest, opts ...grpc.CallOption) (StoreApi_FetchClient, error)
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

StoreApiClient is the client API for StoreApi service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStoreApiClient 

func NewStoreApiClient(cc grpc.ClientConnInterface) StoreApiClient

type StoreApiServer 

type StoreApiServer interface {
	Bulk(context.Context, *BulkRequest) (*emptypb.Empty, error)
	Search(context.Context, *SearchRequest) (*SearchResponse, error)
	StartAsyncSearch(context.Context, *StartAsyncSearchRequest) (*StartAsyncSearchResponse, error)
	FetchAsyncSearchResult(context.Context, *FetchAsyncSearchResultRequest) (*FetchAsyncSearchResultResponse, error)
	CancelAsyncSearch(context.Context, *CancelAsyncSearchRequest) (*CancelAsyncSearchResponse, error)
	DeleteAsyncSearch(context.Context, *DeleteAsyncSearchRequest) (*DeleteAsyncSearchResponse, error)
	GetAsyncSearchesList(context.Context, *GetAsyncSearchesListRequest) (*GetAsyncSearchesListResponse, error)
	Fetch(*FetchRequest, StoreApi_FetchServer) error
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	// contains filtered or unexported methods
}

StoreApiServer is the server API for StoreApi service. All implementations must embed UnimplementedStoreApiServer for forward compatibility

type StoreApi_FetchClient 

type StoreApi_FetchClient interface {
	Recv() (*BinaryData, error)
	grpc.ClientStream
}

type StoreApi_FetchServer 

type StoreApi_FetchServer interface {
	Send(*BinaryData) error
	grpc.ServerStream
}

type UnimplementedStoreApiServer 

type UnimplementedStoreApiServer struct {
}

UnimplementedStoreApiServer must be embedded to have forward compatible implementations.

func (UnimplementedStoreApiServer) Bulk 

func (UnimplementedStoreApiServer) Bulk(context.Context, *BulkRequest) (*emptypb.Empty, error)

func (UnimplementedStoreApiServer) CancelAsyncSearch added in v0.59.0 

func (UnimplementedStoreApiServer) CancelAsyncSearch(context.Context, *CancelAsyncSearchRequest) (*CancelAsyncSearchResponse, error)

func (UnimplementedStoreApiServer) DeleteAsyncSearch added in v0.59.0 

func (UnimplementedStoreApiServer) DeleteAsyncSearch(context.Context, *DeleteAsyncSearchRequest) (*DeleteAsyncSearchResponse, error)

func (UnimplementedStoreApiServer) Fetch 

func (UnimplementedStoreApiServer) Fetch(*FetchRequest, StoreApi_FetchServer) error

func (UnimplementedStoreApiServer) FetchAsyncSearchResult 

func (UnimplementedStoreApiServer) FetchAsyncSearchResult(context.Context, *FetchAsyncSearchResultRequest) (*FetchAsyncSearchResultResponse, error)

func (UnimplementedStoreApiServer) GetAsyncSearchesList added in v0.59.0 

func (UnimplementedStoreApiServer) GetAsyncSearchesList(context.Context, *GetAsyncSearchesListRequest) (*GetAsyncSearchesListResponse, error)

func (UnimplementedStoreApiServer) Search 

func (UnimplementedStoreApiServer) Search(context.Context, *SearchRequest) (*SearchResponse, error)

func (UnimplementedStoreApiServer) StartAsyncSearch 

func (UnimplementedStoreApiServer) StartAsyncSearch(context.Context, *StartAsyncSearchRequest) (*StartAsyncSearchResponse, error)

func (UnimplementedStoreApiServer) Status 

func (UnimplementedStoreApiServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

type UnsafeStoreApiServer 

type UnsafeStoreApiServer interface {
	// contains filtered or unexported methods
}

UnsafeStoreApiServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StoreApiServer will result in compilation errors.

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.