seqproxyapi

package
v0.64.1 Latest Latest
Warning

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

 Go to latest Published: Dec 25, 2025 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Overview

Package seqproxyapi is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrorCode_name = map[int32]string{
		0: "ERROR_CODE_UNSPECIFIED",
		1: "ERROR_CODE_NO",
		2: "ERROR_CODE_PARTIAL_RESPONSE",
		3: "ERROR_CODE_TOO_MANY_FRACTIONS_HIT",
	}
	ErrorCode_value = map[string]int32{
		"ERROR_CODE_UNSPECIFIED":            0,
		"ERROR_CODE_NO":                     1,
		"ERROR_CODE_PARTIAL_RESPONSE":       2,
		"ERROR_CODE_TOO_MANY_FRACTIONS_HIT": 3,
	}
)

Enum value maps for ErrorCode.

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 (
	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_seqproxyapi_v1_seq_proxy_api_proto protoreflect.FileDescriptor
View Source 
var SeqProxyApi_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "seqproxyapi.v1.SeqProxyApi",
	HandlerType: (*SeqProxyApiServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Search",
			Handler:    _SeqProxyApi_Search_Handler,
		},
		{
			MethodName: "ComplexSearch",
			Handler:    _SeqProxyApi_ComplexSearch_Handler,
		},
		{
			MethodName: "GetAggregation",
			Handler:    _SeqProxyApi_GetAggregation_Handler,
		},
		{
			MethodName: "GetHistogram",
			Handler:    _SeqProxyApi_GetHistogram_Handler,
		},
		{
			MethodName: "Mapping",
			Handler:    _SeqProxyApi_Mapping_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _SeqProxyApi_Status_Handler,
		},
		{
			MethodName: "StartAsyncSearch",
			Handler:    _SeqProxyApi_StartAsyncSearch_Handler,
		},
		{
			MethodName: "FetchAsyncSearchResult",
			Handler:    _SeqProxyApi_FetchAsyncSearchResult_Handler,
		},
		{
			MethodName: "CancelAsyncSearch",
			Handler:    _SeqProxyApi_CancelAsyncSearch_Handler,
		},
		{
			MethodName: "DeleteAsyncSearch",
			Handler:    _SeqProxyApi_DeleteAsyncSearch_Handler,
		},
		{
			MethodName: "GetAsyncSearchesList",
			Handler:    _SeqProxyApi_GetAsyncSearchesList_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Fetch",
			Handler:       _SeqProxyApi_Fetch_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Export",
			Handler:       _SeqProxyApi_Export_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "seqproxyapi/v1/seq_proxy_api.proto",
}

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

Functions

func RegisterSeqProxyApiHandler 

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

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

func RegisterSeqProxyApiHandlerClient 

func RegisterSeqProxyApiHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SeqProxyApiClient) error

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

func RegisterSeqProxyApiHandlerFromEndpoint 

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

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

func RegisterSeqProxyApiHandlerServer 

func RegisterSeqProxyApiHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SeqProxyApiServer) error

RegisterSeqProxyApiHandlerServer registers the http handlers for service SeqProxyApi to "mux". UnaryRPC :call SeqProxyApiServer 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 RegisterSeqProxyApiHandlerFromEndpoint 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 RegisterSeqProxyApiServer 

func RegisterSeqProxyApiServer(s grpc.ServiceRegistrar, srv SeqProxyApiServer)

Types

type AggFunc 

type AggFunc int32

Aggregation function used in request. 

const (
	AggFunc_AGG_FUNC_COUNT    AggFunc = 0 // Returns how many times `field` was equal to particular value.
	AggFunc_AGG_FUNC_SUM      AggFunc = 1 // Performs an addition operation on `field`, among documents with same `group_by` field.
	AggFunc_AGG_FUNC_MIN      AggFunc = 2 // Finds minimum value for `field`, among documents with same `group_by` field.
	AggFunc_AGG_FUNC_MAX      AggFunc = 3 // Finds maximum value for `field`, among documents with same `group_by` field.
	AggFunc_AGG_FUNC_AVG      AggFunc = 4 // Finds average value for `field`, among documents with same `group_by` field.
	AggFunc_AGG_FUNC_QUANTILE AggFunc = 5 // Finds quantiles for `field`, among documents with same `group_by` field.
	AggFunc_AGG_FUNC_UNIQUE   AggFunc = 6 // Finds unique values for `group_by` field.
)

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"`                            // Field over which aggregation function is used on.
	GroupBy   string    `protobuf:"bytes,3,opt,name=group_by,json=groupBy,proto3" json:"group_by,omitempty"`         // Field over which to create group for further aggregation.
	Func      AggFunc   `protobuf:"varint,4,opt,name=func,proto3,enum=seqproxyapi.v1.AggFunc" json:"func,omitempty"` // Function to apply on aggregated field.
	Quantiles []float64 `protobuf:"fixed64,5,rep,packed,name=quantiles,proto3" json:"quantiles,omitempty"`           // Field used only for `AGG_FUNC_QUANTILE`. Represents list of quantiles to calculate.
	Interval  *string   `protobuf:"bytes,6,opt,name=interval,proto3,oneof" json:"interval,omitempty"`                // Field used only for time series.
	// contains filtered or unexported fields
}

Aggregation query. Generally uses `field` and `group_by`, for details, refer to AggFunc definition.

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() string

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 Aggregation 

type Aggregation struct {
	Buckets   []*Aggregation_Bucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`                       // List of aggregations for given request.
	NotExists int64                 `protobuf:"varint,2,opt,name=not_exists,json=notExists,proto3" json:"not_exists,omitempty"` // Number of documents in which such field does not exist
	// contains filtered or unexported fields
}

Aggregation response.

func (*Aggregation) CloneMessageVT 

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

func (*Aggregation) CloneVT 

func (m *Aggregation) CloneVT() *Aggregation

func (*Aggregation) Descriptor deprecated 

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

Deprecated: Use Aggregation.ProtoReflect.Descriptor instead.

func (*Aggregation) EqualMessageVT 

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

func (*Aggregation) EqualVT 

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

func (*Aggregation) GetBuckets 

func (x *Aggregation) GetBuckets() []*Aggregation_Bucket

func (*Aggregation) GetNotExists 

func (x *Aggregation) GetNotExists() int64

func (*Aggregation) MarshalToSizedBufferVT 

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

func (*Aggregation) MarshalToSizedBufferVTStrict 

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

func (*Aggregation) MarshalToVT 

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

func (*Aggregation) MarshalToVTStrict 

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

func (*Aggregation) MarshalVT 

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

func (*Aggregation) MarshalVTStrict 

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

func (*Aggregation) ProtoMessage 

func (*Aggregation) ProtoMessage()

func (*Aggregation) ProtoReflect 

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

func (*Aggregation) Reset 

func (x *Aggregation) Reset()

func (*Aggregation) SizeVT 

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

func (*Aggregation) String 

func (x *Aggregation) String() string

func (*Aggregation) UnmarshalVT 

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

func (*Aggregation) UnmarshalVTUnsafe 

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

type Aggregation_Bucket 

type Aggregation_Bucket struct {
	Key       string                 `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`                               // Field name.
	Value     float64                `protobuf:"fixed64,3,opt,name=value,proto3" json:"value,omitempty"`                         // Calculated aggregation value.
	NotExists int64                  `protobuf:"varint,4,opt,name=not_exists,json=notExists,proto3" json:"not_exists,omitempty"` // Number of documents without presence of that field.
	Quantiles []float64              `protobuf:"fixed64,5,rep,packed,name=quantiles,proto3" json:"quantiles,omitempty"`          // Value of quantiles for given request. Returned when quantiles aggregation func used.
	Ts        *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=ts,proto3,oneof" json:"ts,omitempty"`                           // Will be used to determine bin of time series.
	// contains filtered or unexported fields
}

Key-value pair containing result of single aggregation.

func (*Aggregation_Bucket) CloneMessageVT 

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

func (*Aggregation_Bucket) CloneVT 

func (m *Aggregation_Bucket) CloneVT() *Aggregation_Bucket

func (*Aggregation_Bucket) Descriptor deprecated 

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

Deprecated: Use Aggregation_Bucket.ProtoReflect.Descriptor instead.

func (*Aggregation_Bucket) EqualMessageVT 

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

func (*Aggregation_Bucket) EqualVT 

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

func (*Aggregation_Bucket) GetKey 

func (x *Aggregation_Bucket) GetKey() string

func (*Aggregation_Bucket) GetNotExists 

func (x *Aggregation_Bucket) GetNotExists() int64

func (*Aggregation_Bucket) GetQuantiles 

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

func (*Aggregation_Bucket) GetTs 

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

func (*Aggregation_Bucket) GetValue 

func (x *Aggregation_Bucket) GetValue() float64

func (*Aggregation_Bucket) MarshalJSON 

func (b *Aggregation_Bucket) MarshalJSON() ([]byte, error)

MarshalJSON overrides "value" field to encode math.NaN and math.Inf as string.

func (*Aggregation_Bucket) MarshalToSizedBufferVT 

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

func (*Aggregation_Bucket) MarshalToSizedBufferVTStrict 

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

func (*Aggregation_Bucket) MarshalToVT 

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

func (*Aggregation_Bucket) MarshalToVTStrict 

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

func (*Aggregation_Bucket) MarshalVT 

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

func (*Aggregation_Bucket) MarshalVTStrict 

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

func (*Aggregation_Bucket) ProtoMessage 

func (*Aggregation_Bucket) ProtoMessage()

func (*Aggregation_Bucket) ProtoReflect 

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

func (*Aggregation_Bucket) Reset 

func (x *Aggregation_Bucket) Reset()

func (*Aggregation_Bucket) SizeVT 

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

func (*Aggregation_Bucket) String 

func (x *Aggregation_Bucket) String() string

func (*Aggregation_Bucket) UnmarshalJSON 

func (b *Aggregation_Bucket) UnmarshalJSON(data []byte) error

func (*Aggregation_Bucket) UnmarshalVT 

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

func (*Aggregation_Bucket) UnmarshalVTUnsafe 

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

type AsyncSearchStatus added in v0.59.0 

type AsyncSearchStatus int32
const (
	// The asynchronous search is still in progress.
	// See the 'progress' field for completion percentage.
	AsyncSearchStatus_AsyncSearchStatusInProgress AsyncSearchStatus = 0
	// The asynchronous search completed successfully.
	AsyncSearchStatus_AsyncSearchStatusDone AsyncSearchStatus = 1
	// The asynchronous search was canceled, possibly via the CancelAsyncSearch handler.
	AsyncSearchStatus_AsyncSearchStatusCanceled AsyncSearchStatus = 2
	// The asynchronous search encountered errors in some shards.
	// See ComplexSearchResponse.Error for details.
	AsyncSearchStatus_AsyncSearchStatusError AsyncSearchStatus = 3
)

func AsyncSearchStatusFromString added in v0.59.0 

func AsyncSearchStatusFromString(s string) (AsyncSearchStatus, error)

func MustProtoAsyncSearchStatus added in v0.59.0 

func MustProtoAsyncSearchStatus(s asyncsearcher.AsyncSearchStatus) AsyncSearchStatus

func ToProtoAsyncSearchStatus added in v0.59.0 

func ToProtoAsyncSearchStatus(s asyncsearcher.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() asyncsearcher.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() (asyncsearcher.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=seqproxyapi.v1.AsyncSearchStatus" json:"status,omitempty"`
	Request    *StartAsyncSearchRequest `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"`
	StartedAt  *timestamppb.Timestamp   `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	ExpiresAt  *timestamppb.Timestamp   `protobuf:"bytes,5,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	CanceledAt *timestamppb.Timestamp   `protobuf:"bytes,6,opt,name=canceled_at,json=canceledAt,proto3,oneof" json:"canceled_at,omitempty"`
	// Search progress in range [0, 1].
	Progress float64 `protobuf:"fixed64,7,opt,name=progress,proto3" json:"progress,omitempty"`
	// The size of data stored on disk, in bytes.
	DiskUsage uint64  `protobuf:"varint,8,opt,name=disk_usage,json=diskUsage,proto3" json:"disk_usage,omitempty"`
	Error     *string `protobuf:"bytes,9,opt,name=error,proto3,oneof" json:"error,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) 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) GetError added in v0.62.5 

func (x *AsyncSearchesListItem) GetError() string

func (*AsyncSearchesListItem) GetExpiresAt added in v0.59.0 

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

func (*AsyncSearchesListItem) GetProgress added in v0.59.0 

func (x *AsyncSearchesListItem) GetProgress() float64

func (*AsyncSearchesListItem) GetRequest added in v0.59.0 

func (x *AsyncSearchesListItem) GetRequest() *StartAsyncSearchRequest

func (*AsyncSearchesListItem) GetSearchId added in v0.59.0 

func (x *AsyncSearchesListItem) GetSearchId() string

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) MarshalJSON added in v0.59.0 

func (i *AsyncSearchesListItem) MarshalJSON() ([]byte, error)

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 CancelAsyncSearchRequest 

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 

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

func (*CancelAsyncSearchRequest) CloneVT 

func (m *CancelAsyncSearchRequest) CloneVT() *CancelAsyncSearchRequest

func (*CancelAsyncSearchRequest) Descriptor deprecated 

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

Deprecated: Use CancelAsyncSearchRequest.ProtoReflect.Descriptor instead.

func (*CancelAsyncSearchRequest) EqualMessageVT 

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

func (*CancelAsyncSearchRequest) EqualVT 

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

func (*CancelAsyncSearchRequest) GetSearchId 

func (x *CancelAsyncSearchRequest) GetSearchId() string

func (*CancelAsyncSearchRequest) MarshalToSizedBufferVT 

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

func (*CancelAsyncSearchRequest) MarshalToSizedBufferVTStrict 

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

func (*CancelAsyncSearchRequest) MarshalToVT 

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

func (*CancelAsyncSearchRequest) MarshalToVTStrict 

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

func (*CancelAsyncSearchRequest) MarshalVT 

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

func (*CancelAsyncSearchRequest) MarshalVTStrict 

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

func (*CancelAsyncSearchRequest) ProtoMessage 

func (*CancelAsyncSearchRequest) ProtoMessage()

func (*CancelAsyncSearchRequest) ProtoReflect 

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

func (*CancelAsyncSearchRequest) Reset 

func (x *CancelAsyncSearchRequest) Reset()

func (*CancelAsyncSearchRequest) SizeVT 

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

func (*CancelAsyncSearchRequest) String 

func (x *CancelAsyncSearchRequest) String() string

func (*CancelAsyncSearchRequest) UnmarshalVT 

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

func (*CancelAsyncSearchRequest) UnmarshalVTUnsafe 

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

type CancelAsyncSearchResponse 

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

func (*CancelAsyncSearchResponse) CloneMessageVT 

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

func (*CancelAsyncSearchResponse) CloneVT 

func (m *CancelAsyncSearchResponse) CloneVT() *CancelAsyncSearchResponse

func (*CancelAsyncSearchResponse) Descriptor deprecated 

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

Deprecated: Use CancelAsyncSearchResponse.ProtoReflect.Descriptor instead.

func (*CancelAsyncSearchResponse) EqualMessageVT 

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

func (*CancelAsyncSearchResponse) EqualVT 

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

func (*CancelAsyncSearchResponse) MarshalToSizedBufferVT 

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

func (*CancelAsyncSearchResponse) MarshalToSizedBufferVTStrict 

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

func (*CancelAsyncSearchResponse) MarshalToVT 

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

func (*CancelAsyncSearchResponse) MarshalToVTStrict 

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

func (*CancelAsyncSearchResponse) MarshalVT 

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

func (*CancelAsyncSearchResponse) MarshalVTStrict 

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

func (*CancelAsyncSearchResponse) ProtoMessage 

func (*CancelAsyncSearchResponse) ProtoMessage()

func (*CancelAsyncSearchResponse) ProtoReflect 

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

func (*CancelAsyncSearchResponse) Reset 

func (x *CancelAsyncSearchResponse) Reset()

func (*CancelAsyncSearchResponse) SizeVT 

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

func (*CancelAsyncSearchResponse) String 

func (x *CancelAsyncSearchResponse) String() string

func (*CancelAsyncSearchResponse) UnmarshalVT 

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

func (*CancelAsyncSearchResponse) UnmarshalVTUnsafe 

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

type ComplexSearchRequest 

type ComplexSearchRequest struct {
	Query     *SearchQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`                            // Search query.
	Aggs      []*AggQuery  `protobuf:"bytes,2,rep,name=aggs,proto3" json:"aggs,omitempty"`                              // List of aggregation queries.
	Hist      *HistQuery   `protobuf:"bytes,3,opt,name=hist,proto3,oneof" json:"hist,omitempty"`                        // Histogram query.
	Size      int64        `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`                             // Maximum number of documents to return.
	Offset    int64        `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`                         // Search offset.
	WithTotal bool         `protobuf:"varint,6,opt,name=with_total,json=withTotal,proto3" json:"with_total,omitempty"`  // Should total number of documents be returned in response.
	Order     Order        `protobuf:"varint,7,opt,name=order,proto3,enum=seqproxyapi.v1.Order" json:"order,omitempty"` // Document order ORDER_DESC/ORDER_ASC.
	// contains filtered or unexported fields
}

func (*ComplexSearchRequest) CloneMessageVT 

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

func (*ComplexSearchRequest) CloneVT 

func (m *ComplexSearchRequest) CloneVT() *ComplexSearchRequest

func (*ComplexSearchRequest) Descriptor deprecated 

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

Deprecated: Use ComplexSearchRequest.ProtoReflect.Descriptor instead.

func (*ComplexSearchRequest) EqualMessageVT 

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

func (*ComplexSearchRequest) EqualVT 

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

func (*ComplexSearchRequest) GetAggs 

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

func (*ComplexSearchRequest) GetHist 

func (x *ComplexSearchRequest) GetHist() *HistQuery

func (*ComplexSearchRequest) GetOffset 

func (x *ComplexSearchRequest) GetOffset() int64

func (*ComplexSearchRequest) GetOrder 

func (x *ComplexSearchRequest) GetOrder() Order

func (*ComplexSearchRequest) GetQuery 

func (x *ComplexSearchRequest) GetQuery() *SearchQuery

func (*ComplexSearchRequest) GetSize 

func (x *ComplexSearchRequest) GetSize() int64

func (*ComplexSearchRequest) GetWithTotal 

func (x *ComplexSearchRequest) GetWithTotal() bool

func (*ComplexSearchRequest) MarshalToSizedBufferVT 

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

func (*ComplexSearchRequest) MarshalToSizedBufferVTStrict 

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

func (*ComplexSearchRequest) MarshalToVT 

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

func (*ComplexSearchRequest) MarshalToVTStrict 

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

func (*ComplexSearchRequest) MarshalVT 

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

func (*ComplexSearchRequest) MarshalVTStrict 

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

func (*ComplexSearchRequest) ProtoMessage 

func (*ComplexSearchRequest) ProtoMessage()

func (*ComplexSearchRequest) ProtoReflect 

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

func (*ComplexSearchRequest) Reset 

func (x *ComplexSearchRequest) Reset()

func (*ComplexSearchRequest) SizeVT 

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

func (*ComplexSearchRequest) String 

func (x *ComplexSearchRequest) String() string

func (*ComplexSearchRequest) UnmarshalVT 

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

func (*ComplexSearchRequest) UnmarshalVTUnsafe 

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

type ComplexSearchResponse 

type ComplexSearchResponse struct {

	// Deprecated: Marked as deprecated in seqproxyapi/v1/seq_proxy_api.proto.
	PartialResponse bool           `protobuf:"varint,1,opt,name=partial_response,json=partialResponse,proto3" json:"partial_response,omitempty"` // True if some stores returned an error. Deprecated, use `Error` instead.
	Total           int64          `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`                                            // Total number of documents satisfying request. Returned if `with_total` field in request is `true`.
	Docs            []*Document    `protobuf:"bytes,3,rep,name=docs,proto3" json:"docs,omitempty"`                                               // Documents, satisfying the request.
	Aggs            []*Aggregation `protobuf:"bytes,4,rep,name=aggs,proto3" json:"aggs,omitempty"`                                               // Aggregation results.
	Hist            *Histogram     `protobuf:"bytes,5,opt,name=hist,proto3,oneof" json:"hist,omitempty"`                                         // Histogram results.
	Error           *Error         `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`                                             // Error if happened.
	Explain         *ExplainEntry  `protobuf:"bytes,7,opt,name=explain,proto3,oneof" json:"explain,omitempty"`                                   // Explain info.
	// contains filtered or unexported fields
}

func (*ComplexSearchResponse) CloneMessageVT 

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

func (*ComplexSearchResponse) CloneVT 

func (m *ComplexSearchResponse) CloneVT() *ComplexSearchResponse

func (*ComplexSearchResponse) Descriptor deprecated 

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

Deprecated: Use ComplexSearchResponse.ProtoReflect.Descriptor instead.

func (*ComplexSearchResponse) EqualMessageVT 

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

func (*ComplexSearchResponse) EqualVT 

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

func (*ComplexSearchResponse) GetAggs 

func (x *ComplexSearchResponse) GetAggs() []*Aggregation

func (*ComplexSearchResponse) GetDocs 

func (x *ComplexSearchResponse) GetDocs() []*Document

func (*ComplexSearchResponse) GetError 

func (x *ComplexSearchResponse) GetError() *Error

func (*ComplexSearchResponse) GetExplain 

func (x *ComplexSearchResponse) GetExplain() *ExplainEntry

func (*ComplexSearchResponse) GetHist 

func (x *ComplexSearchResponse) GetHist() *Histogram

func (*ComplexSearchResponse) GetPartialResponse deprecated 

func (x *ComplexSearchResponse) GetPartialResponse() bool

Deprecated: Marked as deprecated in seqproxyapi/v1/seq_proxy_api.proto.

func (*ComplexSearchResponse) GetTotal 

func (x *ComplexSearchResponse) GetTotal() int64

func (*ComplexSearchResponse) MarshalToSizedBufferVT 

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

func (*ComplexSearchResponse) MarshalToSizedBufferVTStrict 

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

func (*ComplexSearchResponse) MarshalToVT 

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

func (*ComplexSearchResponse) MarshalToVTStrict 

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

func (*ComplexSearchResponse) MarshalVT 

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

func (*ComplexSearchResponse) MarshalVTStrict 

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

func (*ComplexSearchResponse) ProtoMessage 

func (*ComplexSearchResponse) ProtoMessage()

func (*ComplexSearchResponse) ProtoReflect 

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

func (*ComplexSearchResponse) Reset 

func (x *ComplexSearchResponse) Reset()

func (*ComplexSearchResponse) SizeVT 

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

func (*ComplexSearchResponse) String 

func (x *ComplexSearchResponse) String() string

func (*ComplexSearchResponse) UnmarshalVT 

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

func (*ComplexSearchResponse) UnmarshalVTUnsafe 

func (m *ComplexSearchResponse) 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 Document 

type Document struct {
	Id   string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`     // seq-id of the document.
	Data []byte                 `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // content of the document in utf-8 format.
	Time *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"` // timestamp from the document.
	// contains filtered or unexported fields
}

Document returned by seq-db.

func (*Document) CloneMessageVT 

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

func (*Document) CloneVT 

func (m *Document) CloneVT() *Document

func (*Document) Descriptor deprecated 

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

Deprecated: Use Document.ProtoReflect.Descriptor instead.

func (*Document) EqualMessageVT 

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

func (*Document) EqualVT 

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

func (*Document) GetData 

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

func (*Document) GetId 

func (x *Document) GetId() string

func (*Document) GetTime 

func (x *Document) GetTime() *timestamppb.Timestamp

func (*Document) MarshalJSON 

func (d *Document) MarshalJSON() ([]byte, error)

MarshalJSON replaces struct { "data" []byte } with struct { "data" json.RawMessage }.

func (*Document) MarshalToSizedBufferVT 

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

func (*Document) MarshalToSizedBufferVTStrict 

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

func (*Document) MarshalToVT 

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

func (*Document) MarshalToVTStrict 

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

func (*Document) MarshalVT 

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

func (*Document) MarshalVTStrict 

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

func (*Document) ProtoMessage 

func (*Document) ProtoMessage()

func (*Document) ProtoReflect 

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

func (*Document) Reset 

func (x *Document) Reset()

func (*Document) SizeVT 

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

func (*Document) String 

func (x *Document) String() string

func (*Document) UnmarshalJSON 

func (d *Document) UnmarshalJSON(data []byte) error

UnmarshalJSON replaces struct { "data" json.RawMessage } with struct { "data" []byte }.

func (*Document) UnmarshalVT 

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

func (*Document) UnmarshalVTUnsafe 

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

type Error 

type Error struct {
	Code    ErrorCode `protobuf:"varint,1,opt,name=code,proto3,enum=seqproxyapi.v1.ErrorCode" json:"code,omitempty"` // Response error code.
	Message string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                          // Additional message.
	// contains filtered or unexported fields
}

Additional details provided if an error during request handling occurred.

func (*Error) CloneMessageVT 

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

func (*Error) CloneVT 

func (m *Error) CloneVT() *Error

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) EqualMessageVT 

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

func (*Error) EqualVT 

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

func (*Error) GetCode 

func (x *Error) GetCode() ErrorCode

func (*Error) GetMessage 

func (x *Error) GetMessage() string

func (*Error) MarshalJSON 

func (e *Error) MarshalJSON() ([]byte, error)

func (*Error) MarshalToSizedBufferVT 

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

func (*Error) MarshalToSizedBufferVTStrict 

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

func (*Error) MarshalToVT 

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

func (*Error) MarshalToVTStrict 

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

func (*Error) MarshalVT 

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

func (*Error) MarshalVTStrict 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) SizeVT 

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

func (*Error) String 

func (x *Error) String() string

func (*Error) UnmarshalJSON 

func (e *Error) UnmarshalJSON(data []byte) error

func (*Error) UnmarshalVT 

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

func (*Error) UnmarshalVTUnsafe 

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

type ErrorCode 

type ErrorCode int32

Custom error code, returned by seq-db proxy. 

const (
	ErrorCode_ERROR_CODE_UNSPECIFIED            ErrorCode = 0 // Unknown/undefined code.
	ErrorCode_ERROR_CODE_NO                     ErrorCode = 1 // No error code. Returned when there were no problems during the request handling.
	ErrorCode_ERROR_CODE_PARTIAL_RESPONSE       ErrorCode = 2 // Partial response code. Returned when some of the seq-stores returned an error.
	ErrorCode_ERROR_CODE_TOO_MANY_FRACTIONS_HIT ErrorCode = 3 // Too many fractions hit code. Returned when too many fractions were hit during search exceeded limit.
)

func (ErrorCode) Descriptor 

func (ErrorCode) Descriptor() protoreflect.EnumDescriptor

func (ErrorCode) Enum 

func (x ErrorCode) Enum() *ErrorCode

func (ErrorCode) EnumDescriptor deprecated 

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

Deprecated: Use ErrorCode.Descriptor instead.

func (ErrorCode) Number 

func (x ErrorCode) Number() protoreflect.EnumNumber

func (ErrorCode) String 

func (x ErrorCode) String() string

func (ErrorCode) Type 

func (ErrorCode) Type() protoreflect.EnumType

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
}

Explain info

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

func (e *ExplainEntry) MarshalJSON() ([]byte, error)

MarshalJSON overrides duration field with formatted string instead of google.protobuf.Duration.

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

func (e *ExplainEntry) UnmarshalJSON(data []byte) error

func (*ExplainEntry) UnmarshalVT 

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

func (*ExplainEntry) UnmarshalVTUnsafe 

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

type ExportRequest 

type ExportRequest struct {
	Query  *SearchQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`    // Search query.
	Size   int64        `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`     // Maximum number of documents to return.
	Offset int64        `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"` // Search offset.
	// contains filtered or unexported fields
}

func (*ExportRequest) CloneMessageVT 

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

func (*ExportRequest) CloneVT 

func (m *ExportRequest) CloneVT() *ExportRequest

func (*ExportRequest) Descriptor deprecated 

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

Deprecated: Use ExportRequest.ProtoReflect.Descriptor instead.

func (*ExportRequest) EqualMessageVT 

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

func (*ExportRequest) EqualVT 

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

func (*ExportRequest) GetOffset 

func (x *ExportRequest) GetOffset() int64

func (*ExportRequest) GetQuery 

func (x *ExportRequest) GetQuery() *SearchQuery

func (*ExportRequest) GetSize 

func (x *ExportRequest) GetSize() int64

func (*ExportRequest) MarshalToSizedBufferVT 

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

func (*ExportRequest) MarshalToSizedBufferVTStrict 

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

func (*ExportRequest) MarshalToVT 

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

func (*ExportRequest) MarshalToVTStrict 

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

func (*ExportRequest) MarshalVT 

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

func (*ExportRequest) MarshalVTStrict 

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

func (*ExportRequest) ProtoMessage 

func (*ExportRequest) ProtoMessage()

func (*ExportRequest) ProtoReflect 

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

func (*ExportRequest) Reset 

func (x *ExportRequest) Reset()

func (*ExportRequest) SizeVT 

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

func (*ExportRequest) String 

func (x *ExportRequest) String() string

func (*ExportRequest) UnmarshalVT 

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

func (*ExportRequest) UnmarshalVTUnsafe 

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

type ExportResponse 

type ExportResponse struct {
	Doc *Document `protobuf:"bytes,1,opt,name=doc,proto3" json:"doc,omitempty"` // Response document.
	// contains filtered or unexported fields
}

func (*ExportResponse) CloneMessageVT 

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

func (*ExportResponse) CloneVT 

func (m *ExportResponse) CloneVT() *ExportResponse

func (*ExportResponse) Descriptor deprecated 

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

Deprecated: Use ExportResponse.ProtoReflect.Descriptor instead.

func (*ExportResponse) EqualMessageVT 

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

func (*ExportResponse) EqualVT 

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

func (*ExportResponse) GetDoc 

func (x *ExportResponse) GetDoc() *Document

func (*ExportResponse) MarshalToSizedBufferVT 

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

func (*ExportResponse) MarshalToSizedBufferVTStrict 

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

func (*ExportResponse) MarshalToVT 

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

func (*ExportResponse) MarshalToVTStrict 

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

func (*ExportResponse) MarshalVT 

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

func (*ExportResponse) MarshalVTStrict 

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

func (*ExportResponse) ProtoMessage 

func (*ExportResponse) ProtoMessage()

func (*ExportResponse) ProtoReflect 

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

func (*ExportResponse) Reset 

func (x *ExportResponse) Reset()

func (*ExportResponse) SizeVT 

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

func (*ExportResponse) String 

func (x *ExportResponse) String() string

func (*ExportResponse) UnmarshalVT 

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

func (*ExportResponse) UnmarshalVTUnsafe 

func (m *ExportResponse) 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"`
	// Maximum number of documents to fetch (pagination).
	// Ignored if with_docs was set to false, since documents are not stored in that case.
	Size int32 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// Document offset (pagination).
	// Ignored if with_docs was set to false, since documents are not stored in that case.
	Offset int32 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	// Documents sort order.
	Order Order `protobuf:"varint,4,opt,name=order,proto3,enum=seqproxyapi.v1.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=seqproxyapi.v1.AsyncSearchStatus" json:"status,omitempty"`
	Request    *StartAsyncSearchRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	Response   *ComplexSearchResponse   `protobuf:"bytes,3,opt,name=response,proto3" json:"response,omitempty"`
	StartedAt  *timestamppb.Timestamp   `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	ExpiresAt  *timestamppb.Timestamp   `protobuf:"bytes,5,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	CanceledAt *timestamppb.Timestamp   `protobuf:"bytes,6,opt,name=canceled_at,json=canceledAt,proto3,oneof" json:"canceled_at,omitempty"`
	// Search progress in range [0, 1].
	Progress float64 `protobuf:"fixed64,7,opt,name=progress,proto3" json:"progress,omitempty"`
	// The size of data stored on disk, in bytes.
	DiskUsage uint64 `protobuf:"varint,8,opt,name=disk_usage,json=diskUsage,proto3" json:"disk_usage,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) 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) GetProgress added in v0.59.0 

func (x *FetchAsyncSearchResultResponse) GetProgress() float64

func (*FetchAsyncSearchResultResponse) GetRequest added in v0.59.0 

func (x *FetchAsyncSearchResultResponse) GetRequest() *StartAsyncSearchRequest

func (*FetchAsyncSearchResultResponse) GetResponse 

func (x *FetchAsyncSearchResultResponse) GetResponse() *ComplexSearchResponse

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) MarshalJSON added in v0.59.0 

func (r *FetchAsyncSearchResultResponse) MarshalJSON() ([]byte, error)

MarshalJSON overrides timestamp fields and other fields with custom formatting for FetchAsyncSearchResultResponse.

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"` // Document ids to fetch.
	FieldsFilter *FetchRequest_FieldsFilter `protobuf:"bytes,2,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) GetFieldsFilter 

func (x *FetchRequest) GetFieldsFilter() *FetchRequest_FieldsFilter

func (*FetchRequest) GetIds 

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

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 {

	// list of fields to include or exclude, see allow_list flag for details.
	Fields []string `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	// allow_list means how to process 'fields' list:
	// true - remove all fields except the fields from the list,
	// false - remove given fields from documents.
	// Currently it works only with top-level fields, not with nested.
	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 GetAggregationRequest 

type GetAggregationRequest struct {
	Query *SearchQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // Search query.
	Aggs  []*AggQuery  `protobuf:"bytes,2,rep,name=aggs,proto3" json:"aggs,omitempty"`   // List of aggregation queries.
	// contains filtered or unexported fields
}

func (*GetAggregationRequest) CloneMessageVT 

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

func (*GetAggregationRequest) CloneVT 

func (m *GetAggregationRequest) CloneVT() *GetAggregationRequest

func (*GetAggregationRequest) Descriptor deprecated 

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

Deprecated: Use GetAggregationRequest.ProtoReflect.Descriptor instead.

func (*GetAggregationRequest) EqualMessageVT 

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

func (*GetAggregationRequest) EqualVT 

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

func (*GetAggregationRequest) GetAggs 

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

func (*GetAggregationRequest) GetQuery 

func (x *GetAggregationRequest) GetQuery() *SearchQuery

func (*GetAggregationRequest) MarshalToSizedBufferVT 

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

func (*GetAggregationRequest) MarshalToSizedBufferVTStrict 

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

func (*GetAggregationRequest) MarshalToVT 

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

func (*GetAggregationRequest) MarshalToVTStrict 

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

func (*GetAggregationRequest) MarshalVT 

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

func (*GetAggregationRequest) MarshalVTStrict 

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

func (*GetAggregationRequest) ProtoMessage 

func (*GetAggregationRequest) ProtoMessage()

func (*GetAggregationRequest) ProtoReflect 

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

func (*GetAggregationRequest) Reset 

func (x *GetAggregationRequest) Reset()

func (*GetAggregationRequest) SizeVT 

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

func (*GetAggregationRequest) String 

func (x *GetAggregationRequest) String() string

func (*GetAggregationRequest) UnmarshalVT 

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

func (*GetAggregationRequest) UnmarshalVTUnsafe 

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

type GetAggregationResponse 

type GetAggregationResponse struct {

	// Deprecated: Marked as deprecated in seqproxyapi/v1/seq_proxy_api.proto.
	PartialResponse bool           `protobuf:"varint,1,opt,name=partial_response,json=partialResponse,proto3" json:"partial_response,omitempty"` // True if some stores returned an error. Deprecated, use `Error` instead.
	Total           int64          `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`                                            // Total number of documents satisfying request. Returned if `with_total` field in request is `true`.
	Aggs            []*Aggregation `protobuf:"bytes,3,rep,name=aggs,proto3" json:"aggs,omitempty"`                                               // Aggregation results.
	Error           *Error         `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`                                             // Error if happened.
	// contains filtered or unexported fields
}

func (*GetAggregationResponse) CloneMessageVT 

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

func (*GetAggregationResponse) CloneVT 

func (m *GetAggregationResponse) CloneVT() *GetAggregationResponse

func (*GetAggregationResponse) Descriptor deprecated 

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

Deprecated: Use GetAggregationResponse.ProtoReflect.Descriptor instead.

func (*GetAggregationResponse) EqualMessageVT 

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

func (*GetAggregationResponse) EqualVT 

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

func (*GetAggregationResponse) GetAggs 

func (x *GetAggregationResponse) GetAggs() []*Aggregation

func (*GetAggregationResponse) GetError 

func (x *GetAggregationResponse) GetError() *Error

func (*GetAggregationResponse) GetPartialResponse deprecated 

func (x *GetAggregationResponse) GetPartialResponse() bool

Deprecated: Marked as deprecated in seqproxyapi/v1/seq_proxy_api.proto.

func (*GetAggregationResponse) GetTotal 

func (x *GetAggregationResponse) GetTotal() int64

func (*GetAggregationResponse) MarshalToSizedBufferVT 

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

func (*GetAggregationResponse) MarshalToSizedBufferVTStrict 

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

func (*GetAggregationResponse) MarshalToVT 

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

func (*GetAggregationResponse) MarshalToVTStrict 

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

func (*GetAggregationResponse) MarshalVT 

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

func (*GetAggregationResponse) MarshalVTStrict 

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

func (*GetAggregationResponse) ProtoMessage 

func (*GetAggregationResponse) ProtoMessage()

func (*GetAggregationResponse) ProtoReflect 

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

func (*GetAggregationResponse) Reset 

func (x *GetAggregationResponse) Reset()

func (*GetAggregationResponse) SizeVT 

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

func (*GetAggregationResponse) String 

func (x *GetAggregationResponse) String() string

func (*GetAggregationResponse) UnmarshalVT 

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

func (*GetAggregationResponse) UnmarshalVTUnsafe 

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

type GetAsyncSearchesListRequest added in v0.59.0 

type GetAsyncSearchesListRequest struct {
	Status *AsyncSearchStatus `protobuf:"varint,1,opt,name=status,proto3,enum=seqproxyapi.v1.AsyncSearchStatus,oneof" json:"status,omitempty"`
	// Maximum number of searches to fetch (pagination).
	Size int32 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// Searches offset (pagination).
	Offset int32 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	// list of async search ids to filter out result
	Ids []string `protobuf:"bytes,4,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) GetOffset added in v0.59.0 

func (x *GetAsyncSearchesListRequest) GetOffset() int32

func (*GetAsyncSearchesListRequest) GetSize added in v0.59.0 

func (x *GetAsyncSearchesListRequest) GetSize() int32

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 GetHistogramRequest 

type GetHistogramRequest struct {
	Query *SearchQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // Search query.
	Hist  *HistQuery   `protobuf:"bytes,2,opt,name=hist,proto3" json:"hist,omitempty"`   // Histogram query.
	// contains filtered or unexported fields
}

func (*GetHistogramRequest) CloneMessageVT 

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

func (*GetHistogramRequest) CloneVT 

func (m *GetHistogramRequest) CloneVT() *GetHistogramRequest

func (*GetHistogramRequest) Descriptor deprecated 

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

Deprecated: Use GetHistogramRequest.ProtoReflect.Descriptor instead.

func (*GetHistogramRequest) EqualMessageVT 

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

func (*GetHistogramRequest) EqualVT 

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

func (*GetHistogramRequest) GetHist 

func (x *GetHistogramRequest) GetHist() *HistQuery

func (*GetHistogramRequest) GetQuery 

func (x *GetHistogramRequest) GetQuery() *SearchQuery

func (*GetHistogramRequest) MarshalToSizedBufferVT 

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

func (*GetHistogramRequest) MarshalToSizedBufferVTStrict 

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

func (*GetHistogramRequest) MarshalToVT 

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

func (*GetHistogramRequest) MarshalToVTStrict 

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

func (*GetHistogramRequest) MarshalVT 

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

func (*GetHistogramRequest) MarshalVTStrict 

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

func (*GetHistogramRequest) ProtoMessage 

func (*GetHistogramRequest) ProtoMessage()

func (*GetHistogramRequest) ProtoReflect 

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

func (*GetHistogramRequest) Reset 

func (x *GetHistogramRequest) Reset()

func (*GetHistogramRequest) SizeVT 

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

func (*GetHistogramRequest) String 

func (x *GetHistogramRequest) String() string

func (*GetHistogramRequest) UnmarshalVT 

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

func (*GetHistogramRequest) UnmarshalVTUnsafe 

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

type GetHistogramResponse 

type GetHistogramResponse struct {

	// Deprecated: Marked as deprecated in seqproxyapi/v1/seq_proxy_api.proto.
	PartialResponse bool       `protobuf:"varint,1,opt,name=partial_response,json=partialResponse,proto3" json:"partial_response,omitempty"` // True if some stores returned an error. Deprecated, use `Error` instead.
	Total           int64      `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`                                            // Total number of documents satisfying request. Returned if `with_total` field in request is `true`.
	Hist            *Histogram `protobuf:"bytes,3,opt,name=hist,proto3" json:"hist,omitempty"`                                               // Histogram results.
	Error           *Error     `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`                                             // Error if happened.
	// contains filtered or unexported fields
}

func (*GetHistogramResponse) CloneMessageVT 

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

func (*GetHistogramResponse) CloneVT 

func (m *GetHistogramResponse) CloneVT() *GetHistogramResponse

func (*GetHistogramResponse) Descriptor deprecated 

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

Deprecated: Use GetHistogramResponse.ProtoReflect.Descriptor instead.

func (*GetHistogramResponse) EqualMessageVT 

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

func (*GetHistogramResponse) EqualVT 

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

func (*GetHistogramResponse) GetError 

func (x *GetHistogramResponse) GetError() *Error

func (*GetHistogramResponse) GetHist 

func (x *GetHistogramResponse) GetHist() *Histogram

func (*GetHistogramResponse) GetPartialResponse deprecated 

func (x *GetHistogramResponse) GetPartialResponse() bool

Deprecated: Marked as deprecated in seqproxyapi/v1/seq_proxy_api.proto.

func (*GetHistogramResponse) GetTotal 

func (x *GetHistogramResponse) GetTotal() int64

func (*GetHistogramResponse) MarshalToSizedBufferVT 

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

func (*GetHistogramResponse) MarshalToSizedBufferVTStrict 

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

func (*GetHistogramResponse) MarshalToVT 

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

func (*GetHistogramResponse) MarshalToVTStrict 

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

func (*GetHistogramResponse) MarshalVT 

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

func (*GetHistogramResponse) MarshalVTStrict 

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

func (*GetHistogramResponse) ProtoMessage 

func (*GetHistogramResponse) ProtoMessage()

func (*GetHistogramResponse) ProtoReflect 

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

func (*GetHistogramResponse) Reset 

func (x *GetHistogramResponse) Reset()

func (*GetHistogramResponse) SizeVT 

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

func (*GetHistogramResponse) String 

func (x *GetHistogramResponse) String() string

func (*GetHistogramResponse) UnmarshalVT 

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

func (*GetHistogramResponse) UnmarshalVTUnsafe 

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

type HistQuery 

type HistQuery struct {
	Interval string `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"` // Interval in promql duration format like `1m`, `5s`. More details: https://prometheus.io/docs/prometheus/latest/querying/basics/#float-literals-and-time-durations
	// contains filtered or unexported fields
}

Histogram query

func (*HistQuery) CloneMessageVT 

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

func (*HistQuery) CloneVT 

func (m *HistQuery) CloneVT() *HistQuery

func (*HistQuery) Descriptor deprecated 

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

Deprecated: Use HistQuery.ProtoReflect.Descriptor instead.

func (*HistQuery) EqualMessageVT 

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

func (*HistQuery) EqualVT 

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

func (*HistQuery) GetInterval 

func (x *HistQuery) GetInterval() string

func (*HistQuery) MarshalToSizedBufferVT 

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

func (*HistQuery) MarshalToSizedBufferVTStrict 

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

func (*HistQuery) MarshalToVT 

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

func (*HistQuery) MarshalToVTStrict 

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

func (*HistQuery) MarshalVT 

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

func (*HistQuery) MarshalVTStrict 

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

func (*HistQuery) ProtoMessage 

func (*HistQuery) ProtoMessage()

func (*HistQuery) ProtoReflect 

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

func (*HistQuery) Reset 

func (x *HistQuery) Reset()

func (*HistQuery) SizeVT 

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

func (*HistQuery) String 

func (x *HistQuery) String() string

func (*HistQuery) UnmarshalVT 

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

func (*HistQuery) UnmarshalVTUnsafe 

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

type Histogram 

type Histogram struct {
	Buckets []*Histogram_Bucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"` // Buckets for given histogram request.
	// contains filtered or unexported fields
}

Histogram response.

func (*Histogram) CloneMessageVT 

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

func (*Histogram) CloneVT 

func (m *Histogram) CloneVT() *Histogram

func (*Histogram) Descriptor deprecated 

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

Deprecated: Use Histogram.ProtoReflect.Descriptor instead.

func (*Histogram) EqualMessageVT 

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

func (*Histogram) EqualVT 

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

func (*Histogram) GetBuckets 

func (x *Histogram) GetBuckets() []*Histogram_Bucket

func (*Histogram) MarshalToSizedBufferVT 

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

func (*Histogram) MarshalToSizedBufferVTStrict 

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

func (*Histogram) MarshalToVT 

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

func (*Histogram) MarshalToVTStrict 

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

func (*Histogram) MarshalVT 

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

func (*Histogram) MarshalVTStrict 

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

func (*Histogram) ProtoMessage 

func (*Histogram) ProtoMessage()

func (*Histogram) ProtoReflect 

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

func (*Histogram) Reset 

func (x *Histogram) Reset()

func (*Histogram) SizeVT 

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

func (*Histogram) String 

func (x *Histogram) String() string

func (*Histogram) UnmarshalVT 

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

func (*Histogram) UnmarshalVTUnsafe 

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

type Histogram_Bucket 

type Histogram_Bucket struct {
	DocCount uint64                 `protobuf:"varint,1,opt,name=doc_count,json=docCount,proto3" json:"doc_count,omitempty"` // Number of documents in bucket.
	Ts       *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=ts,proto3" json:"ts,omitempty"`                              // Left border of the bucket.
	// contains filtered or unexported fields
}

Key-value pair with time as a key and number of documents in this bucket as a value.

func (*Histogram_Bucket) CloneMessageVT 

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

func (*Histogram_Bucket) CloneVT 

func (m *Histogram_Bucket) CloneVT() *Histogram_Bucket

func (*Histogram_Bucket) Descriptor deprecated 

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

Deprecated: Use Histogram_Bucket.ProtoReflect.Descriptor instead.

func (*Histogram_Bucket) EqualMessageVT 

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

func (*Histogram_Bucket) EqualVT 

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

func (*Histogram_Bucket) GetDocCount 

func (x *Histogram_Bucket) GetDocCount() uint64

func (*Histogram_Bucket) GetTs 

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

func (*Histogram_Bucket) MarshalToSizedBufferVT 

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

func (*Histogram_Bucket) MarshalToSizedBufferVTStrict 

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

func (*Histogram_Bucket) MarshalToVT 

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

func (*Histogram_Bucket) MarshalToVTStrict 

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

func (*Histogram_Bucket) MarshalVT 

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

func (*Histogram_Bucket) MarshalVTStrict 

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

func (*Histogram_Bucket) ProtoMessage 

func (*Histogram_Bucket) ProtoMessage()

func (*Histogram_Bucket) ProtoReflect 

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

func (*Histogram_Bucket) Reset 

func (x *Histogram_Bucket) Reset()

func (*Histogram_Bucket) SizeVT 

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

func (*Histogram_Bucket) String 

func (x *Histogram_Bucket) String() string

func (*Histogram_Bucket) UnmarshalVT 

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

func (*Histogram_Bucket) UnmarshalVTUnsafe 

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

type MappingRequest 

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

func (*MappingRequest) CloneMessageVT 

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

func (*MappingRequest) CloneVT 

func (m *MappingRequest) CloneVT() *MappingRequest

func (*MappingRequest) Descriptor deprecated 

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

Deprecated: Use MappingRequest.ProtoReflect.Descriptor instead.

func (*MappingRequest) EqualMessageVT 

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

func (*MappingRequest) EqualVT 

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

func (*MappingRequest) MarshalToSizedBufferVT 

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

func (*MappingRequest) MarshalToSizedBufferVTStrict 

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

func (*MappingRequest) MarshalToVT 

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

func (*MappingRequest) MarshalToVTStrict 

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

func (*MappingRequest) MarshalVT 

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

func (*MappingRequest) MarshalVTStrict 

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

func (*MappingRequest) ProtoMessage 

func (*MappingRequest) ProtoMessage()

func (*MappingRequest) ProtoReflect 

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

func (*MappingRequest) Reset 

func (x *MappingRequest) Reset()

func (*MappingRequest) SizeVT 

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

func (*MappingRequest) String 

func (x *MappingRequest) String() string

func (*MappingRequest) UnmarshalVT 

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

func (*MappingRequest) UnmarshalVTUnsafe 

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

type MappingResponse 

type MappingResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // utf-8 encoded mapping info.
	// contains filtered or unexported fields
}

func (*MappingResponse) CloneMessageVT 

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

func (*MappingResponse) CloneVT 

func (m *MappingResponse) CloneVT() *MappingResponse

func (*MappingResponse) Descriptor deprecated 

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

Deprecated: Use MappingResponse.ProtoReflect.Descriptor instead.

func (*MappingResponse) EqualMessageVT 

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

func (*MappingResponse) EqualVT 

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

func (*MappingResponse) GetData 

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

func (*MappingResponse) MarshalToSizedBufferVT 

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

func (*MappingResponse) MarshalToSizedBufferVTStrict 

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

func (*MappingResponse) MarshalToVT 

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

func (*MappingResponse) MarshalToVTStrict 

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

func (*MappingResponse) MarshalVT 

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

func (*MappingResponse) MarshalVTStrict 

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

func (*MappingResponse) ProtoMessage 

func (*MappingResponse) ProtoMessage()

func (*MappingResponse) ProtoReflect 

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

func (*MappingResponse) Reset 

func (x *MappingResponse) Reset()

func (*MappingResponse) SizeVT 

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

func (*MappingResponse) String 

func (x *MappingResponse) String() string

func (*MappingResponse) UnmarshalVT 

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

func (*MappingResponse) UnmarshalVTUnsafe 

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

type Order 

type Order int32

Order of document sorting. 

const (
	Order_ORDER_DESC Order = 0 // Type for descending order.
	Order_ORDER_ASC  Order = 1 // Type for ascending order.
)

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 SearchQuery 

type SearchQuery struct {
	Query   string                 `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`      // Search query.
	From    *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`        // Lower bound for search (inclusive).
	To      *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`            // Upper bound for search (inclusive).
	Explain bool                   `protobuf:"varint,4,opt,name=explain,proto3" json:"explain,omitempty"` // Should request be explained (tracing will be provided with the result).
	// contains filtered or unexported fields
}

General search query for requesting documents.

func (*SearchQuery) CloneMessageVT 

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

func (*SearchQuery) CloneVT 

func (m *SearchQuery) CloneVT() *SearchQuery

func (*SearchQuery) Descriptor deprecated 

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

Deprecated: Use SearchQuery.ProtoReflect.Descriptor instead.

func (*SearchQuery) EqualMessageVT 

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

func (*SearchQuery) EqualVT 

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

func (*SearchQuery) GetExplain 

func (x *SearchQuery) GetExplain() bool

func (*SearchQuery) GetFrom 

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

func (*SearchQuery) GetQuery 

func (x *SearchQuery) GetQuery() string

func (*SearchQuery) GetTo 

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

func (*SearchQuery) MarshalToSizedBufferVT 

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

func (*SearchQuery) MarshalToSizedBufferVTStrict 

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

func (*SearchQuery) MarshalToVT 

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

func (*SearchQuery) MarshalToVTStrict 

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

func (*SearchQuery) MarshalVT 

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

func (*SearchQuery) MarshalVTStrict 

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

func (*SearchQuery) ProtoMessage 

func (*SearchQuery) ProtoMessage()

func (*SearchQuery) ProtoReflect 

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

func (*SearchQuery) Reset 

func (x *SearchQuery) Reset()

func (*SearchQuery) SizeVT 

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

func (*SearchQuery) String 

func (x *SearchQuery) String() string

func (*SearchQuery) UnmarshalVT 

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

func (*SearchQuery) UnmarshalVTUnsafe 

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

type SearchRequest 

type SearchRequest struct {
	Query     *SearchQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`                            // Search query.
	Size      int64        `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`                             // Maximum number of documents to return.
	Offset    int64        `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`                         // Search offset.
	WithTotal bool         `protobuf:"varint,4,opt,name=with_total,json=withTotal,proto3" json:"with_total,omitempty"`  // Should total number of documents be returned in response.
	Order     Order        `protobuf:"varint,5,opt,name=order,proto3,enum=seqproxyapi.v1.Order" json:"order,omitempty"` // Document order ORDER_DESC/ORDER_ASC.
	// 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) GetOffset 

func (x *SearchRequest) GetOffset() int64

func (*SearchRequest) GetOrder 

func (x *SearchRequest) GetOrder() Order

func (*SearchRequest) GetQuery 

func (x *SearchRequest) GetQuery() *SearchQuery

func (*SearchRequest) GetSize 

func (x *SearchRequest) GetSize() 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 seqproxyapi/v1/seq_proxy_api.proto.
	PartialResponse bool        `protobuf:"varint,1,opt,name=partial_response,json=partialResponse,proto3" json:"partial_response,omitempty"` // True if some stores returned an error. Deprecated, use `Error` instead.
	Total           int64       `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`                                            // Total number of documents satisfying request. Returned if `with_total` field in request is `true`.
	Docs            []*Document `protobuf:"bytes,3,rep,name=docs,proto3" json:"docs,omitempty"`                                               // Documents, satisfying the request.
	Error           *Error      `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`                                             // Error if happened.
	// 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) GetDocs 

func (x *SearchResponse) GetDocs() []*Document

func (*SearchResponse) GetError 

func (x *SearchResponse) GetError() *Error

func (*SearchResponse) GetPartialResponse deprecated 

func (x *SearchResponse) GetPartialResponse() bool

Deprecated: Marked as deprecated in seqproxyapi/v1/seq_proxy_api.proto.

func (*SearchResponse) GetTotal 

func (x *SearchResponse) GetTotal() int64

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 SeqProxyApiClient 

type SeqProxyApiClient interface {
	// Fetch documents for given SearchQuery.
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
	// Fetch documents, aggregations and histograms for given queries correspondingly.
	ComplexSearch(ctx context.Context, in *ComplexSearchRequest, opts ...grpc.CallOption) (*ComplexSearchResponse, error)
	// Fetch aggregations for given SearchQuery and AggQueries.
	GetAggregation(ctx context.Context, in *GetAggregationRequest, opts ...grpc.CallOption) (*GetAggregationResponse, error)
	// Fetch histogram for given SearchQuery and HistQuery.
	GetHistogram(ctx context.Context, in *GetHistogramRequest, opts ...grpc.CallOption) (*GetHistogramResponse, error)
	// Fetch documents by the corresponding seq-ids.
	Fetch(ctx context.Context, in *FetchRequest, opts ...grpc.CallOption) (SeqProxyApi_FetchClient, error)
	// Fetch current seq-db mapping.
	Mapping(ctx context.Context, in *MappingRequest, opts ...grpc.CallOption) (*MappingResponse, error)
	// Fetch seq-db store's availability information.
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	// Stream documents for given SearchQuery. Same as Search, but returns streaming response.
	Export(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (SeqProxyApi_ExportClient, error)
	// Starts a new asynchronous search operation.
	// The server processes the request in the background and returns a search ID.
	StartAsyncSearch(ctx context.Context, in *StartAsyncSearchRequest, opts ...grpc.CallOption) (*StartAsyncSearchResponse, error)
	// Fetches the result or current status of a previously started async search.
	// Clients should use the search ID returned by StartAsyncSearch.
	FetchAsyncSearchResult(ctx context.Context, in *FetchAsyncSearchResultRequest, opts ...grpc.CallOption) (*FetchAsyncSearchResultResponse, error)
	// Cancels an ongoing asynchronous search operation if it hasn't completed yet.
	CancelAsyncSearch(ctx context.Context, in *CancelAsyncSearchRequest, opts ...grpc.CallOption) (*CancelAsyncSearchResponse, error)
	// Frees up resources if the result is no longer needed.
	DeleteAsyncSearch(ctx context.Context, in *DeleteAsyncSearchRequest, opts ...grpc.CallOption) (*DeleteAsyncSearchResponse, error)
	// Fetch list of async searches.
	GetAsyncSearchesList(ctx context.Context, in *GetAsyncSearchesListRequest, opts ...grpc.CallOption) (*GetAsyncSearchesListResponse, error)
}

SeqProxyApiClient is the client API for SeqProxyApi 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 NewSeqProxyApiClient 

func NewSeqProxyApiClient(cc grpc.ClientConnInterface) SeqProxyApiClient

type SeqProxyApiServer 

type SeqProxyApiServer interface {
	// Fetch documents for given SearchQuery.
	Search(context.Context, *SearchRequest) (*SearchResponse, error)
	// Fetch documents, aggregations and histograms for given queries correspondingly.
	ComplexSearch(context.Context, *ComplexSearchRequest) (*ComplexSearchResponse, error)
	// Fetch aggregations for given SearchQuery and AggQueries.
	GetAggregation(context.Context, *GetAggregationRequest) (*GetAggregationResponse, error)
	// Fetch histogram for given SearchQuery and HistQuery.
	GetHistogram(context.Context, *GetHistogramRequest) (*GetHistogramResponse, error)
	// Fetch documents by the corresponding seq-ids.
	Fetch(*FetchRequest, SeqProxyApi_FetchServer) error
	// Fetch current seq-db mapping.
	Mapping(context.Context, *MappingRequest) (*MappingResponse, error)
	// Fetch seq-db store's availability information.
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	// Stream documents for given SearchQuery. Same as Search, but returns streaming response.
	Export(*ExportRequest, SeqProxyApi_ExportServer) error
	// Starts a new asynchronous search operation.
	// The server processes the request in the background and returns a search ID.
	StartAsyncSearch(context.Context, *StartAsyncSearchRequest) (*StartAsyncSearchResponse, error)
	// Fetches the result or current status of a previously started async search.
	// Clients should use the search ID returned by StartAsyncSearch.
	FetchAsyncSearchResult(context.Context, *FetchAsyncSearchResultRequest) (*FetchAsyncSearchResultResponse, error)
	// Cancels an ongoing asynchronous search operation if it hasn't completed yet.
	CancelAsyncSearch(context.Context, *CancelAsyncSearchRequest) (*CancelAsyncSearchResponse, error)
	// Frees up resources if the result is no longer needed.
	DeleteAsyncSearch(context.Context, *DeleteAsyncSearchRequest) (*DeleteAsyncSearchResponse, error)
	// Fetch list of async searches.
	GetAsyncSearchesList(context.Context, *GetAsyncSearchesListRequest) (*GetAsyncSearchesListResponse, error)
	// contains filtered or unexported methods
}

SeqProxyApiServer is the server API for SeqProxyApi service. All implementations must embed UnimplementedSeqProxyApiServer for forward compatibility

type SeqProxyApi_ExportClient 

type SeqProxyApi_ExportClient interface {
	Recv() (*ExportResponse, error)
	grpc.ClientStream
}

type SeqProxyApi_ExportServer 

type SeqProxyApi_ExportServer interface {
	Send(*ExportResponse) error
	grpc.ServerStream
}

type SeqProxyApi_FetchClient 

type SeqProxyApi_FetchClient interface {
	Recv() (*Document, error)
	grpc.ClientStream
}

type SeqProxyApi_FetchServer 

type SeqProxyApi_FetchServer interface {
	Send(*Document) error
	grpc.ServerStream
}

type StartAsyncSearchRequest 

type StartAsyncSearchRequest struct {

	// Duration to retain the result of an asynchronous query.
	// After this period, the result will be deleted.
	Retention *durationpb.Duration `protobuf:"bytes,1,opt,name=retention,proto3" json:"retention,omitempty"`
	// Search query to execute.
	Query *SearchQuery `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// List of aggregation queries.
	Aggs []*AggQuery `protobuf:"bytes,3,rep,name=aggs,proto3" json:"aggs,omitempty"`
	// Optional histogram query.
	Hist *HistQuery `protobuf:"bytes,4,opt,name=hist,proto3,oneof" json:"hist,omitempty"`
	// Set this to true to enable document retrieval via FetchAsyncSearch.
	// Note: enabling this may significantly increase disk space usage.
	WithDocs bool `protobuf:"varint,5,opt,name=with_docs,json=withDocs,proto3" json:"with_docs,omitempty"`
	// Maximum number of documents to find. Doesn't affect aggs and hist.
	// Ignored if with_docs was set to false.
	Size int64 `protobuf:"varint,6,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) GetHist 

func (x *StartAsyncSearchRequest) GetHist() *HistQuery

func (*StartAsyncSearchRequest) GetQuery 

func (x *StartAsyncSearchRequest) GetQuery() *SearchQuery

func (*StartAsyncSearchRequest) GetRetention 

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

func (*StartAsyncSearchRequest) GetSize added in v0.61.2 

func (x *StartAsyncSearchRequest) GetSize() int64

func (*StartAsyncSearchRequest) GetWithDocs added in v0.59.0 

func (x *StartAsyncSearchRequest) GetWithDocs() bool

func (*StartAsyncSearchRequest) MarshalJSON added in v0.59.0 

func (r *StartAsyncSearchRequest) MarshalJSON() ([]byte, error)

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 {

	// Unique ID used to retrieve search results with FetchAsyncSearchResult.
	SearchId string `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"`
	// 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) GetSearchId 

func (x *StartAsyncSearchResponse) GetSearchId() string

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 {
	NumberOfStores    int32                  `protobuf:"varint,1,opt,name=number_of_stores,json=numberOfStores,proto3" json:"number_of_stores,omitempty"`               // Total number of stores.
	OldestStorageTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=oldest_storage_time,json=oldestStorageTime,proto3,oneof" json:"oldest_storage_time,omitempty"` // Timestamp of the oldest stored document across all stores.
	Stores            []*StoreStatus         `protobuf:"bytes,4,rep,name=stores,proto3" json:"stores,omitempty"`                                                        // Detailed information about each store.
	// 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) GetNumberOfStores 

func (x *StatusResponse) GetNumberOfStores() int32

func (*StatusResponse) GetOldestStorageTime 

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

func (*StatusResponse) GetStores 

func (x *StatusResponse) GetStores() []*StoreStatus

func (*StatusResponse) MarshalJSON 

func (s *StatusResponse) MarshalJSON() ([]byte, error)

MarshalJSON overrides oldest_storage_time field with formatted string instead of google.protobuf.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) UnmarshalJSON 

func (s *StatusResponse) UnmarshalJSON(data []byte) error

func (*StatusResponse) UnmarshalVT 

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

func (*StatusResponse) UnmarshalVTUnsafe 

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

type StoreStatus 

type StoreStatus struct {
	Host   string             `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`           // Store's IP-address.
	Values *StoreStatusValues `protobuf:"bytes,2,opt,name=values,proto3,oneof" json:"values,omitempty"` // Store's status information.
	Error  *string            `protobuf:"bytes,3,opt,name=error,proto3,oneof" json:"error,omitempty"`   // Error during the request.
	// contains filtered or unexported fields
}

func (*StoreStatus) CloneMessageVT 

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

func (*StoreStatus) CloneVT 

func (m *StoreStatus) CloneVT() *StoreStatus

func (*StoreStatus) Descriptor deprecated 

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

Deprecated: Use StoreStatus.ProtoReflect.Descriptor instead.

func (*StoreStatus) EqualMessageVT 

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

func (*StoreStatus) EqualVT 

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

func (*StoreStatus) GetError 

func (x *StoreStatus) GetError() string

func (*StoreStatus) GetHost 

func (x *StoreStatus) GetHost() string

func (*StoreStatus) GetValues 

func (x *StoreStatus) GetValues() *StoreStatusValues

func (*StoreStatus) MarshalToSizedBufferVT 

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

func (*StoreStatus) MarshalToSizedBufferVTStrict 

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

func (*StoreStatus) MarshalToVT 

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

func (*StoreStatus) MarshalToVTStrict 

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

func (*StoreStatus) MarshalVT 

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

func (*StoreStatus) MarshalVTStrict 

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

func (*StoreStatus) ProtoMessage 

func (*StoreStatus) ProtoMessage()

func (*StoreStatus) ProtoReflect 

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

func (*StoreStatus) Reset 

func (x *StoreStatus) Reset()

func (*StoreStatus) SizeVT 

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

func (*StoreStatus) String 

func (x *StoreStatus) String() string

func (*StoreStatus) UnmarshalVT 

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

func (*StoreStatus) UnmarshalVTUnsafe 

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

type StoreStatusValues 

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

func (*StoreStatusValues) CloneMessageVT 

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

func (*StoreStatusValues) CloneVT 

func (m *StoreStatusValues) CloneVT() *StoreStatusValues

func (*StoreStatusValues) Descriptor deprecated 

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

Deprecated: Use StoreStatusValues.ProtoReflect.Descriptor instead.

func (*StoreStatusValues) EqualMessageVT 

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

func (*StoreStatusValues) EqualVT 

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

func (*StoreStatusValues) GetOldestTime 

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

func (*StoreStatusValues) MarshalJSON 

func (s *StoreStatusValues) MarshalJSON() ([]byte, error)

MarshalJSON overrides oldest_time field with formatted string instead of google.protobuf.Timestamp.

func (*StoreStatusValues) MarshalToSizedBufferVT 

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

func (*StoreStatusValues) MarshalToSizedBufferVTStrict 

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

func (*StoreStatusValues) MarshalToVT 

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

func (*StoreStatusValues) MarshalToVTStrict 

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

func (*StoreStatusValues) MarshalVT 

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

func (*StoreStatusValues) MarshalVTStrict 

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

func (*StoreStatusValues) ProtoMessage 

func (*StoreStatusValues) ProtoMessage()

func (*StoreStatusValues) ProtoReflect 

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

func (*StoreStatusValues) Reset 

func (x *StoreStatusValues) Reset()

func (*StoreStatusValues) SizeVT 

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

func (*StoreStatusValues) String 

func (x *StoreStatusValues) String() string

func (*StoreStatusValues) UnmarshalJSON 

func (s *StoreStatusValues) UnmarshalJSON(data []byte) error

func (*StoreStatusValues) UnmarshalVT 

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

func (*StoreStatusValues) UnmarshalVTUnsafe 

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

type TestAggBucket 

type TestAggBucket Aggregation_Bucket

TestAggBucket is a type alias to avoid recursion in MarshalJSON.

type TestDoc 

type TestDoc Document

TestDoc is Document wrapper that is used to omit methods like MarshalJSON.

type TestExplainEntry 

type TestExplainEntry ExplainEntry

TestExplainEntry is ExplainEntry wrapper that is used to omit methods like MarshalJSON.

type TestFetchAsyncSearchResultResponse added in v0.59.0 

type TestFetchAsyncSearchResultResponse FetchAsyncSearchResultResponse

TestFetchAsyncSearchResultResponse is FetchAsyncSearchResultResponse wrapper that is used to omit methods like MarshalJSON. Need this marshaler to not conflict with Document's custom marshaler

type TestStatusResponse 

type TestStatusResponse StatusResponse

TestStatusResponse is StatusResponse wrapper that is used to omit methods like MarshalJSON.

type TestStoreStatusValues 

type TestStoreStatusValues StoreStatusValues

TestStoreStatusValues is StoreStatusValues wrapper that is used to omit methods like MarshalJSON.

type UnimplementedSeqProxyApiServer 

type UnimplementedSeqProxyApiServer struct {
}

UnimplementedSeqProxyApiServer must be embedded to have forward compatible implementations.

func (UnimplementedSeqProxyApiServer) CancelAsyncSearch 

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

func (UnimplementedSeqProxyApiServer) ComplexSearch 

func (UnimplementedSeqProxyApiServer) ComplexSearch(context.Context, *ComplexSearchRequest) (*ComplexSearchResponse, error)

func (UnimplementedSeqProxyApiServer) DeleteAsyncSearch added in v0.59.0 

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

func (UnimplementedSeqProxyApiServer) Export 

func (UnimplementedSeqProxyApiServer) Export(*ExportRequest, SeqProxyApi_ExportServer) error

func (UnimplementedSeqProxyApiServer) Fetch 

func (UnimplementedSeqProxyApiServer) Fetch(*FetchRequest, SeqProxyApi_FetchServer) error

func (UnimplementedSeqProxyApiServer) FetchAsyncSearchResult 

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

func (UnimplementedSeqProxyApiServer) GetAggregation 

func (UnimplementedSeqProxyApiServer) GetAggregation(context.Context, *GetAggregationRequest) (*GetAggregationResponse, error)

func (UnimplementedSeqProxyApiServer) GetAsyncSearchesList added in v0.59.0 

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

func (UnimplementedSeqProxyApiServer) GetHistogram 

func (UnimplementedSeqProxyApiServer) GetHistogram(context.Context, *GetHistogramRequest) (*GetHistogramResponse, error)

func (UnimplementedSeqProxyApiServer) Mapping 

func (UnimplementedSeqProxyApiServer) Mapping(context.Context, *MappingRequest) (*MappingResponse, error)

func (UnimplementedSeqProxyApiServer) Search 

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

func (UnimplementedSeqProxyApiServer) StartAsyncSearch 

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

func (UnimplementedSeqProxyApiServer) Status 

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

type UnsafeSeqProxyApiServer 

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

UnsafeSeqProxyApiServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SeqProxyApiServer 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.