query

package
v0.0.0-...-28787c5 Latest Latest
Warning

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

 Go to latest Published: Mar 26, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package query is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	OrderBy_name = map[int32]string{
		0: "ASC",
		1: "DESC",
	}
	OrderBy_value = map[string]int32{
		"ASC":  0,
		"DESC": 1,
	}
)

Enum value maps for OrderBy.

View Source 
var (
	QueryType_name = map[int32]string{
		0: "Search",
		1: "Fetch",
		2: "AdvanceSearch",
		3: "Report",
	}
	QueryType_value = map[string]int32{
		"Search":        0,
		"Fetch":         1,
		"AdvanceSearch": 2,
		"Report":        3,
	}
)

Enum value maps for QueryType.

View Source 
var File_api_proto_query_proto protoreflect.FileDescriptor

Functions

func RegisterQueryServiceHandler 

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

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

func RegisterQueryServiceHandlerClient 

func RegisterQueryServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryServiceClient) error

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

func RegisterQueryServiceHandlerFromEndpoint 

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

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

func RegisterQueryServiceHandlerServer 

func RegisterQueryServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServiceServer) error

RegisterQueryServiceHandlerServer registers the http handlers for service QueryService to "mux". UnaryRPC :call QueryServiceServer 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 RegisterQueryServiceHandlerFromEndpoint instead.

func RegisterQueryServiceServer 

func RegisterQueryServiceServer(s *grpc.Server, srv QueryServiceServer)

Types

type CancelQueryRequest 

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

func (*CancelQueryRequest) Descriptor deprecated 

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

Deprecated: Use CancelQueryRequest.ProtoReflect.Descriptor instead.

func (*CancelQueryRequest) GetQueryId 

func (x *CancelQueryRequest) GetQueryId() string

func (*CancelQueryRequest) ProtoMessage 

func (*CancelQueryRequest) ProtoMessage()

func (*CancelQueryRequest) ProtoReflect 

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

func (*CancelQueryRequest) Reset 

func (x *CancelQueryRequest) Reset()

func (*CancelQueryRequest) String 

func (x *CancelQueryRequest) String() string

type Facet 

type Facet struct {
	Key    string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*Facet) Descriptor deprecated 

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

Deprecated: Use Facet.ProtoReflect.Descriptor instead.

func (*Facet) GetKey 

func (x *Facet) GetKey() string

func (*Facet) GetValues 

func (x *Facet) GetValues() []string

func (*Facet) ProtoMessage 

func (*Facet) ProtoMessage()

func (*Facet) ProtoReflect 

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

func (*Facet) Reset 

func (x *Facet) Reset()

func (*Facet) String 

func (x *Facet) String() string

type FacetValues 

type FacetValues struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*FacetValues) Descriptor deprecated 

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

Deprecated: Use FacetValues.ProtoReflect.Descriptor instead.

func (*FacetValues) GetValues 

func (x *FacetValues) GetValues() []string

func (*FacetValues) ProtoMessage 

func (*FacetValues) ProtoMessage()

func (*FacetValues) ProtoReflect 

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

func (*FacetValues) Reset 

func (x *FacetValues) Reset()

func (*FacetValues) String 

func (x *FacetValues) String() string

type FilterValues 

type FilterValues struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterValues) Descriptor deprecated 

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

Deprecated: Use FilterValues.ProtoReflect.Descriptor instead.

func (*FilterValues) GetValues 

func (x *FilterValues) GetValues() []string

func (*FilterValues) ProtoMessage 

func (*FilterValues) ProtoMessage()

func (*FilterValues) ProtoReflect 

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

func (*FilterValues) Reset 

func (x *FilterValues) Reset()

func (*FilterValues) String 

func (x *FilterValues) String() string

type GetDataRequest 

type GetDataRequest struct {
	QueryId string   `protobuf:"bytes,1,opt,name=queryId,proto3" json:"queryId,omitempty"`
	Facets  []*Facet `protobuf:"bytes,2,rep,name=facets,proto3" json:"facets,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDataRequest) Descriptor deprecated 

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

Deprecated: Use GetDataRequest.ProtoReflect.Descriptor instead.

func (*GetDataRequest) GetFacets 

func (x *GetDataRequest) GetFacets() []*Facet

func (*GetDataRequest) GetQueryId 

func (x *GetDataRequest) GetQueryId() string

func (*GetDataRequest) ProtoMessage 

func (*GetDataRequest) ProtoMessage()

func (*GetDataRequest) ProtoReflect 

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

func (*GetDataRequest) Reset 

func (x *GetDataRequest) Reset()

func (*GetDataRequest) String 

func (x *GetDataRequest) String() string

type GetDataResponse 

type GetDataResponse struct {
	Data             []*SysLogMessage `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	Status           string           `protobuf:"bytes,2,opt,name=Status,proto3" json:"Status,omitempty"`
	Remaining        int32            `protobuf:"varint,3,opt,name=remaining,proto3" json:"remaining,omitempty"`
	Facets           []*Facet         `protobuf:"bytes,4,rep,name=facets,proto3" json:"facets,omitempty"`
	Percent          *Progress        `protobuf:"bytes,6,opt,name=percent,proto3" json:"percent,omitempty"`
	Size             *Progress        `protobuf:"bytes,7,opt,name=size,proto3" json:"size,omitempty"`
	ResponsePageSize int32            `protobuf:"varint,8,opt,name=responsePageSize,proto3" json:"responsePageSize,omitempty"`
	Patterns         []*Patterns      `protobuf:"bytes,9,rep,name=patterns,proto3" json:"patterns,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDataResponse) Descriptor deprecated 

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

Deprecated: Use GetDataResponse.ProtoReflect.Descriptor instead.

func (*GetDataResponse) GetData 

func (x *GetDataResponse) GetData() []*SysLogMessage

func (*GetDataResponse) GetFacets 

func (x *GetDataResponse) GetFacets() []*Facet

func (*GetDataResponse) GetPatterns 

func (x *GetDataResponse) GetPatterns() []*Patterns

func (*GetDataResponse) GetPercent 

func (x *GetDataResponse) GetPercent() *Progress

func (*GetDataResponse) GetRemaining 

func (x *GetDataResponse) GetRemaining() int32

func (*GetDataResponse) GetResponsePageSize 

func (x *GetDataResponse) GetResponsePageSize() int32

func (*GetDataResponse) GetSize 

func (x *GetDataResponse) GetSize() *Progress

func (*GetDataResponse) GetStatus 

func (x *GetDataResponse) GetStatus() string

func (*GetDataResponse) ProtoMessage 

func (*GetDataResponse) ProtoMessage()

func (*GetDataResponse) ProtoReflect 

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

func (*GetDataResponse) Reset 

func (x *GetDataResponse) Reset()

func (*GetDataResponse) String 

func (x *GetDataResponse) String() string

type GetMessagesRequest 

type GetMessagesRequest struct {
	QueryId string   `protobuf:"bytes,1,opt,name=queryId,proto3" json:"queryId,omitempty"`
	MsgIds  []string `protobuf:"bytes,2,rep,name=msgIds,proto3" json:"msgIds,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMessagesRequest) Descriptor deprecated 

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

Deprecated: Use GetMessagesRequest.ProtoReflect.Descriptor instead.

func (*GetMessagesRequest) GetMsgIds 

func (x *GetMessagesRequest) GetMsgIds() []string

func (*GetMessagesRequest) GetQueryId 

func (x *GetMessagesRequest) GetQueryId() string

func (*GetMessagesRequest) ProtoMessage 

func (*GetMessagesRequest) ProtoMessage()

func (*GetMessagesRequest) ProtoReflect 

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

func (*GetMessagesRequest) Reset 

func (x *GetMessagesRequest) Reset()

func (*GetMessagesRequest) String 

func (x *GetMessagesRequest) String() string

type GetMessagesResponse 

type GetMessagesResponse struct {
	Data []*SysLogMessage `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMessagesResponse) Descriptor deprecated 

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

Deprecated: Use GetMessagesResponse.ProtoReflect.Descriptor instead.

func (*GetMessagesResponse) GetData 

func (x *GetMessagesResponse) GetData() []*SysLogMessage

func (*GetMessagesResponse) ProtoMessage 

func (*GetMessagesResponse) ProtoMessage()

func (*GetMessagesResponse) ProtoReflect 

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

func (*GetMessagesResponse) Reset 

func (x *GetMessagesResponse) Reset()

func (*GetMessagesResponse) String 

func (x *GetMessagesResponse) String() string

type GetPatternResponse 

type GetPatternResponse struct {
	Data  []*Pattern `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	MinTs int64      `protobuf:"varint,2,opt,name=minTs,proto3" json:"minTs,omitempty"`
	MaxTs int64      `protobuf:"varint,3,opt,name=maxTs,proto3" json:"maxTs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPatternResponse) Descriptor deprecated 

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

Deprecated: Use GetPatternResponse.ProtoReflect.Descriptor instead.

func (*GetPatternResponse) GetData 

func (x *GetPatternResponse) GetData() []*Pattern

func (*GetPatternResponse) GetMaxTs 

func (x *GetPatternResponse) GetMaxTs() int64

func (*GetPatternResponse) GetMinTs 

func (x *GetPatternResponse) GetMinTs() int64

func (*GetPatternResponse) ProtoMessage 

func (*GetPatternResponse) ProtoMessage()

func (*GetPatternResponse) ProtoReflect 

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

func (*GetPatternResponse) Reset 

func (x *GetPatternResponse) Reset()

func (*GetPatternResponse) String 

func (x *GetPatternResponse) String() string

type GetPatternsRequest 

type GetPatternsRequest struct {
	QueryId string  `protobuf:"bytes,1,opt,name=queryId,proto3" json:"queryId,omitempty"`
	Order   OrderBy `protobuf:"varint,2,opt,name=order,proto3,enum=query.OrderBy" json:"order,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPatternsRequest) Descriptor deprecated 

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

Deprecated: Use GetPatternsRequest.ProtoReflect.Descriptor instead.

func (*GetPatternsRequest) GetOrder 

func (x *GetPatternsRequest) GetOrder() OrderBy

func (*GetPatternsRequest) GetQueryId 

func (x *GetPatternsRequest) GetQueryId() string

func (*GetPatternsRequest) ProtoMessage 

func (*GetPatternsRequest) ProtoMessage()

func (*GetPatternsRequest) ProtoReflect 

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

func (*GetPatternsRequest) Reset 

func (x *GetPatternsRequest) Reset()

func (*GetPatternsRequest) String 

func (x *GetPatternsRequest) String() string

type GetQueryByIdResponse 

type GetQueryByIdResponse struct {
	Namespace        string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ApplicationNames []string `protobuf:"bytes,2,rep,name=applicationNames,proto3" json:"applicationNames,omitempty"`
	StartTime        int64    `protobuf:"varint,3,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime          int64    `protobuf:"varint,4,opt,name=endTime,proto3" json:"endTime,omitempty"`
	KeyWord          string   `protobuf:"bytes,5,opt,name=keyWord,proto3" json:"keyWord,omitempty"`
	IsAdvanceQuery   bool     `protobuf:"varint,6,opt,name=isAdvanceQuery,proto3" json:"isAdvanceQuery,omitempty"`
	// contains filtered or unexported fields
}

func (*GetQueryByIdResponse) Descriptor deprecated 

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

Deprecated: Use GetQueryByIdResponse.ProtoReflect.Descriptor instead.

func (*GetQueryByIdResponse) GetApplicationNames 

func (x *GetQueryByIdResponse) GetApplicationNames() []string

func (*GetQueryByIdResponse) GetEndTime 

func (x *GetQueryByIdResponse) GetEndTime() int64

func (*GetQueryByIdResponse) GetIsAdvanceQuery 

func (x *GetQueryByIdResponse) GetIsAdvanceQuery() bool

func (*GetQueryByIdResponse) GetKeyWord 

func (x *GetQueryByIdResponse) GetKeyWord() string

func (*GetQueryByIdResponse) GetNamespace 

func (x *GetQueryByIdResponse) GetNamespace() string

func (*GetQueryByIdResponse) GetStartTime 

func (x *GetQueryByIdResponse) GetStartTime() int64

func (*GetQueryByIdResponse) ProtoMessage 

func (*GetQueryByIdResponse) ProtoMessage()

func (*GetQueryByIdResponse) ProtoReflect 

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

func (*GetQueryByIdResponse) Reset 

func (x *GetQueryByIdResponse) Reset()

func (*GetQueryByIdResponse) String 

func (x *GetQueryByIdResponse) String() string

type GetQueryResponse 

type GetQueryResponse struct {
	QueryId string            `protobuf:"bytes,1,opt,name=queryId,proto3" json:"queryId,omitempty"`
	Info    []*QueryInfo      `protobuf:"bytes,3,rep,name=info,proto3" json:"info,omitempty"`
	Errors  []*QueryErrors    `protobuf:"bytes,4,rep,name=errors,proto3" json:"errors,omitempty"`
	Meta    map[string]string `` /* 149-byte string literal not displayed */
	Details string            `protobuf:"bytes,6,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*GetQueryResponse) Descriptor deprecated 

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

Deprecated: Use GetQueryResponse.ProtoReflect.Descriptor instead.

func (*GetQueryResponse) GetDetails 

func (x *GetQueryResponse) GetDetails() string

func (*GetQueryResponse) GetErrors 

func (x *GetQueryResponse) GetErrors() []*QueryErrors

func (*GetQueryResponse) GetInfo 

func (x *GetQueryResponse) GetInfo() []*QueryInfo

func (*GetQueryResponse) GetMeta 

func (x *GetQueryResponse) GetMeta() map[string]string

func (*GetQueryResponse) GetQueryId 

func (x *GetQueryResponse) GetQueryId() string

func (*GetQueryResponse) ProtoMessage 

func (*GetQueryResponse) ProtoMessage()

func (*GetQueryResponse) ProtoReflect 

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

func (*GetQueryResponse) Reset 

func (x *GetQueryResponse) Reset()

func (*GetQueryResponse) String 

func (x *GetQueryResponse) String() string

type GetReportRequest 

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

func (*GetReportRequest) Descriptor deprecated 

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

Deprecated: Use GetReportRequest.ProtoReflect.Descriptor instead.

func (*GetReportRequest) GetQueryId 

func (x *GetReportRequest) GetQueryId() string

func (*GetReportRequest) ProtoMessage 

func (*GetReportRequest) ProtoMessage()

func (*GetReportRequest) ProtoReflect 

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

func (*GetReportRequest) Reset 

func (x *GetReportRequest) Reset()

func (*GetReportRequest) String 

func (x *GetReportRequest) String() string

type GetReportResponse 

type GetReportResponse struct {
	QueryId string          `protobuf:"bytes,1,opt,name=queryId,proto3" json:"queryId,omitempty"`
	Status  string          `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Results []*ReportResult `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	Percent *Progress       `protobuf:"bytes,4,opt,name=percent,proto3" json:"percent,omitempty"`
	Size    *Progress       `protobuf:"bytes,5,opt,name=size,proto3" json:"size,omitempty"`
	Url     string          `protobuf:"bytes,6,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*GetReportResponse) Descriptor deprecated 

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

Deprecated: Use GetReportResponse.ProtoReflect.Descriptor instead.

func (*GetReportResponse) GetPercent 

func (x *GetReportResponse) GetPercent() *Progress

func (*GetReportResponse) GetQueryId 

func (x *GetReportResponse) GetQueryId() string

func (*GetReportResponse) GetResults 

func (x *GetReportResponse) GetResults() []*ReportResult

func (*GetReportResponse) GetSize 

func (x *GetReportResponse) GetSize() *Progress

func (*GetReportResponse) GetStatus 

func (x *GetReportResponse) GetStatus() string

func (*GetReportResponse) GetUrl 

func (x *GetReportResponse) GetUrl() string

func (*GetReportResponse) ProtoMessage 

func (*GetReportResponse) ProtoMessage()

func (*GetReportResponse) ProtoReflect 

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

func (*GetReportResponse) Reset 

func (x *GetReportResponse) Reset()

func (*GetReportResponse) String 

func (x *GetReportResponse) String() string

type OrderBy 

type OrderBy int32
const (
	OrderBy_ASC  OrderBy = 0
	OrderBy_DESC OrderBy = 1
)

func (OrderBy) Descriptor 

func (OrderBy) Descriptor() protoreflect.EnumDescriptor

func (OrderBy) Enum 

func (x OrderBy) Enum() *OrderBy

func (OrderBy) EnumDescriptor deprecated 

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

Deprecated: Use OrderBy.Descriptor instead.

func (OrderBy) Number 

func (x OrderBy) Number() protoreflect.EnumNumber

func (OrderBy) String 

func (x OrderBy) String() string

func (OrderBy) Type 

func (OrderBy) Type() protoreflect.EnumType

type Pattern 

type Pattern struct {
	PatternId string `protobuf:"bytes,1,opt,name=patternId,proto3" json:"patternId,omitempty"`
	Ts        int64  `protobuf:"varint,2,opt,name=ts,proto3" json:"ts,omitempty"`
	MsgId     string `protobuf:"bytes,3,opt,name=msgId,proto3" json:"msgId,omitempty"`
	// contains filtered or unexported fields
}

func (*Pattern) Descriptor deprecated 

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

Deprecated: Use Pattern.ProtoReflect.Descriptor instead.

func (*Pattern) GetMsgId 

func (x *Pattern) GetMsgId() string

func (*Pattern) GetPatternId 

func (x *Pattern) GetPatternId() string

func (*Pattern) GetTs 

func (x *Pattern) GetTs() int64

func (*Pattern) ProtoMessage 

func (*Pattern) ProtoMessage()

func (*Pattern) ProtoReflect 

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

func (*Pattern) Reset 

func (x *Pattern) Reset()

func (*Pattern) String 

func (x *Pattern) String() string

type Patterns 

type Patterns struct {
	PatternId string `protobuf:"bytes,1,opt,name=patternId,proto3" json:"patternId,omitempty"`
	Count     int64  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Desc      string `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"`
	// contains filtered or unexported fields
}

func (*Patterns) Descriptor deprecated 

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

Deprecated: Use Patterns.ProtoReflect.Descriptor instead.

func (*Patterns) GetCount 

func (x *Patterns) GetCount() int64

func (*Patterns) GetDesc 

func (x *Patterns) GetDesc() string

func (*Patterns) GetPatternId 

func (x *Patterns) GetPatternId() string

func (*Patterns) ProtoMessage 

func (*Patterns) ProtoMessage()

func (*Patterns) ProtoReflect 

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

func (*Patterns) Reset 

func (x *Patterns) Reset()

func (*Patterns) String 

func (x *Patterns) String() string

type Progress 

type Progress struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	OutOf string `protobuf:"bytes,2,opt,name=outOf,proto3" json:"outOf,omitempty"`
	Type  string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Progress) Descriptor deprecated 

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

Deprecated: Use Progress.ProtoReflect.Descriptor instead.

func (*Progress) GetOutOf 

func (x *Progress) GetOutOf() string

func (*Progress) GetType 

func (x *Progress) GetType() string

func (*Progress) GetValue 

func (x *Progress) GetValue() string

func (*Progress) ProtoMessage 

func (*Progress) ProtoMessage()

func (*Progress) ProtoReflect 

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

func (*Progress) Reset 

func (x *Progress) Reset()

func (*Progress) String 

func (x *Progress) String() string

type QueryErrors 

type QueryErrors struct {
	Key     string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryErrors) Descriptor deprecated 

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

Deprecated: Use QueryErrors.ProtoReflect.Descriptor instead.

func (*QueryErrors) GetKey 

func (x *QueryErrors) GetKey() string

func (*QueryErrors) GetMessage 

func (x *QueryErrors) GetMessage() string

func (*QueryErrors) ProtoMessage 

func (*QueryErrors) ProtoMessage()

func (*QueryErrors) ProtoReflect 

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

func (*QueryErrors) Reset 

func (x *QueryErrors) Reset()

func (*QueryErrors) String 

func (x *QueryErrors) String() string

type QueryInfo 

type QueryInfo struct {
	Key     string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryInfo) Descriptor deprecated 

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

Deprecated: Use QueryInfo.ProtoReflect.Descriptor instead.

func (*QueryInfo) GetKey 

func (x *QueryInfo) GetKey() string

func (*QueryInfo) GetMessage 

func (x *QueryInfo) GetMessage() string

func (*QueryInfo) ProtoMessage 

func (*QueryInfo) ProtoMessage()

func (*QueryInfo) ProtoReflect 

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

func (*QueryInfo) Reset 

func (x *QueryInfo) Reset()

func (*QueryInfo) String 

func (x *QueryInfo) String() string

type QueryProperties 

type QueryProperties struct {
	ApplicationNames []string                 `protobuf:"bytes,1,rep,name=applicationNames,proto3" json:"applicationNames,omitempty"`
	Filters          map[string]*FilterValues `` /* 155-byte string literal not displayed */
	Namespace        string                   `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Order            OrderBy                  `protobuf:"varint,4,opt,name=order,proto3,enum=query.OrderBy" json:"order,omitempty"`
	PageSize         uint32                   `protobuf:"varint,6,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	StartTime        string                   `protobuf:"bytes,7,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime          string                   `protobuf:"bytes,8,opt,name=endTime,proto3" json:"endTime,omitempty"`
	KeyWord          string                   `protobuf:"bytes,9,opt,name=keyWord,proto3" json:"keyWord,omitempty"`
	Destination      string                   `protobuf:"bytes,10,opt,name=destination,proto3" json:"destination,omitempty"`
	Facets           bool                     `protobuf:"varint,11,opt,name=facets,proto3" json:"facets,omitempty"`
	QType            QueryType                `protobuf:"varint,12,opt,name=qType,proto3,enum=query.QueryType" json:"qType,omitempty"`
	Patterns         bool                     `protobuf:"varint,13,opt,name=patterns,proto3" json:"patterns,omitempty"`
	IsAdvanceQuery   bool                     `protobuf:"varint,14,opt,name=isAdvanceQuery,proto3" json:"isAdvanceQuery,omitempty"`
	ReportDefinition string                   `protobuf:"bytes,15,opt,name=reportDefinition,proto3" json:"reportDefinition,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryProperties) Descriptor deprecated 

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

Deprecated: Use QueryProperties.ProtoReflect.Descriptor instead.

func (*QueryProperties) GetApplicationNames 

func (x *QueryProperties) GetApplicationNames() []string

func (*QueryProperties) GetDestination 

func (x *QueryProperties) GetDestination() string

func (*QueryProperties) GetEndTime 

func (x *QueryProperties) GetEndTime() string

func (*QueryProperties) GetFacets 

func (x *QueryProperties) GetFacets() bool

func (*QueryProperties) GetFilters 

func (x *QueryProperties) GetFilters() map[string]*FilterValues

func (*QueryProperties) GetIsAdvanceQuery 

func (x *QueryProperties) GetIsAdvanceQuery() bool

func (*QueryProperties) GetKeyWord 

func (x *QueryProperties) GetKeyWord() string

func (*QueryProperties) GetNamespace 

func (x *QueryProperties) GetNamespace() string

func (*QueryProperties) GetOrder 

func (x *QueryProperties) GetOrder() OrderBy

func (*QueryProperties) GetPageSize 

func (x *QueryProperties) GetPageSize() uint32

func (*QueryProperties) GetPatterns 

func (x *QueryProperties) GetPatterns() bool

func (*QueryProperties) GetQType 

func (x *QueryProperties) GetQType() QueryType

func (*QueryProperties) GetReportDefinition 

func (x *QueryProperties) GetReportDefinition() string

func (*QueryProperties) GetStartTime 

func (x *QueryProperties) GetStartTime() string

func (*QueryProperties) ProtoMessage 

func (*QueryProperties) ProtoMessage()

func (*QueryProperties) ProtoReflect 

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

func (*QueryProperties) Reset 

func (x *QueryProperties) Reset()

func (*QueryProperties) String 

func (x *QueryProperties) String() string

type QueryServiceClient 

type QueryServiceClient interface {
	Query(ctx context.Context, in *QueryProperties, opts ...grpc.CallOption) (*GetQueryResponse, error)
	GetDataNext(ctx context.Context, in *GetDataRequest, opts ...grpc.CallOption) (*GetDataResponse, error)
	GetDataPrevious(ctx context.Context, in *GetDataRequest, opts ...grpc.CallOption) (*GetDataResponse, error)
	PostDataNext(ctx context.Context, in *GetDataRequest, opts ...grpc.CallOption) (*GetDataResponse, error)
	PostDataPrevious(ctx context.Context, in *GetDataRequest, opts ...grpc.CallOption) (*GetDataResponse, error)
	GetPatternData(ctx context.Context, in *GetPatternsRequest, opts ...grpc.CallOption) (*GetPatternResponse, error)
	PostMessagesById(ctx context.Context, in *GetMessagesRequest, opts ...grpc.CallOption) (*GetMessagesResponse, error)
	GetReportResult(ctx context.Context, in *GetReportRequest, opts ...grpc.CallOption) (*GetReportResponse, error)
	CancelQuery(ctx context.Context, in *CancelQueryRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetSharedQueryDetailsById(ctx context.Context, in *SharedQueryRequest, opts ...grpc.CallOption) (*GetQueryByIdResponse, error)
	ShareQuery(ctx context.Context, in *SharedQueryRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

QueryServiceClient is the client API for QueryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryServiceClient 

func NewQueryServiceClient(cc grpc.ClientConnInterface) QueryServiceClient

type QueryServiceServer 

type QueryServiceServer interface {
	Query(context.Context, *QueryProperties) (*GetQueryResponse, error)
	GetDataNext(context.Context, *GetDataRequest) (*GetDataResponse, error)
	GetDataPrevious(context.Context, *GetDataRequest) (*GetDataResponse, error)
	PostDataNext(context.Context, *GetDataRequest) (*GetDataResponse, error)
	PostDataPrevious(context.Context, *GetDataRequest) (*GetDataResponse, error)
	GetPatternData(context.Context, *GetPatternsRequest) (*GetPatternResponse, error)
	PostMessagesById(context.Context, *GetMessagesRequest) (*GetMessagesResponse, error)
	GetReportResult(context.Context, *GetReportRequest) (*GetReportResponse, error)
	CancelQuery(context.Context, *CancelQueryRequest) (*emptypb.Empty, error)
	GetSharedQueryDetailsById(context.Context, *SharedQueryRequest) (*GetQueryByIdResponse, error)
	ShareQuery(context.Context, *SharedQueryRequest) (*emptypb.Empty, error)
}

QueryServiceServer is the server API for QueryService service.

type QueryType 

type QueryType int32
const (
	QueryType_Search        QueryType = 0
	QueryType_Fetch         QueryType = 1
	QueryType_AdvanceSearch QueryType = 2
	QueryType_Report        QueryType = 3
)

func (QueryType) Descriptor 

func (QueryType) Descriptor() protoreflect.EnumDescriptor

func (QueryType) Enum 

func (x QueryType) Enum() *QueryType

func (QueryType) EnumDescriptor deprecated 

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

Deprecated: Use QueryType.Descriptor instead.

func (QueryType) Number 

func (x QueryType) Number() protoreflect.EnumNumber

func (QueryType) String 

func (x QueryType) String() string

func (QueryType) Type 

func (QueryType) Type() protoreflect.EnumType

type ReportGroupBy 

type ReportGroupBy struct {
	Label string `protobuf:"bytes,1,opt,name=Label,proto3" json:"Label,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportGroupBy) Descriptor deprecated 

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

Deprecated: Use ReportGroupBy.ProtoReflect.Descriptor instead.

func (*ReportGroupBy) GetLabel 

func (x *ReportGroupBy) GetLabel() string

func (*ReportGroupBy) GetValue 

func (x *ReportGroupBy) GetValue() string

func (*ReportGroupBy) ProtoMessage 

func (*ReportGroupBy) ProtoMessage()

func (*ReportGroupBy) ProtoReflect 

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

func (*ReportGroupBy) Reset 

func (x *ReportGroupBy) Reset()

func (*ReportGroupBy) String 

func (x *ReportGroupBy) String() string

type ReportResult 

type ReportResult struct {
	TimeStamp string           `protobuf:"bytes,1,opt,name=timeStamp,proto3" json:"timeStamp,omitempty"`
	Value     string           `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	GroupBy   []*ReportGroupBy `protobuf:"bytes,3,rep,name=groupBy,proto3" json:"groupBy,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportResult) Descriptor deprecated 

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

Deprecated: Use ReportResult.ProtoReflect.Descriptor instead.

func (*ReportResult) GetGroupBy 

func (x *ReportResult) GetGroupBy() []*ReportGroupBy

func (*ReportResult) GetTimeStamp 

func (x *ReportResult) GetTimeStamp() string

func (*ReportResult) GetValue 

func (x *ReportResult) GetValue() string

func (*ReportResult) ProtoMessage 

func (*ReportResult) ProtoMessage()

func (*ReportResult) ProtoReflect 

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

func (*ReportResult) Reset 

func (x *ReportResult) Reset()

func (*ReportResult) String 

func (x *ReportResult) String() string

type SharedQueryRequest 

type SharedQueryRequest struct {
	QueryIds []string `protobuf:"bytes,1,rep,name=QueryIds,proto3" json:"QueryIds,omitempty"`
	// contains filtered or unexported fields
}

func (*SharedQueryRequest) Descriptor deprecated 

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

Deprecated: Use SharedQueryRequest.ProtoReflect.Descriptor instead.

func (*SharedQueryRequest) GetQueryIds 

func (x *SharedQueryRequest) GetQueryIds() []string

func (*SharedQueryRequest) ProtoMessage 

func (*SharedQueryRequest) ProtoMessage()

func (*SharedQueryRequest) ProtoReflect 

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

func (*SharedQueryRequest) Reset 

func (x *SharedQueryRequest) Reset()

func (*SharedQueryRequest) String 

func (x *SharedQueryRequest) String() string

type StructuredDataValues 

type StructuredDataValues struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*StructuredDataValues) Descriptor deprecated 

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

Deprecated: Use StructuredDataValues.ProtoReflect.Descriptor instead.

func (*StructuredDataValues) GetValues 

func (x *StructuredDataValues) GetValues() []string

func (*StructuredDataValues) ProtoMessage 

func (*StructuredDataValues) ProtoMessage()

func (*StructuredDataValues) ProtoReflect 

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

func (*StructuredDataValues) Reset 

func (x *StructuredDataValues) Reset()

func (*StructuredDataValues) String 

func (x *StructuredDataValues) String() string

type SysLogMessage 

type SysLogMessage struct {
	AppName        string   `protobuf:"bytes,2,opt,name=AppName,proto3" json:"AppName,omitempty"`
	Facility       string   `protobuf:"bytes,3,opt,name=Facility,proto3" json:"Facility,omitempty"`
	FacilityString string   `protobuf:"bytes,4,opt,name=FacilityString,proto3" json:"FacilityString,omitempty"`
	Hostname       string   `protobuf:"bytes,5,opt,name=Hostname,proto3" json:"Hostname,omitempty"`
	Message        string   `protobuf:"bytes,6,opt,name=Message,proto3" json:"Message,omitempty"`
	MsgID          string   `protobuf:"bytes,7,opt,name=MsgID,proto3" json:"MsgID,omitempty"`
	Priority       string   `protobuf:"bytes,9,opt,name=Priority,proto3" json:"Priority,omitempty"`
	ProcID         string   `protobuf:"bytes,10,opt,name=ProcID,proto3" json:"ProcID,omitempty"`
	Sender         string   `protobuf:"bytes,11,opt,name=Sender,proto3" json:"Sender,omitempty"`
	Severity       string   `protobuf:"bytes,12,opt,name=Severity,proto3" json:"Severity,omitempty"`
	SeverityString string   `protobuf:"bytes,13,opt,name=SeverityString,proto3" json:"SeverityString,omitempty"`
	StructuredData []*Facet `protobuf:"bytes,14,rep,name=StructuredData,proto3" json:"StructuredData,omitempty"`
	Tag            string   `protobuf:"bytes,15,opt,name=Tag,proto3" json:"Tag,omitempty"`
	Timestamp      string   `protobuf:"bytes,16,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Namespace      string   `protobuf:"bytes,17,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	Event          string   `protobuf:"bytes,18,opt,name=Event,proto3" json:"Event,omitempty"`
	EventId        string   `protobuf:"bytes,19,opt,name=EventId,proto3" json:"EventId,omitempty"`
	MsTimestamp    int64    `protobuf:"varint,20,opt,name=MsTimestamp,proto3" json:"MsTimestamp,omitempty"`
	STimestamp     int64    `protobuf:"varint,21,opt,name=STimestamp,proto3" json:"STimestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*SysLogMessage) Descriptor deprecated 

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

Deprecated: Use SysLogMessage.ProtoReflect.Descriptor instead.

func (*SysLogMessage) GetAppName 

func (x *SysLogMessage) GetAppName() string

func (*SysLogMessage) GetEvent 

func (x *SysLogMessage) GetEvent() string

func (*SysLogMessage) GetEventId 

func (x *SysLogMessage) GetEventId() string

func (*SysLogMessage) GetFacility 

func (x *SysLogMessage) GetFacility() string

func (*SysLogMessage) GetFacilityString 

func (x *SysLogMessage) GetFacilityString() string

func (*SysLogMessage) GetHostname 

func (x *SysLogMessage) GetHostname() string

func (*SysLogMessage) GetMessage 

func (x *SysLogMessage) GetMessage() string

func (*SysLogMessage) GetMsTimestamp 

func (x *SysLogMessage) GetMsTimestamp() int64

func (*SysLogMessage) GetMsgID 

func (x *SysLogMessage) GetMsgID() string

func (*SysLogMessage) GetNamespace 

func (x *SysLogMessage) GetNamespace() string

func (*SysLogMessage) GetPriority 

func (x *SysLogMessage) GetPriority() string

func (*SysLogMessage) GetProcID 

func (x *SysLogMessage) GetProcID() string

func (*SysLogMessage) GetSTimestamp 

func (x *SysLogMessage) GetSTimestamp() int64

func (*SysLogMessage) GetSender 

func (x *SysLogMessage) GetSender() string

func (*SysLogMessage) GetSeverity 

func (x *SysLogMessage) GetSeverity() string

func (*SysLogMessage) GetSeverityString 

func (x *SysLogMessage) GetSeverityString() string

func (*SysLogMessage) GetStructuredData 

func (x *SysLogMessage) GetStructuredData() []*Facet

func (*SysLogMessage) GetTag 

func (x *SysLogMessage) GetTag() string

func (*SysLogMessage) GetTimestamp 

func (x *SysLogMessage) GetTimestamp() string

func (*SysLogMessage) ProtoMessage 

func (*SysLogMessage) ProtoMessage()

func (*SysLogMessage) ProtoReflect 

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

func (*SysLogMessage) Reset 

func (x *SysLogMessage) Reset()

func (*SysLogMessage) String 

func (x *SysLogMessage) String() string

type UnimplementedQueryServiceServer 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServiceServer) CancelQuery 

func (*UnimplementedQueryServiceServer) CancelQuery(context.Context, *CancelQueryRequest) (*emptypb.Empty, error)

func (*UnimplementedQueryServiceServer) GetDataNext 

func (*UnimplementedQueryServiceServer) GetDataNext(context.Context, *GetDataRequest) (*GetDataResponse, error)

func (*UnimplementedQueryServiceServer) GetDataPrevious 

func (*UnimplementedQueryServiceServer) GetDataPrevious(context.Context, *GetDataRequest) (*GetDataResponse, error)

func (*UnimplementedQueryServiceServer) GetPatternData 

func (*UnimplementedQueryServiceServer) GetPatternData(context.Context, *GetPatternsRequest) (*GetPatternResponse, error)

func (*UnimplementedQueryServiceServer) GetReportResult 

func (*UnimplementedQueryServiceServer) GetReportResult(context.Context, *GetReportRequest) (*GetReportResponse, error)

func (*UnimplementedQueryServiceServer) GetSharedQueryDetailsById 

func (*UnimplementedQueryServiceServer) GetSharedQueryDetailsById(context.Context, *SharedQueryRequest) (*GetQueryByIdResponse, error)

func (*UnimplementedQueryServiceServer) PostDataNext 

func (*UnimplementedQueryServiceServer) PostDataNext(context.Context, *GetDataRequest) (*GetDataResponse, error)

func (*UnimplementedQueryServiceServer) PostDataPrevious 

func (*UnimplementedQueryServiceServer) PostDataPrevious(context.Context, *GetDataRequest) (*GetDataResponse, error)

func (*UnimplementedQueryServiceServer) PostMessagesById 

func (*UnimplementedQueryServiceServer) PostMessagesById(context.Context, *GetMessagesRequest) (*GetMessagesResponse, error)

func (*UnimplementedQueryServiceServer) Query 

func (*UnimplementedQueryServiceServer) Query(context.Context, *QueryProperties) (*GetQueryResponse, error)

func (*UnimplementedQueryServiceServer) ShareQuery 

func (*UnimplementedQueryServiceServer) ShareQuery(context.Context, *SharedQueryRequest) (*emptypb.Empty, error)

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.