seqapi

type AggFunc int32

type Aggregation struct {
	Buckets   []*Aggregation_Bucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`
	NotExists int64                 `protobuf:"varint,2,opt,name=not_exists,json=notExists,proto3" json:"not_exists,omitempty"`
	// contains filtered or unexported fields
}

type AggregationQuery 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=seqapi.v1.AggFunc" json:"func,omitempty"`
	Quantiles []float64 `protobuf:"fixed64,5,rep,packed,name=quantiles,proto3" json:"quantiles,omitempty"`
	Interval  *string   `protobuf:"bytes,6,opt,name=interval,proto3,oneof" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

type Aggregation_Bucket struct {
	Key       string                 `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value     *float64               `protobuf:"fixed64,3,opt,name=value,proto3,oneof" json:"value,omitempty"`
	NotExists int64                  `protobuf:"varint,4,opt,name=not_exists,json=notExists,proto3" json:"not_exists,omitempty"`
	Quantiles []float64              `protobuf:"fixed64,5,rep,packed,name=quantiles,proto3" json:"quantiles,omitempty"`
	Ts        *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=ts,proto3,oneof" json:"ts,omitempty"`
	// contains filtered or unexported fields
}

type AsyncSearchStatus int32

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

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

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

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

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

type ErrorCode int32

type Event struct {
	Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	Id   string                 `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// The values of this map is JSON.
	// For example, the data can be:
	// message: "ok google";
	// errorKind: { "kind": "NotFound", "code": "404" };
	// status: 404;
	Data map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ExportFormat int32

type ExportRequest struct {
	Query  string                 `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // query for SeqDB in key:value format
	From   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	To     *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
	Limit  int32                  `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset int32                  `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
	Format ExportFormat           `protobuf:"varint,6,opt,name=format,proto3,enum=seqapi.v1.ExportFormat" json:"format,omitempty"`
	Fields []string               `protobuf:"bytes,7,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

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

type FetchAsyncSearchResultResponse struct {
	Status     AsyncSearchStatus        `protobuf:"varint,1,opt,name=status,proto3,enum=seqapi.v1.AsyncSearchStatus" json:"status,omitempty"`
	Request    *StartAsyncSearchRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	Response   *SearchResponse          `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"`
	Progress   float64                  `protobuf:"fixed64,7,opt,name=progress,proto3" json:"progress,omitempty"`
	DiskUsage  uint64                   `protobuf:"varint,8,opt,name=disk_usage,json=diskUsage,proto3" json:"disk_usage,omitempty"`
	Meta       string                   `protobuf:"bytes,9,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

type Field struct {
	Name string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type FieldType `protobuf:"varint,2,opt,name=type,proto3,enum=seqapi.v1.FieldType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

type FieldType int32

type GetAggregationRequest struct {
	Query string                 `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	From  *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	To    *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
	// Deprecated: Marked as deprecated in seqapi/v1/seq_api.proto.
	AggField     string              `protobuf:"bytes,4,opt,name=agg_field,json=aggField,proto3" json:"agg_field,omitempty"`
	Aggregations []*AggregationQuery `protobuf:"bytes,5,rep,name=aggregations,proto3" json:"aggregations,omitempty"`
	// contains filtered or unexported fields
}

type GetAggregationResponse struct {

	// Deprecated: Marked as deprecated in seqapi/v1/seq_api.proto.
	Aggregation *Aggregation `protobuf:"bytes,1,opt,name=aggregation,proto3" json:"aggregation,omitempty"`
	// Deprecated: Marked as deprecated in seqapi/v1/seq_api.proto.
	PartialResponse bool           `protobuf:"varint,2,opt,name=partial_response,json=partialResponse,proto3" json:"partial_response,omitempty"`
	Aggregations    []*Aggregation `protobuf:"bytes,3,rep,name=aggregations,proto3" json:"aggregations,omitempty"`
	Error           *Error         `protobuf:"bytes,4,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type GetAsyncSearchesListRequest struct {
	Status    *AsyncSearchStatus `protobuf:"varint,1,opt,name=status,proto3,enum=seqapi.v1.AsyncSearchStatus,oneof" json:"status,omitempty"`
	Limit     int32              `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset    int32              `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	OwnerName *string            `protobuf:"bytes,4,opt,name=owner_name,json=ownerName,proto3,oneof" json:"owner_name,omitempty"`
	// contains filtered or unexported fields
}

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

type GetAsyncSearchesListResponse_ListItem 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=seqapi.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"`
	Progress   float64                  `protobuf:"fixed64,7,opt,name=progress,proto3" json:"progress,omitempty"`
	DiskUsage  uint64                   `protobuf:"varint,8,opt,name=disk_usage,json=diskUsage,proto3" json:"disk_usage,omitempty"`
	OwnerName  string                   `protobuf:"bytes,9,opt,name=owner_name,json=ownerName,proto3" json:"owner_name,omitempty"`
	Error      *string                  `protobuf:"bytes,10,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

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

type GetEventResponse struct {
	Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

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

type GetFieldsResponse struct {
	Fields []*Field `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

type GetHistogramRequest struct {
	Query    string                 `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Interval string                 `protobuf:"bytes,2,opt,name=interval,proto3" json:"interval,omitempty"`
	From     *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"`
	To       *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

type GetHistogramResponse struct {
	Histogram *Histogram `protobuf:"bytes,1,opt,name=histogram,proto3" json:"histogram,omitempty"`
	// Deprecated: Marked as deprecated in seqapi/v1/seq_api.proto.
	PartialResponse bool   `protobuf:"varint,2,opt,name=partial_response,json=partialResponse,proto3" json:"partial_response,omitempty"`
	Error           *Error `protobuf:"bytes,3,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

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

type GetLimitsResponse struct {
	MaxSearchLimit            int32 `protobuf:"varint,1,opt,name=max_search_limit,json=maxSearchLimit,proto3" json:"max_search_limit,omitempty"`
	MaxExportLimit            int32 `protobuf:"varint,2,opt,name=max_export_limit,json=maxExportLimit,proto3" json:"max_export_limit,omitempty"`
	MaxParallelExportRequests int32 `` /* 141-byte string literal not displayed */
	MaxAggregationsPerRequest int32 `` /* 141-byte string literal not displayed */
	SeqCliMaxSearchLimit      int32 `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

type GetLogsLifespanResponse struct {
	Lifespan *durationpb.Duration `protobuf:"bytes,1,opt,name=lifespan,proto3" json:"lifespan,omitempty"`
	// contains filtered or unexported fields
}

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

type Histogram_Bucket struct {
	DocCount uint64 `protobuf:"varint,1,opt,name=doc_count,json=docCount,proto3" json:"doc_count,omitempty"`
	Key      uint64 `protobuf:"varint,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type Order int32

type SearchRequest struct {
	Query        string                   `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // query for SeqDB in key:value format
	From         *timestamppb.Timestamp   `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	To           *timestamppb.Timestamp   `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
	Limit        int32                    `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset       int32                    `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
	Histogram    *SearchRequest_Histogram `protobuf:"bytes,6,opt,name=histogram,proto3,oneof" json:"histogram,omitempty"`
	WithTotal    bool                     `protobuf:"varint,7,opt,name=with_total,json=withTotal,proto3" json:"with_total,omitempty"`
	Aggregations []*AggregationQuery      `protobuf:"bytes,8,rep,name=aggregations,proto3" json:"aggregations,omitempty"`
	Order        Order                    `protobuf:"varint,9,opt,name=order,proto3,enum=seqapi.v1.Order" json:"order,omitempty"`
	// contains filtered or unexported fields
}

type SearchRequest_Histogram struct {
	Interval string `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

type SearchResponse struct {
	Events    []*Event   `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	Total     int64      `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	Histogram *Histogram `protobuf:"bytes,3,opt,name=histogram,proto3,oneof" json:"histogram,omitempty"`
	// Deprecated: Marked as deprecated in seqapi/v1/seq_api.proto.
	PartialResponse bool           `protobuf:"varint,4,opt,name=partial_response,json=partialResponse,proto3" json:"partial_response,omitempty"`
	Aggregations    []*Aggregation `protobuf:"bytes,5,rep,name=aggregations,proto3" json:"aggregations,omitempty"`
	Error           *Error         `protobuf:"bytes,6,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type SeqAPIServiceClient interface {
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
	GetEvent(ctx context.Context, in *GetEventRequest, opts ...grpc.CallOption) (*GetEventResponse, error)
	GetHistogram(ctx context.Context, in *GetHistogramRequest, opts ...grpc.CallOption) (*GetHistogramResponse, error)
	GetAggregation(ctx context.Context, in *GetAggregationRequest, opts ...grpc.CallOption) (*GetAggregationResponse, error)
	GetFields(ctx context.Context, in *GetFieldsRequest, opts ...grpc.CallOption) (*GetFieldsResponse, error)
	GetPinnedFields(ctx context.Context, in *GetFieldsRequest, opts ...grpc.CallOption) (*GetFieldsResponse, error)
	GetLimits(ctx context.Context, in *GetLimitsRequest, opts ...grpc.CallOption) (*GetLimitsResponse, error)
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	GetLogsLifespan(ctx context.Context, in *GetLogsLifespanRequest, opts ...grpc.CallOption) (*GetLogsLifespanResponse, error)
	StartAsyncSearch(ctx context.Context, in *StartAsyncSearchRequest, opts ...grpc.CallOption) (*StartAsyncSearchResponse, error)
	FetchAsyncSearchResult(ctx context.Context, in *FetchAsyncSearchResultRequest, opts ...grpc.CallOption) (*FetchAsyncSearchResultResponse, error)
	GetAsyncSearchesList(ctx context.Context, in *GetAsyncSearchesListRequest, opts ...grpc.CallOption) (*GetAsyncSearchesListResponse, error)
	CancelAsyncSearch(ctx context.Context, in *CancelAsyncSearchRequest, opts ...grpc.CallOption) (*CancelAsyncSearchResponse, error)
	DeleteAsyncSearch(ctx context.Context, in *DeleteAsyncSearchRequest, opts ...grpc.CallOption) (*DeleteAsyncSearchResponse, error)
}

type SeqAPIServiceServer interface {
	Search(context.Context, *SearchRequest) (*SearchResponse, error)
	GetEvent(context.Context, *GetEventRequest) (*GetEventResponse, error)
	GetHistogram(context.Context, *GetHistogramRequest) (*GetHistogramResponse, error)
	GetAggregation(context.Context, *GetAggregationRequest) (*GetAggregationResponse, error)
	GetFields(context.Context, *GetFieldsRequest) (*GetFieldsResponse, error)
	GetPinnedFields(context.Context, *GetFieldsRequest) (*GetFieldsResponse, error)
	GetLimits(context.Context, *GetLimitsRequest) (*GetLimitsResponse, error)
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	GetLogsLifespan(context.Context, *GetLogsLifespanRequest) (*GetLogsLifespanResponse, error)
	StartAsyncSearch(context.Context, *StartAsyncSearchRequest) (*StartAsyncSearchResponse, error)
	FetchAsyncSearchResult(context.Context, *FetchAsyncSearchResultRequest) (*FetchAsyncSearchResultResponse, error)
	GetAsyncSearchesList(context.Context, *GetAsyncSearchesListRequest) (*GetAsyncSearchesListResponse, error)
	CancelAsyncSearch(context.Context, *CancelAsyncSearchRequest) (*CancelAsyncSearchResponse, error)
	DeleteAsyncSearch(context.Context, *DeleteAsyncSearchRequest) (*DeleteAsyncSearchResponse, error)
}

type StartAsyncSearchRequest struct {
	Retention *durationpb.Duration               `protobuf:"bytes,1,opt,name=retention,proto3" json:"retention,omitempty"`
	Query     string                             `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	From      *timestamppb.Timestamp             `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"`
	To        *timestamppb.Timestamp             `protobuf:"bytes,4,opt,name=to,proto3" json:"to,omitempty"`
	Aggs      []*AggregationQuery                `protobuf:"bytes,5,rep,name=aggs,proto3" json:"aggs,omitempty"`
	Hist      *StartAsyncSearchRequest_HistQuery `protobuf:"bytes,6,opt,name=hist,proto3,oneof" json:"hist,omitempty"`
	WithDocs  bool                               `protobuf:"varint,7,opt,name=with_docs,json=withDocs,proto3" json:"with_docs,omitempty"`
	Size      int32                              `protobuf:"varint,8,opt,name=size,proto3" json:"size,omitempty"`
	Meta      string                             `protobuf:"bytes,9,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

type StartAsyncSearchRequest_HistQuery struct {
	Interval string `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

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

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

type StatusResponse struct {
	NumberOfStores    int32                  `protobuf:"varint,1,opt,name=number_of_stores,json=numberOfStores,proto3" json:"number_of_stores,omitempty"`
	OldestStorageTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=oldest_storage_time,json=oldestStorageTime,proto3,oneof" json:"oldest_storage_time,omitempty"`
	Stores            []*StoreStatus         `protobuf:"bytes,4,rep,name=stores,proto3" json:"stores,omitempty"`
	// contains filtered or unexported fields
}

type StoreStatus struct {
	Host   string             `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Values *StoreStatusValues `protobuf:"bytes,2,opt,name=values,proto3,oneof" json:"values,omitempty"`
	Error  *string            `protobuf:"bytes,3,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

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

type UnimplementedSeqAPIServiceServer struct {
}

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