storeapi

package
v0.57.0 Latest Latest
Warning

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

 Go to latest Published: Jul 31, 2025 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Overview

Package storeapi is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

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

Enum value maps for AggFunc.

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

Enum value maps for Order.

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

Enum value maps for SearchErrorCode.

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

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

Functions

func RegisterStoreApiHandler 

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

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

func RegisterStoreApiHandlerClient 

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

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

func RegisterStoreApiHandlerFromEndpoint 

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

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

func RegisterStoreApiHandlerServer 

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

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

func RegisterStoreApiServer 

func RegisterStoreApiServer(s grpc.ServiceRegistrar, srv StoreApiServer)

Types

type AggFunc 

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

func MustProtoAggFunc 

func MustProtoAggFunc(f seq.AggFunc) AggFunc

func ToProtoAggFunc 

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

func (AggFunc) Descriptor 

func (AggFunc) Descriptor() protoreflect.EnumDescriptor

func (AggFunc) Enum 

func (x AggFunc) Enum() *AggFunc

func (AggFunc) EnumDescriptor deprecated 

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

Deprecated: Use AggFunc.Descriptor instead.

func (AggFunc) MustAggFunc 

func (f AggFunc) MustAggFunc() seq.AggFunc

func (AggFunc) Number 

func (x AggFunc) Number() protoreflect.EnumNumber

func (AggFunc) String 

func (x AggFunc) String() string

func (AggFunc) ToAggFunc 

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

func (AggFunc) Type 

func (AggFunc) Type() protoreflect.EnumType

type AggQuery 

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

func (*AggQuery) CloneMessageVT 

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

func (*AggQuery) CloneVT 

func (m *AggQuery) CloneVT() *AggQuery

func (*AggQuery) Descriptor deprecated 

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

Deprecated: Use AggQuery.ProtoReflect.Descriptor instead.

func (*AggQuery) EqualMessageVT 

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

func (*AggQuery) EqualVT 

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

func (*AggQuery) GetField 

func (x *AggQuery) GetField() string

func (*AggQuery) GetFunc 

func (x *AggQuery) GetFunc() AggFunc

func (*AggQuery) GetGroupBy 

func (x *AggQuery) GetGroupBy() string

func (*AggQuery) GetInterval 

func (x *AggQuery) GetInterval() int64

func (*AggQuery) GetQuantiles 

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

func (*AggQuery) MarshalToSizedBufferVT 

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

func (*AggQuery) MarshalToSizedBufferVTStrict 

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

func (*AggQuery) MarshalToVT 

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

func (*AggQuery) MarshalToVTStrict 

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

func (*AggQuery) MarshalVT 

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

func (*AggQuery) MarshalVTStrict 

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

func (*AggQuery) ProtoMessage 

func (*AggQuery) ProtoMessage()

func (*AggQuery) ProtoReflect 

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

func (*AggQuery) Reset 

func (x *AggQuery) Reset()

func (*AggQuery) SizeVT 

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

func (*AggQuery) String 

func (x *AggQuery) String() string

func (*AggQuery) UnmarshalVT 

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

func (*AggQuery) UnmarshalVTUnsafe 

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

type BinaryData 

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

func (*BinaryData) CloneMessageVT 

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

func (*BinaryData) CloneVT 

func (m *BinaryData) CloneVT() *BinaryData

func (*BinaryData) Descriptor deprecated 

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

Deprecated: Use BinaryData.ProtoReflect.Descriptor instead.

func (*BinaryData) EqualMessageVT 

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

func (*BinaryData) EqualVT 

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

func (*BinaryData) GetData 

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

func (*BinaryData) MarshalToSizedBufferVT 

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

func (*BinaryData) MarshalToSizedBufferVTStrict 

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

func (*BinaryData) MarshalToVT 

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

func (*BinaryData) MarshalToVTStrict 

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

func (*BinaryData) MarshalVT 

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

func (*BinaryData) MarshalVTStrict 

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

func (*BinaryData) ProtoMessage 

func (*BinaryData) ProtoMessage()

func (*BinaryData) ProtoReflect 

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

func (*BinaryData) Reset 

func (x *BinaryData) Reset()

func (*BinaryData) SizeVT 

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

func (*BinaryData) String 

func (x *BinaryData) String() string

func (*BinaryData) UnmarshalVT 

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

func (*BinaryData) UnmarshalVTUnsafe 

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

type BulkRequest 

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

func (*BulkRequest) CloneMessageVT 

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

func (*BulkRequest) CloneVT 

func (m *BulkRequest) CloneVT() *BulkRequest

func (*BulkRequest) Descriptor deprecated 

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

Deprecated: Use BulkRequest.ProtoReflect.Descriptor instead.

func (*BulkRequest) EqualMessageVT 

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

func (*BulkRequest) EqualVT 

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

func (*BulkRequest) GetCount 

func (x *BulkRequest) GetCount() int64

func (*BulkRequest) GetDocs 

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

func (*BulkRequest) GetMetas 

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

func (*BulkRequest) MarshalToSizedBufferVT 

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

func (*BulkRequest) MarshalToSizedBufferVTStrict 

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

func (*BulkRequest) MarshalToVT 

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

func (*BulkRequest) MarshalToVTStrict 

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

func (*BulkRequest) MarshalVT 

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

func (*BulkRequest) MarshalVTStrict 

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

func (*BulkRequest) ProtoMessage 

func (*BulkRequest) ProtoMessage()

func (*BulkRequest) ProtoReflect 

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

func (*BulkRequest) Reset 

func (x *BulkRequest) Reset()

func (*BulkRequest) SizeVT 

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

func (*BulkRequest) String 

func (x *BulkRequest) String() string

func (*BulkRequest) UnmarshalVT 

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

func (*BulkRequest) UnmarshalVTUnsafe 

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

type ExplainEntry 

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

func (*ExplainEntry) CloneMessageVT 

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

func (*ExplainEntry) CloneVT 

func (m *ExplainEntry) CloneVT() *ExplainEntry

func (*ExplainEntry) Descriptor deprecated 

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

Deprecated: Use ExplainEntry.ProtoReflect.Descriptor instead.

func (*ExplainEntry) EqualMessageVT 

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

func (*ExplainEntry) EqualVT 

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

func (*ExplainEntry) GetChildren 

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

func (*ExplainEntry) GetDuration 

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

func (*ExplainEntry) GetMessage 

func (x *ExplainEntry) GetMessage() string

func (*ExplainEntry) MarshalToSizedBufferVT 

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

func (*ExplainEntry) MarshalToSizedBufferVTStrict 

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

func (*ExplainEntry) MarshalToVT 

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

func (*ExplainEntry) MarshalToVTStrict 

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

func (*ExplainEntry) MarshalVT 

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

func (*ExplainEntry) MarshalVTStrict 

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

func (*ExplainEntry) ProtoMessage 

func (*ExplainEntry) ProtoMessage()

func (*ExplainEntry) ProtoReflect 

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

func (*ExplainEntry) Reset 

func (x *ExplainEntry) Reset()

func (*ExplainEntry) SizeVT 

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

func (*ExplainEntry) String 

func (x *ExplainEntry) String() string

func (*ExplainEntry) UnmarshalVT 

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

func (*ExplainEntry) UnmarshalVTUnsafe 

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

type FetchAsyncSearchResultRequest 

type FetchAsyncSearchResultRequest struct {
	SearchId string `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"`
	WithDocs bool   `protobuf:"varint,2,opt,name=with_docs,json=withDocs,proto3" json:"with_docs,omitempty"`
	Size     int32  `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	Offset   int32  `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,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) GetSearchId 

func (x *FetchAsyncSearchResultRequest) GetSearchId() string

func (*FetchAsyncSearchResultRequest) GetSize 

func (x *FetchAsyncSearchResultRequest) GetSize() int32

func (*FetchAsyncSearchResultRequest) GetWithDocs 

func (x *FetchAsyncSearchResultRequest) GetWithDocs() bool

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 {
	Done              bool                   `protobuf:"varint,1,opt,name=done,proto3" json:"done,omitempty"`
	Response          *SearchResponse        `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	Expiration        *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=expiration,proto3" json:"expiration,omitempty"`
	Aggs              []*AggQuery            `protobuf:"bytes,5,rep,name=aggs,proto3" json:"aggs,omitempty"`
	HistogramInterval int64                  `protobuf:"varint,6,opt,name=histogram_interval,json=histogramInterval,proto3" json:"histogram_interval,omitempty"`
	Order             Order                  `protobuf:"varint,7,opt,name=order,proto3,enum=api.Order" json:"order,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchAsyncSearchResultResponse) CloneMessageVT 

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

func (*FetchAsyncSearchResultResponse) CloneVT 

func (m *FetchAsyncSearchResultResponse) CloneVT() *FetchAsyncSearchResultResponse

func (*FetchAsyncSearchResultResponse) Descriptor deprecated 

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

Deprecated: Use FetchAsyncSearchResultResponse.ProtoReflect.Descriptor instead.

func (*FetchAsyncSearchResultResponse) EqualMessageVT 

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

func (*FetchAsyncSearchResultResponse) EqualVT 

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

func (*FetchAsyncSearchResultResponse) GetAggs 

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

func (*FetchAsyncSearchResultResponse) GetDone 

func (x *FetchAsyncSearchResultResponse) GetDone() bool

func (*FetchAsyncSearchResultResponse) GetExpiration 

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

func (*FetchAsyncSearchResultResponse) GetHistogramInterval 

func (x *FetchAsyncSearchResultResponse) GetHistogramInterval() int64

func (*FetchAsyncSearchResultResponse) GetOrder 

func (x *FetchAsyncSearchResultResponse) GetOrder() Order

func (*FetchAsyncSearchResultResponse) GetResponse 

func (x *FetchAsyncSearchResultResponse) GetResponse() *SearchResponse

func (*FetchAsyncSearchResultResponse) MarshalToSizedBufferVT 

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

func (*FetchAsyncSearchResultResponse) MarshalToSizedBufferVTStrict 

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

func (*FetchAsyncSearchResultResponse) MarshalToVT 

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

func (*FetchAsyncSearchResultResponse) MarshalToVTStrict 

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

func (*FetchAsyncSearchResultResponse) MarshalVT 

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

func (*FetchAsyncSearchResultResponse) MarshalVTStrict 

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

func (*FetchAsyncSearchResultResponse) ProtoMessage 

func (*FetchAsyncSearchResultResponse) ProtoMessage()

func (*FetchAsyncSearchResultResponse) ProtoReflect 

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

func (*FetchAsyncSearchResultResponse) Reset 

func (x *FetchAsyncSearchResultResponse) Reset()

func (*FetchAsyncSearchResultResponse) SizeVT 

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

func (*FetchAsyncSearchResultResponse) String 

func (x *FetchAsyncSearchResultResponse) String() string

func (*FetchAsyncSearchResultResponse) UnmarshalVT 

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

func (*FetchAsyncSearchResultResponse) UnmarshalVTUnsafe 

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

type FetchRequest 

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

func (*FetchRequest) CloneMessageVT 

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

func (*FetchRequest) CloneVT 

func (m *FetchRequest) CloneVT() *FetchRequest

func (*FetchRequest) Descriptor deprecated 

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

Deprecated: Use FetchRequest.ProtoReflect.Descriptor instead.

func (*FetchRequest) EqualMessageVT 

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

func (*FetchRequest) EqualVT 

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

func (*FetchRequest) GetExplain 

func (x *FetchRequest) GetExplain() bool

func (*FetchRequest) GetFieldsFilter 

func (x *FetchRequest) GetFieldsFilter() *FetchRequest_FieldsFilter

func (*FetchRequest) GetIds 

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

func (*FetchRequest) GetIdsWithHints 

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

func (*FetchRequest) MarshalToSizedBufferVT 

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

func (*FetchRequest) MarshalToSizedBufferVTStrict 

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

func (*FetchRequest) MarshalToVT 

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

func (*FetchRequest) MarshalToVTStrict 

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

func (*FetchRequest) MarshalVT 

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

func (*FetchRequest) MarshalVTStrict 

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

func (*FetchRequest) ProtoMessage 

func (*FetchRequest) ProtoMessage()

func (*FetchRequest) ProtoReflect 

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

func (*FetchRequest) Reset 

func (x *FetchRequest) Reset()

func (*FetchRequest) SizeVT 

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

func (*FetchRequest) String 

func (x *FetchRequest) String() string

func (*FetchRequest) UnmarshalVT 

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

func (*FetchRequest) UnmarshalVTUnsafe 

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

type FetchRequest_FieldsFilter 

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

func (*FetchRequest_FieldsFilter) CloneMessageVT 

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

func (*FetchRequest_FieldsFilter) CloneVT 

func (m *FetchRequest_FieldsFilter) CloneVT() *FetchRequest_FieldsFilter

func (*FetchRequest_FieldsFilter) Descriptor deprecated 

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

Deprecated: Use FetchRequest_FieldsFilter.ProtoReflect.Descriptor instead.

func (*FetchRequest_FieldsFilter) EqualMessageVT 

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

func (*FetchRequest_FieldsFilter) EqualVT 

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

func (*FetchRequest_FieldsFilter) GetAllowList 

func (x *FetchRequest_FieldsFilter) GetAllowList() bool

func (*FetchRequest_FieldsFilter) GetFields 

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

func (*FetchRequest_FieldsFilter) MarshalToSizedBufferVT 

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

func (*FetchRequest_FieldsFilter) MarshalToSizedBufferVTStrict 

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

func (*FetchRequest_FieldsFilter) MarshalToVT 

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

func (*FetchRequest_FieldsFilter) MarshalToVTStrict 

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

func (*FetchRequest_FieldsFilter) MarshalVT 

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

func (*FetchRequest_FieldsFilter) MarshalVTStrict 

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

func (*FetchRequest_FieldsFilter) ProtoMessage 

func (*FetchRequest_FieldsFilter) ProtoMessage()

func (*FetchRequest_FieldsFilter) ProtoReflect 

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

func (*FetchRequest_FieldsFilter) Reset 

func (x *FetchRequest_FieldsFilter) Reset()

func (*FetchRequest_FieldsFilter) SizeVT 

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

func (*FetchRequest_FieldsFilter) String 

func (x *FetchRequest_FieldsFilter) String() string

func (*FetchRequest_FieldsFilter) UnmarshalVT 

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

func (*FetchRequest_FieldsFilter) UnmarshalVTUnsafe 

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

type IdWithHint 

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

func (*IdWithHint) CloneMessageVT 

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

func (*IdWithHint) CloneVT 

func (m *IdWithHint) CloneVT() *IdWithHint

func (*IdWithHint) Descriptor deprecated 

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

Deprecated: Use IdWithHint.ProtoReflect.Descriptor instead.

func (*IdWithHint) EqualMessageVT 

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

func (*IdWithHint) EqualVT 

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

func (*IdWithHint) GetHint 

func (x *IdWithHint) GetHint() string

func (*IdWithHint) GetId 

func (x *IdWithHint) GetId() string

func (*IdWithHint) MarshalToSizedBufferVT 

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

func (*IdWithHint) MarshalToSizedBufferVTStrict 

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

func (*IdWithHint) MarshalToVT 

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

func (*IdWithHint) MarshalToVTStrict 

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

func (*IdWithHint) MarshalVT 

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

func (*IdWithHint) MarshalVTStrict 

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

func (*IdWithHint) ProtoMessage 

func (*IdWithHint) ProtoMessage()

func (*IdWithHint) ProtoReflect 

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

func (*IdWithHint) Reset 

func (x *IdWithHint) Reset()

func (*IdWithHint) SizeVT 

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

func (*IdWithHint) String 

func (x *IdWithHint) String() string

func (*IdWithHint) UnmarshalVT 

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

func (*IdWithHint) UnmarshalVTUnsafe 

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

type Order 

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

func MustProtoOrder 

func MustProtoOrder(o seq.DocsOrder) Order

func ToProtoOrder 

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

func (Order) Descriptor 

func (Order) Descriptor() protoreflect.EnumDescriptor

func (Order) Enum 

func (x Order) Enum() *Order

func (Order) EnumDescriptor deprecated 

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

Deprecated: Use Order.Descriptor instead.

func (Order) MustDocsOrder 

func (o Order) MustDocsOrder() seq.DocsOrder

func (Order) Number 

func (x Order) Number() protoreflect.EnumNumber

func (Order) String 

func (x Order) String() string

func (Order) ToDocsOrder 

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

func (Order) Type 

func (Order) Type() protoreflect.EnumType

type SearchErrorCode 

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

func (SearchErrorCode) Descriptor 

func (SearchErrorCode) Descriptor() protoreflect.EnumDescriptor

func (SearchErrorCode) Enum 

func (x SearchErrorCode) Enum() *SearchErrorCode

func (SearchErrorCode) EnumDescriptor deprecated 

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

Deprecated: Use SearchErrorCode.Descriptor instead.

func (SearchErrorCode) Number 

func (x SearchErrorCode) Number() protoreflect.EnumNumber

func (SearchErrorCode) String 

func (x SearchErrorCode) String() string

func (SearchErrorCode) Type 

func (SearchErrorCode) Type() protoreflect.EnumType

type SearchRequest 

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

func (*SearchRequest) CloneMessageVT 

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

func (*SearchRequest) CloneVT 

func (m *SearchRequest) CloneVT() *SearchRequest

func (*SearchRequest) Descriptor deprecated 

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

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) EqualMessageVT 

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

func (*SearchRequest) EqualVT 

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

func (*SearchRequest) GetAggregation deprecated 

func (x *SearchRequest) GetAggregation() string

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

func (*SearchRequest) GetAggregationFilter deprecated 

func (x *SearchRequest) GetAggregationFilter() string

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

func (*SearchRequest) GetAggs 

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

func (*SearchRequest) GetExplain 

func (x *SearchRequest) GetExplain() bool

func (*SearchRequest) GetFrom 

func (x *SearchRequest) GetFrom() int64

func (*SearchRequest) GetInterval 

func (x *SearchRequest) GetInterval() int64

func (*SearchRequest) GetOffset 

func (x *SearchRequest) GetOffset() int64

func (*SearchRequest) GetOrder 

func (x *SearchRequest) GetOrder() Order

func (*SearchRequest) GetQuery 

func (x *SearchRequest) GetQuery() string

func (*SearchRequest) GetSize 

func (x *SearchRequest) GetSize() int64

func (*SearchRequest) GetTo 

func (x *SearchRequest) GetTo() int64

func (*SearchRequest) GetWithTotal 

func (x *SearchRequest) GetWithTotal() bool

func (*SearchRequest) MarshalToSizedBufferVT 

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

func (*SearchRequest) MarshalToSizedBufferVTStrict 

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

func (*SearchRequest) MarshalToVT 

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

func (*SearchRequest) MarshalToVTStrict 

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

func (*SearchRequest) MarshalVT 

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

func (*SearchRequest) MarshalVTStrict 

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

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect 

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

func (*SearchRequest) Reset 

func (x *SearchRequest) Reset()

func (*SearchRequest) SizeVT 

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

func (*SearchRequest) String 

func (x *SearchRequest) String() string

func (*SearchRequest) UnmarshalVT 

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

func (*SearchRequest) UnmarshalVTUnsafe 

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

type SearchResponse 

type SearchResponse struct {

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

func (*SearchResponse) CloneMessageVT 

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

func (*SearchResponse) CloneVT 

func (m *SearchResponse) CloneVT() *SearchResponse

func (*SearchResponse) Descriptor deprecated 

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

Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.

func (*SearchResponse) EqualMessageVT 

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

func (*SearchResponse) EqualVT 

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

func (*SearchResponse) GetAggs 

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

func (*SearchResponse) GetCode 

func (x *SearchResponse) GetCode() SearchErrorCode

func (*SearchResponse) GetData deprecated 

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

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

func (*SearchResponse) GetErrors 

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

func (*SearchResponse) GetExplain 

func (x *SearchResponse) GetExplain() *ExplainEntry

func (*SearchResponse) GetHistogram 

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

func (*SearchResponse) GetIdSources 

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

func (*SearchResponse) GetTotal 

func (x *SearchResponse) GetTotal() uint64

func (*SearchResponse) MarshalToSizedBufferVT 

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

func (*SearchResponse) MarshalToSizedBufferVTStrict 

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

func (*SearchResponse) MarshalToVT 

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

func (*SearchResponse) MarshalToVTStrict 

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

func (*SearchResponse) MarshalVT 

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

func (*SearchResponse) MarshalVTStrict 

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

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) ProtoReflect 

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

func (*SearchResponse) Reset 

func (x *SearchResponse) Reset()

func (*SearchResponse) SizeVT 

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

func (*SearchResponse) String 

func (x *SearchResponse) String() string

func (*SearchResponse) UnmarshalVT 

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

func (*SearchResponse) UnmarshalVTUnsafe 

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

type SearchResponse_Agg 

type SearchResponse_Agg struct {

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

func (*SearchResponse_Agg) CloneMessageVT 

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

func (*SearchResponse_Agg) CloneVT 

func (m *SearchResponse_Agg) CloneVT() *SearchResponse_Agg

func (*SearchResponse_Agg) Descriptor deprecated 

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

Deprecated: Use SearchResponse_Agg.ProtoReflect.Descriptor instead.

func (*SearchResponse_Agg) EqualMessageVT 

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

func (*SearchResponse_Agg) EqualVT 

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

func (*SearchResponse_Agg) GetAgg deprecated 

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

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

func (*SearchResponse_Agg) GetAggHistogram 

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

func (*SearchResponse_Agg) GetNotExists 

func (x *SearchResponse_Agg) GetNotExists() int64

func (*SearchResponse_Agg) GetTimeseries 

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

func (*SearchResponse_Agg) MarshalToSizedBufferVT 

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

func (*SearchResponse_Agg) MarshalToSizedBufferVTStrict 

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

func (*SearchResponse_Agg) MarshalToVT 

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

func (*SearchResponse_Agg) MarshalToVTStrict 

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

func (*SearchResponse_Agg) MarshalVT 

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

func (*SearchResponse_Agg) MarshalVTStrict 

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

func (*SearchResponse_Agg) ProtoMessage 

func (*SearchResponse_Agg) ProtoMessage()

func (*SearchResponse_Agg) ProtoReflect 

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

func (*SearchResponse_Agg) Reset 

func (x *SearchResponse_Agg) Reset()

func (*SearchResponse_Agg) SizeVT 

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

func (*SearchResponse_Agg) String 

func (x *SearchResponse_Agg) String() string

func (*SearchResponse_Agg) UnmarshalVT 

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

func (*SearchResponse_Agg) UnmarshalVTUnsafe 

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

type SearchResponse_Bin 

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

func (*SearchResponse_Bin) CloneMessageVT 

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

func (*SearchResponse_Bin) CloneVT 

func (m *SearchResponse_Bin) CloneVT() *SearchResponse_Bin

func (*SearchResponse_Bin) Descriptor deprecated 

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

Deprecated: Use SearchResponse_Bin.ProtoReflect.Descriptor instead.

func (*SearchResponse_Bin) EqualMessageVT 

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

func (*SearchResponse_Bin) EqualVT 

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

func (*SearchResponse_Bin) GetHist 

func (x *SearchResponse_Bin) GetHist() *SearchResponse_Histogram

func (*SearchResponse_Bin) GetLabel 

func (x *SearchResponse_Bin) GetLabel() string

func (*SearchResponse_Bin) GetTs 

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

func (*SearchResponse_Bin) MarshalToSizedBufferVT 

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

func (*SearchResponse_Bin) MarshalToSizedBufferVTStrict 

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

func (*SearchResponse_Bin) MarshalToVT 

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

func (*SearchResponse_Bin) MarshalToVTStrict 

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

func (*SearchResponse_Bin) MarshalVT 

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

func (*SearchResponse_Bin) MarshalVTStrict 

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

func (*SearchResponse_Bin) ProtoMessage 

func (*SearchResponse_Bin) ProtoMessage()

func (*SearchResponse_Bin) ProtoReflect 

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

func (*SearchResponse_Bin) Reset 

func (x *SearchResponse_Bin) Reset()

func (*SearchResponse_Bin) SizeVT 

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

func (*SearchResponse_Bin) String 

func (x *SearchResponse_Bin) String() string

func (*SearchResponse_Bin) UnmarshalVT 

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

func (*SearchResponse_Bin) UnmarshalVTUnsafe 

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

type SearchResponse_Histogram 

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

func (*SearchResponse_Histogram) CloneMessageVT 

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

func (*SearchResponse_Histogram) CloneVT 

func (m *SearchResponse_Histogram) CloneVT() *SearchResponse_Histogram

func (*SearchResponse_Histogram) Descriptor deprecated 

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

Deprecated: Use SearchResponse_Histogram.ProtoReflect.Descriptor instead.

func (*SearchResponse_Histogram) EqualMessageVT 

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

func (*SearchResponse_Histogram) EqualVT 

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

func (*SearchResponse_Histogram) GetMax 

func (x *SearchResponse_Histogram) GetMax() float64

func (*SearchResponse_Histogram) GetMin 

func (x *SearchResponse_Histogram) GetMin() float64

func (*SearchResponse_Histogram) GetNotExists 

func (x *SearchResponse_Histogram) GetNotExists() int64

func (*SearchResponse_Histogram) GetSamples 

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

func (*SearchResponse_Histogram) GetSum 

func (x *SearchResponse_Histogram) GetSum() float64

func (*SearchResponse_Histogram) GetTotal 

func (x *SearchResponse_Histogram) GetTotal() int64

func (*SearchResponse_Histogram) MarshalToSizedBufferVT 

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

func (*SearchResponse_Histogram) MarshalToSizedBufferVTStrict 

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

func (*SearchResponse_Histogram) MarshalToVT 

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

func (*SearchResponse_Histogram) MarshalToVTStrict 

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

func (*SearchResponse_Histogram) MarshalVT 

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

func (*SearchResponse_Histogram) MarshalVTStrict 

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

func (*SearchResponse_Histogram) ProtoMessage 

func (*SearchResponse_Histogram) ProtoMessage()

func (*SearchResponse_Histogram) ProtoReflect 

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

func (*SearchResponse_Histogram) Reset 

func (x *SearchResponse_Histogram) Reset()

func (*SearchResponse_Histogram) SizeVT 

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

func (*SearchResponse_Histogram) String 

func (x *SearchResponse_Histogram) String() string

func (*SearchResponse_Histogram) UnmarshalVT 

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

func (*SearchResponse_Histogram) UnmarshalVTUnsafe 

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

type SearchResponse_Id 

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

func (*SearchResponse_Id) CloneMessageVT 

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

func (*SearchResponse_Id) CloneVT 

func (m *SearchResponse_Id) CloneVT() *SearchResponse_Id

func (*SearchResponse_Id) Descriptor deprecated 

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

Deprecated: Use SearchResponse_Id.ProtoReflect.Descriptor instead.

func (*SearchResponse_Id) EqualMessageVT 

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

func (*SearchResponse_Id) EqualVT 

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

func (*SearchResponse_Id) GetMid 

func (x *SearchResponse_Id) GetMid() uint64

func (*SearchResponse_Id) GetRid 

func (x *SearchResponse_Id) GetRid() uint64

func (*SearchResponse_Id) MarshalToSizedBufferVT 

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

func (*SearchResponse_Id) MarshalToSizedBufferVTStrict 

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

func (*SearchResponse_Id) MarshalToVT 

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

func (*SearchResponse_Id) MarshalToVTStrict 

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

func (*SearchResponse_Id) MarshalVT 

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

func (*SearchResponse_Id) MarshalVTStrict 

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

func (*SearchResponse_Id) ProtoMessage 

func (*SearchResponse_Id) ProtoMessage()

func (*SearchResponse_Id) ProtoReflect 

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

func (*SearchResponse_Id) Reset 

func (x *SearchResponse_Id) Reset()

func (*SearchResponse_Id) SizeVT 

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

func (*SearchResponse_Id) String 

func (x *SearchResponse_Id) String() string

func (*SearchResponse_Id) UnmarshalVT 

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

func (*SearchResponse_Id) UnmarshalVTUnsafe 

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

type SearchResponse_IdWithHint 

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

func (*SearchResponse_IdWithHint) CloneMessageVT 

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

func (*SearchResponse_IdWithHint) CloneVT 

func (m *SearchResponse_IdWithHint) CloneVT() *SearchResponse_IdWithHint

func (*SearchResponse_IdWithHint) Descriptor deprecated 

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

Deprecated: Use SearchResponse_IdWithHint.ProtoReflect.Descriptor instead.

func (*SearchResponse_IdWithHint) EqualMessageVT 

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

func (*SearchResponse_IdWithHint) EqualVT 

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

func (*SearchResponse_IdWithHint) GetHint 

func (x *SearchResponse_IdWithHint) GetHint() string

func (*SearchResponse_IdWithHint) GetId 

func (x *SearchResponse_IdWithHint) GetId() *SearchResponse_Id

func (*SearchResponse_IdWithHint) MarshalToSizedBufferVT 

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

func (*SearchResponse_IdWithHint) MarshalToSizedBufferVTStrict 

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

func (*SearchResponse_IdWithHint) MarshalToVT 

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

func (*SearchResponse_IdWithHint) MarshalToVTStrict 

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

func (*SearchResponse_IdWithHint) MarshalVT 

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

func (*SearchResponse_IdWithHint) MarshalVTStrict 

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

func (*SearchResponse_IdWithHint) ProtoMessage 

func (*SearchResponse_IdWithHint) ProtoMessage()

func (*SearchResponse_IdWithHint) ProtoReflect 

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

func (*SearchResponse_IdWithHint) Reset 

func (x *SearchResponse_IdWithHint) Reset()

func (*SearchResponse_IdWithHint) SizeVT 

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

func (*SearchResponse_IdWithHint) String 

func (x *SearchResponse_IdWithHint) String() string

func (*SearchResponse_IdWithHint) UnmarshalVT 

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

func (*SearchResponse_IdWithHint) UnmarshalVTUnsafe 

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

type StartAsyncSearchRequest 

type StartAsyncSearchRequest struct {
	SearchId          string      `protobuf:"bytes,1,opt,name=search_id,json=searchId,proto3" json:"search_id,omitempty"`
	Query             string      `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	From              int64       `protobuf:"varint,3,opt,name=from,proto3" json:"from,omitempty"`
	To                int64       `protobuf:"varint,4,opt,name=to,proto3" json:"to,omitempty"`
	Aggs              []*AggQuery `protobuf:"bytes,5,rep,name=aggs,proto3" json:"aggs,omitempty"`
	HistogramInterval int64       `protobuf:"varint,6,opt,name=histogram_interval,json=histogramInterval,proto3" json:"histogram_interval,omitempty"`
	Order             Order       `protobuf:"varint,7,opt,name=order,proto3,enum=api.Order" json:"order,omitempty"`
	// contains filtered or unexported fields
}

func (*StartAsyncSearchRequest) CloneMessageVT 

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

func (*StartAsyncSearchRequest) CloneVT 

func (m *StartAsyncSearchRequest) CloneVT() *StartAsyncSearchRequest

func (*StartAsyncSearchRequest) Descriptor deprecated 

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

Deprecated: Use StartAsyncSearchRequest.ProtoReflect.Descriptor instead.

func (*StartAsyncSearchRequest) EqualMessageVT 

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

func (*StartAsyncSearchRequest) EqualVT 

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

func (*StartAsyncSearchRequest) GetAggs 

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

func (*StartAsyncSearchRequest) GetFrom 

func (x *StartAsyncSearchRequest) GetFrom() int64

func (*StartAsyncSearchRequest) GetHistogramInterval 

func (x *StartAsyncSearchRequest) GetHistogramInterval() int64

func (*StartAsyncSearchRequest) GetOrder 

func (x *StartAsyncSearchRequest) GetOrder() Order

func (*StartAsyncSearchRequest) GetQuery 

func (x *StartAsyncSearchRequest) GetQuery() string

func (*StartAsyncSearchRequest) GetSearchId 

func (x *StartAsyncSearchRequest) GetSearchId() string

func (*StartAsyncSearchRequest) GetTo 

func (x *StartAsyncSearchRequest) GetTo() int64

func (*StartAsyncSearchRequest) MarshalToSizedBufferVT 

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

func (*StartAsyncSearchRequest) MarshalToSizedBufferVTStrict 

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

func (*StartAsyncSearchRequest) MarshalToVT 

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

func (*StartAsyncSearchRequest) MarshalToVTStrict 

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

func (*StartAsyncSearchRequest) MarshalVT 

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

func (*StartAsyncSearchRequest) MarshalVTStrict 

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

func (*StartAsyncSearchRequest) ProtoMessage 

func (*StartAsyncSearchRequest) ProtoMessage()

func (*StartAsyncSearchRequest) ProtoReflect 

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

func (*StartAsyncSearchRequest) Reset 

func (x *StartAsyncSearchRequest) Reset()

func (*StartAsyncSearchRequest) SizeVT 

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

func (*StartAsyncSearchRequest) String 

func (x *StartAsyncSearchRequest) String() string

func (*StartAsyncSearchRequest) UnmarshalVT 

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

func (*StartAsyncSearchRequest) UnmarshalVTUnsafe 

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

type StartAsyncSearchResponse 

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

func (*StartAsyncSearchResponse) CloneMessageVT 

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

func (*StartAsyncSearchResponse) CloneVT 

func (m *StartAsyncSearchResponse) CloneVT() *StartAsyncSearchResponse

func (*StartAsyncSearchResponse) Descriptor deprecated 

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

Deprecated: Use StartAsyncSearchResponse.ProtoReflect.Descriptor instead.

func (*StartAsyncSearchResponse) EqualMessageVT 

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

func (*StartAsyncSearchResponse) EqualVT 

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

func (*StartAsyncSearchResponse) MarshalToSizedBufferVT 

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

func (*StartAsyncSearchResponse) MarshalToSizedBufferVTStrict 

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

func (*StartAsyncSearchResponse) MarshalToVT 

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

func (*StartAsyncSearchResponse) MarshalToVTStrict 

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

func (*StartAsyncSearchResponse) MarshalVT 

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

func (*StartAsyncSearchResponse) MarshalVTStrict 

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

func (*StartAsyncSearchResponse) ProtoMessage 

func (*StartAsyncSearchResponse) ProtoMessage()

func (*StartAsyncSearchResponse) ProtoReflect 

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

func (*StartAsyncSearchResponse) Reset 

func (x *StartAsyncSearchResponse) Reset()

func (*StartAsyncSearchResponse) SizeVT 

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

func (*StartAsyncSearchResponse) String 

func (x *StartAsyncSearchResponse) String() string

func (*StartAsyncSearchResponse) UnmarshalVT 

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

func (*StartAsyncSearchResponse) UnmarshalVTUnsafe 

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

type StatusRequest 

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

func (*StatusRequest) CloneMessageVT 

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

func (*StatusRequest) CloneVT 

func (m *StatusRequest) CloneVT() *StatusRequest

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) EqualMessageVT 

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

func (*StatusRequest) EqualVT 

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

func (*StatusRequest) MarshalToSizedBufferVT 

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

func (*StatusRequest) MarshalToSizedBufferVTStrict 

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

func (*StatusRequest) MarshalToVT 

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

func (*StatusRequest) MarshalToVTStrict 

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

func (*StatusRequest) MarshalVT 

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

func (*StatusRequest) MarshalVTStrict 

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

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

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

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) SizeVT 

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

func (*StatusRequest) String 

func (x *StatusRequest) String() string

func (*StatusRequest) UnmarshalVT 

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

func (*StatusRequest) UnmarshalVTUnsafe 

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

type StatusResponse 

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

func (*StatusResponse) CloneMessageVT 

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

func (*StatusResponse) CloneVT 

func (m *StatusResponse) CloneVT() *StatusResponse

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) EqualMessageVT 

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

func (*StatusResponse) EqualVT 

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

func (*StatusResponse) GetOldestTime 

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

func (*StatusResponse) MarshalToSizedBufferVT 

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

func (*StatusResponse) MarshalToSizedBufferVTStrict 

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

func (*StatusResponse) MarshalToVT 

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

func (*StatusResponse) MarshalToVTStrict 

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

func (*StatusResponse) MarshalVT 

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

func (*StatusResponse) MarshalVTStrict 

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

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) SizeVT 

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

func (*StatusResponse) String 

func (x *StatusResponse) String() string

func (*StatusResponse) UnmarshalVT 

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

func (*StatusResponse) UnmarshalVTUnsafe 

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

type StoreApiClient 

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

StoreApiClient is the client API for StoreApi service.

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

func NewStoreApiClient 

func NewStoreApiClient(cc grpc.ClientConnInterface) StoreApiClient

type StoreApiServer 

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

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

type StoreApi_FetchClient 

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

type StoreApi_FetchServer 

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

type UnimplementedStoreApiServer 

type UnimplementedStoreApiServer struct {
}

UnimplementedStoreApiServer must be embedded to have forward compatible implementations.

func (UnimplementedStoreApiServer) Bulk 

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

func (UnimplementedStoreApiServer) Fetch 

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

func (UnimplementedStoreApiServer) FetchAsyncSearchResult 

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

func (UnimplementedStoreApiServer) Search 

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

func (UnimplementedStoreApiServer) StartAsyncSearch 

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

func (UnimplementedStoreApiServer) Status 

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

type UnsafeStoreApiServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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