protos

package
v0.0.0-...-0868fa3 Latest Latest
Warning

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

 Go to latest Published: Sep 14, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	LogType_name = map[int32]string{
		0: "UNKNOWN",
		1: "PROC_CREATE",
		2: "NET_CONNECT",
		3: "SHELL_LOG",
		4: "ACCESS_LOG",
		5: "ACCOUNT_CHANGE",
		6: "SCRIPT_EXEC",
		7: "DNS_ACCESS",
	}
	LogType_value = map[string]int32{
		"UNKNOWN":        0,
		"PROC_CREATE":    1,
		"NET_CONNECT":    2,
		"SHELL_LOG":      3,
		"ACCESS_LOG":     4,
		"ACCOUNT_CHANGE": 5,
		"SCRIPT_EXEC":    6,
		"DNS_ACCESS":     7,
	}
)

Enum value maps for LogType.

View Source 
var (
	SearchRequest_QueryType_name = map[int32]string{
		0: "UNKNOWN",
		1: "SIMPLE",
		2: "COMPLEX",
		3: "ADVANCED",
	}
	SearchRequest_QueryType_value = map[string]int32{
		"UNKNOWN":  0,
		"SIMPLE":   1,
		"COMPLEX":  2,
		"ADVANCED": 3,
	}
)

Enum value maps for SearchRequest_QueryType.

View Source 
var (
	StatusResponse_JobStatus_name = map[int32]string{
		0: "UNKNOWN",
		1: "INIT",
		2: "RUNNING",
		3: "SUCCESS",
		4: "CANCELED",
		5: "FAILED",
		6: "TIMEOUT",
	}
	StatusResponse_JobStatus_value = map[string]int32{
		"UNKNOWN":  0,
		"INIT":     1,
		"RUNNING":  2,
		"SUCCESS":  3,
		"CANCELED": 4,
		"FAILED":   5,
		"TIMEOUT":  6,
	}
)

Enum value maps for StatusResponse_JobStatus.

View Source 
var (
	Column_Type_name = map[int32]string{
		0: "UNKNOWN",
		1: "STRING",
		2: "NUMBER",
		3: "TIME",
		4: "IP",
		5: "BOOL",
	}
	Column_Type_value = map[string]int32{
		"UNKNOWN": 0,
		"STRING":  1,
		"NUMBER":  2,
		"TIME":    3,
		"IP":      4,
		"BOOL":    5,
	}
)

Enum value maps for Column_Type.

View Source 
var (
	ShowRequest_InfoType_name = map[int32]string{
		0: "UNKNOWN",
		1: "CUSTOM_MACRO",
		2: "SYSTEM_MACRO",
		3: "FUNCTION",
		4: "ALIAS",
		5: "USER_TABLE",
	}
	ShowRequest_InfoType_value = map[string]int32{
		"UNKNOWN":      0,
		"CUSTOM_MACRO": 1,
		"SYSTEM_MACRO": 2,
		"FUNCTION":     3,
		"ALIAS":        4,
		"USER_TABLE":   5,
	}
)

Enum value maps for ShowRequest_InfoType.

View Source 
var File_qsl_proto protoreflect.FileDescriptor
View Source 
var QSLEngine_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "QSLEngine",
	HandlerType: (*QSLEngineServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Query",
			Handler:    _QSLEngine_Query_Handler,
		},
		{
			MethodName: "GetStatus",
			Handler:    _QSLEngine_GetStatus_Handler,
		},
		{
			MethodName: "GetResult",
			Handler:    _QSLEngine_GetResult_Handler,
		},
		{
			MethodName: "Terminate",
			Handler:    _QSLEngine_Terminate_Handler,
		},
		{
			MethodName: "GetFields",
			Handler:    _QSLEngine_GetFields_Handler,
		},
		{
			MethodName: "GroupCount",
			Handler:    _QSLEngine_GroupCount_Handler,
		},
		{
			MethodName: "SimpleQuery",
			Handler:    _QSLEngine_SimpleQuery_Handler,
		},
		{
			MethodName: "GetSourceConfig",
			Handler:    _QSLEngine_GetSourceConfig_Handler,
		},
		{
			MethodName: "GetShowInfo",
			Handler:    _QSLEngine_GetShowInfo_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "qsl.proto",
}

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

Functions

func RegisterQSLEngineServer 

func RegisterQSLEngineServer(s grpc.ServiceRegistrar, srv QSLEngineServer)

Types

type Column 

type Column struct {
	Field string      `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Type  Column_Type `protobuf:"varint,2,opt,name=type,proto3,enum=Column_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Column) Descriptor deprecated 

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

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetField 

func (x *Column) GetField() string

func (*Column) GetType 

func (x *Column) GetType() Column_Type

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) ProtoReflect 

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

func (*Column) Reset 

func (x *Column) Reset()

func (*Column) String 

func (x *Column) String() string

type Column_Type 

type Column_Type int32
const (
	Column_UNKNOWN Column_Type = 0
	Column_STRING  Column_Type = 1
	Column_NUMBER  Column_Type = 2
	Column_TIME    Column_Type = 3
	Column_IP      Column_Type = 4
	Column_BOOL    Column_Type = 5
)

func (Column_Type) Descriptor 

func (Column_Type) Descriptor() protoreflect.EnumDescriptor

func (Column_Type) Enum 

func (x Column_Type) Enum() *Column_Type

func (Column_Type) EnumDescriptor deprecated 

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

Deprecated: Use Column_Type.Descriptor instead.

func (Column_Type) Number 

func (x Column_Type) Number() protoreflect.EnumNumber

func (Column_Type) String 

func (x Column_Type) String() string

func (Column_Type) Type 

func (Column_Type) Type() protoreflect.EnumType

type DataSourceConfig 

type DataSourceConfig struct {
	Name           string                         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Url            string                         `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Type           string                         `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Wisteria       bool                           `protobuf:"varint,4,opt,name=wisteria,proto3" json:"wisteria,omitempty"`
	Authentication bool                           `protobuf:"varint,5,opt,name=authentication,proto3" json:"authentication,omitempty"`
	Username       string                         `protobuf:"bytes,6,opt,name=username,proto3" json:"username,omitempty"`
	Password       string                         `protobuf:"bytes,7,opt,name=password,proto3" json:"password,omitempty"`
	DefaultDb      string                         `protobuf:"bytes,8,opt,name=default_db,json=defaultDb,proto3" json:"default_db,omitempty"`
	Abbreviate     map[string]string              `` /* 161-byte string literal not displayed */
	IndexMapping   map[string]*structpb.ListValue `` //https://developers.google.com/protocol-buffers/docs/reference/python-generated#listvalue
	/* 186-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DataSourceConfig) Descriptor deprecated 

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

Deprecated: Use DataSourceConfig.ProtoReflect.Descriptor instead.

func (*DataSourceConfig) GetAbbreviate 

func (x *DataSourceConfig) GetAbbreviate() map[string]string

func (*DataSourceConfig) GetAuthentication 

func (x *DataSourceConfig) GetAuthentication() bool

func (*DataSourceConfig) GetDefaultDb 

func (x *DataSourceConfig) GetDefaultDb() string

func (*DataSourceConfig) GetIndexMapping 

func (x *DataSourceConfig) GetIndexMapping() map[string]*structpb.ListValue

func (*DataSourceConfig) GetName 

func (x *DataSourceConfig) GetName() string

func (*DataSourceConfig) GetPassword 

func (x *DataSourceConfig) GetPassword() string

func (*DataSourceConfig) GetType 

func (x *DataSourceConfig) GetType() string

func (*DataSourceConfig) GetUrl 

func (x *DataSourceConfig) GetUrl() string

func (*DataSourceConfig) GetUsername 

func (x *DataSourceConfig) GetUsername() string

func (*DataSourceConfig) GetWisteria 

func (x *DataSourceConfig) GetWisteria() bool

func (*DataSourceConfig) ProtoMessage 

func (*DataSourceConfig) ProtoMessage()

func (*DataSourceConfig) ProtoReflect 

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

func (*DataSourceConfig) Reset 

func (x *DataSourceConfig) Reset()

func (*DataSourceConfig) String 

func (x *DataSourceConfig) String() string

type FieldRequest 

type FieldRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FieldRequest) Descriptor deprecated 

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

Deprecated: Use FieldRequest.ProtoReflect.Descriptor instead.

func (*FieldRequest) GetJobId 

func (x *FieldRequest) GetJobId() string

func (*FieldRequest) ProtoMessage 

func (*FieldRequest) ProtoMessage()

func (*FieldRequest) ProtoReflect 

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

func (*FieldRequest) Reset 

func (x *FieldRequest) Reset()

func (*FieldRequest) String 

func (x *FieldRequest) String() string

type FieldResponse 

type FieldResponse struct {
	Columns []*Column   `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	Status  *StatusCode `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*FieldResponse) Descriptor deprecated 

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

Deprecated: Use FieldResponse.ProtoReflect.Descriptor instead.

func (*FieldResponse) GetColumns 

func (x *FieldResponse) GetColumns() []*Column

func (*FieldResponse) GetStatus 

func (x *FieldResponse) GetStatus() *StatusCode

func (*FieldResponse) ProtoMessage 

func (*FieldResponse) ProtoMessage()

func (*FieldResponse) ProtoReflect 

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

func (*FieldResponse) Reset 

func (x *FieldResponse) Reset()

func (*FieldResponse) String 

func (x *FieldResponse) String() string

type Filter 

type Filter struct {
	FieldKey  string      `protobuf:"bytes,1,opt,name=field_key,json=fieldKey,proto3" json:"field_key,omitempty"`
	OptionKey string      `protobuf:"bytes,2,opt,name=option_key,json=optionKey,proto3" json:"option_key,omitempty"`
	Content   []string    `protobuf:"bytes,3,rep,name=content,proto3" json:"content,omitempty"`
	FieldType Column_Type `protobuf:"varint,4,opt,name=field_type,json=fieldType,proto3,enum=Column_Type" json:"field_type,omitempty"`
	// contains filtered or unexported fields
}

func (*Filter) Descriptor deprecated 

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetContent 

func (x *Filter) GetContent() []string

func (*Filter) GetFieldKey 

func (x *Filter) GetFieldKey() string

func (*Filter) GetFieldType 

func (x *Filter) GetFieldType() Column_Type

func (*Filter) GetOptionKey 

func (x *Filter) GetOptionKey() string

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

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

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

type GroupCountResponse 

type GroupCountResponse struct {
	Status *StatusCode `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Counts []*LogCount `protobuf:"bytes,2,rep,name=counts,proto3" json:"counts,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupCountResponse) Descriptor deprecated 

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

Deprecated: Use GroupCountResponse.ProtoReflect.Descriptor instead.

func (*GroupCountResponse) GetCounts 

func (x *GroupCountResponse) GetCounts() []*LogCount

func (*GroupCountResponse) GetStatus 

func (x *GroupCountResponse) GetStatus() *StatusCode

func (*GroupCountResponse) ProtoMessage 

func (*GroupCountResponse) ProtoMessage()

func (*GroupCountResponse) ProtoReflect 

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

func (*GroupCountResponse) Reset 

func (x *GroupCountResponse) Reset()

func (*GroupCountResponse) String 

func (x *GroupCountResponse) String() string

type LogCount 

type LogCount struct {
	LogType LogType `protobuf:"varint,1,opt,name=log_type,json=logType,proto3,enum=LogType" json:"log_type,omitempty"`
	Count   int32   `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*LogCount) Descriptor deprecated 

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

Deprecated: Use LogCount.ProtoReflect.Descriptor instead.

func (*LogCount) GetCount 

func (x *LogCount) GetCount() int32

func (*LogCount) GetLogType 

func (x *LogCount) GetLogType() LogType

func (*LogCount) ProtoMessage 

func (*LogCount) ProtoMessage()

func (*LogCount) ProtoReflect 

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

func (*LogCount) Reset 

func (x *LogCount) Reset()

func (*LogCount) String 

func (x *LogCount) String() string

type LogType 

type LogType int32
const (
	LogType_UNKNOWN        LogType = 0
	LogType_PROC_CREATE    LogType = 1
	LogType_NET_CONNECT    LogType = 2
	LogType_SHELL_LOG      LogType = 3
	LogType_ACCESS_LOG     LogType = 4
	LogType_ACCOUNT_CHANGE LogType = 5
	LogType_SCRIPT_EXEC    LogType = 6
	LogType_DNS_ACCESS     LogType = 7
)

func (LogType) Descriptor 

func (LogType) Descriptor() protoreflect.EnumDescriptor

func (LogType) Enum 

func (x LogType) Enum() *LogType

func (LogType) EnumDescriptor deprecated 

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

Deprecated: Use LogType.Descriptor instead.

func (LogType) Number 

func (x LogType) Number() protoreflect.EnumNumber

func (LogType) String 

func (x LogType) String() string

func (LogType) Type 

func (LogType) Type() protoreflect.EnumType

type Order 

type Order struct {
	Key  string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`   // 排序的 key
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // 排序方式 asc|desc
	// contains filtered or unexported fields
}

func (*Order) Descriptor deprecated 

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

Deprecated: Use Order.ProtoReflect.Descriptor instead.

func (*Order) GetKey 

func (x *Order) GetKey() string

func (*Order) GetType 

func (x *Order) GetType() string

func (*Order) ProtoMessage 

func (*Order) ProtoMessage()

func (*Order) ProtoReflect 

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

func (*Order) Reset 

func (x *Order) Reset()

func (*Order) String 

func (x *Order) String() string

type QSLEngineClient 

type QSLEngineClient interface {
	// 异步接口
	Query(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
	GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	GetResult(ctx context.Context, in *ResultRequest, opts ...grpc.CallOption) (*ResultResponse, error)
	Terminate(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error)
	GetFields(ctx context.Context, in *FieldRequest, opts ...grpc.CallOption) (*FieldResponse, error)
	GroupCount(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*GroupCountResponse, error)
	SimpleQuery(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SyncResponse, error)
	GetSourceConfig(ctx context.Context, in *SourceConfigRequest, opts ...grpc.CallOption) (*SourceConfigResponse, error)
	GetShowInfo(ctx context.Context, in *ShowRequest, opts ...grpc.CallOption) (*ShowResponse, error)
}

QSLEngineClient is the client API for QSLEngine 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 NewQSLEngineClient 

func NewQSLEngineClient(cc grpc.ClientConnInterface) QSLEngineClient

type QSLEngineServer 

type QSLEngineServer interface {
	// 异步接口
	Query(context.Context, *SearchRequest) (*SearchResponse, error)
	GetStatus(context.Context, *StatusRequest) (*StatusResponse, error)
	GetResult(context.Context, *ResultRequest) (*ResultResponse, error)
	Terminate(context.Context, *TerminateRequest) (*TerminateResponse, error)
	GetFields(context.Context, *FieldRequest) (*FieldResponse, error)
	GroupCount(context.Context, *SearchRequest) (*GroupCountResponse, error)
	SimpleQuery(context.Context, *SearchRequest) (*SyncResponse, error)
	GetSourceConfig(context.Context, *SourceConfigRequest) (*SourceConfigResponse, error)
	GetShowInfo(context.Context, *ShowRequest) (*ShowResponse, error)
	// contains filtered or unexported methods
}

QSLEngineServer is the server API for QSLEngine service. All implementations must embed UnimplementedQSLEngineServer for forward compatibility

type ResultRequest 

type ResultRequest struct {
	JobId  string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_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:"bytes,4,opt,name=order,proto3" json:"order,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultRequest) Descriptor deprecated 

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

Deprecated: Use ResultRequest.ProtoReflect.Descriptor instead.

func (*ResultRequest) GetJobId 

func (x *ResultRequest) GetJobId() string

func (*ResultRequest) GetLimit 

func (x *ResultRequest) GetLimit() int32

func (*ResultRequest) GetOffset 

func (x *ResultRequest) GetOffset() int32

func (*ResultRequest) GetOrder 

func (x *ResultRequest) GetOrder() *Order

func (*ResultRequest) ProtoMessage 

func (*ResultRequest) ProtoMessage()

func (*ResultRequest) ProtoReflect 

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

func (*ResultRequest) Reset 

func (x *ResultRequest) Reset()

func (*ResultRequest) String 

func (x *ResultRequest) String() string

type ResultResponse 

type ResultResponse struct {
	Status *StatusCode `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Info   []byte      `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	Total  int32       `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"` //是否需要结果总数
	// contains filtered or unexported fields
}

func (*ResultResponse) Descriptor deprecated 

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

Deprecated: Use ResultResponse.ProtoReflect.Descriptor instead.

func (*ResultResponse) GetInfo 

func (x *ResultResponse) GetInfo() []byte

func (*ResultResponse) GetStatus 

func (x *ResultResponse) GetStatus() *StatusCode

func (*ResultResponse) GetTotal 

func (x *ResultResponse) GetTotal() int32

func (*ResultResponse) ProtoMessage 

func (*ResultResponse) ProtoMessage()

func (*ResultResponse) ProtoReflect 

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

func (*ResultResponse) Reset 

func (x *ResultResponse) Reset()

func (*ResultResponse) String 

func (x *ResultResponse) String() string

type SearchRequest 

type SearchRequest struct {
	AppKey    string                  `protobuf:"bytes,1,opt,name=app_key,json=appKey,proto3" json:"app_key,omitempty"`                                         // 应用信息
	AppUser   string                  `protobuf:"bytes,2,opt,name=app_user,json=appUser,proto3" json:"app_user,omitempty"`                                      // 应用内用户ID，用于区分自定义宏
	Qsl       string                  `protobuf:"bytes,3,opt,name=qsl,proto3" json:"qsl,omitempty"`                                                             // 输入框语句
	Timeout   int32                   `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`                                                    // 超时时间
	Filters   []*Filter               `protobuf:"bytes,5,rep,name=filters,proto3" json:"filters,omitempty"`                                                     // 过滤条件
	Whitelist []*WhiteListRule        `protobuf:"bytes,6,rep,name=whitelist,proto3" json:"whitelist,omitempty"`                                                 // 白名单
	LogScopes []LogType               `protobuf:"varint,7,rep,packed,name=log_scopes,json=logScopes,proto3,enum=LogType" json:"log_scopes,omitempty"`           // 日志类型
	TimeStart string                  `protobuf:"bytes,8,opt,name=time_start,json=timeStart,proto3" json:"time_start,omitempty"`                                //时间范围 只能是简单、复合语句
	TimeEnd   string                  `protobuf:"bytes,9,opt,name=time_end,json=timeEnd,proto3" json:"time_end,omitempty"`                                      //时间范围 只能是简单、复合语句
	QueryType SearchRequest_QueryType `protobuf:"varint,10,opt,name=query_type,json=queryType,proto3,enum=SearchRequest_QueryType" json:"query_type,omitempty"` //查询类型
	Orders    []*Order                `protobuf:"bytes,11,rep,name=orders,proto3" json:"orders,omitempty"`                                                      // 默认排序方式，只适用于ES数据源且类型为简单和复合时
	// contains filtered or unexported fields
}

func (*SearchRequest) Descriptor deprecated 

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

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) GetAppKey 

func (x *SearchRequest) GetAppKey() string

func (*SearchRequest) GetAppUser 

func (x *SearchRequest) GetAppUser() string

func (*SearchRequest) GetFilters 

func (x *SearchRequest) GetFilters() []*Filter

func (*SearchRequest) GetLogScopes 

func (x *SearchRequest) GetLogScopes() []LogType

func (*SearchRequest) GetOrders 

func (x *SearchRequest) GetOrders() []*Order

func (*SearchRequest) GetQsl 

func (x *SearchRequest) GetQsl() string

func (*SearchRequest) GetQueryType 

func (x *SearchRequest) GetQueryType() SearchRequest_QueryType

func (*SearchRequest) GetTimeEnd 

func (x *SearchRequest) GetTimeEnd() string

func (*SearchRequest) GetTimeStart 

func (x *SearchRequest) GetTimeStart() string

func (*SearchRequest) GetTimeout 

func (x *SearchRequest) GetTimeout() int32

func (*SearchRequest) GetWhitelist 

func (x *SearchRequest) GetWhitelist() []*WhiteListRule

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect 

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

func (*SearchRequest) Reset 

func (x *SearchRequest) Reset()

func (*SearchRequest) String 

func (x *SearchRequest) String() string

type SearchRequest_QueryType 

type SearchRequest_QueryType int32
const (
	SearchRequest_UNKNOWN  SearchRequest_QueryType = 0
	SearchRequest_SIMPLE   SearchRequest_QueryType = 1 // 简单
	SearchRequest_COMPLEX  SearchRequest_QueryType = 2 // 复合
	SearchRequest_ADVANCED SearchRequest_QueryType = 3 //高级
)

func (SearchRequest_QueryType) Descriptor 

func (SearchRequest_QueryType) Descriptor() protoreflect.EnumDescriptor

func (SearchRequest_QueryType) Enum 

func (x SearchRequest_QueryType) Enum() *SearchRequest_QueryType

func (SearchRequest_QueryType) EnumDescriptor deprecated 

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

Deprecated: Use SearchRequest_QueryType.Descriptor instead.

func (SearchRequest_QueryType) Number 

func (x SearchRequest_QueryType) Number() protoreflect.EnumNumber

func (SearchRequest_QueryType) String 

func (x SearchRequest_QueryType) String() string

func (SearchRequest_QueryType) Type 

func (SearchRequest_QueryType) Type() protoreflect.EnumType

type SearchResponse 

type SearchResponse struct {
	Status *StatusCode `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	JobId  string      `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchResponse) Descriptor deprecated 

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

Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.

func (*SearchResponse) GetJobId 

func (x *SearchResponse) GetJobId() string

func (*SearchResponse) GetStatus 

func (x *SearchResponse) GetStatus() *StatusCode

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) ProtoReflect 

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

func (*SearchResponse) Reset 

func (x *SearchResponse) Reset()

func (*SearchResponse) String 

func (x *SearchResponse) String() string

type ShowRequest 

type ShowRequest struct {
	AppKey   string               `protobuf:"bytes,1,opt,name=app_key,json=appKey,proto3" json:"app_key,omitempty"`                                  // 应用信息
	AppUser  string               `protobuf:"bytes,2,opt,name=app_user,json=appUser,proto3" json:"app_user,omitempty"`                               // 应用内用户ID，用于区分自定义宏
	ShowType ShowRequest_InfoType `protobuf:"varint,3,opt,name=show_type,json=showType,proto3,enum=ShowRequest_InfoType" json:"show_type,omitempty"` // 展示类型等
	// contains filtered or unexported fields
}

func (*ShowRequest) Descriptor deprecated 

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

Deprecated: Use ShowRequest.ProtoReflect.Descriptor instead.

func (*ShowRequest) GetAppKey 

func (x *ShowRequest) GetAppKey() string

func (*ShowRequest) GetAppUser 

func (x *ShowRequest) GetAppUser() string

func (*ShowRequest) GetShowType 

func (x *ShowRequest) GetShowType() ShowRequest_InfoType

func (*ShowRequest) ProtoMessage 

func (*ShowRequest) ProtoMessage()

func (*ShowRequest) ProtoReflect 

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

func (*ShowRequest) Reset 

func (x *ShowRequest) Reset()

func (*ShowRequest) String 

func (x *ShowRequest) String() string

type ShowRequest_InfoType 

type ShowRequest_InfoType int32
const (
	ShowRequest_UNKNOWN      ShowRequest_InfoType = 0
	ShowRequest_CUSTOM_MACRO ShowRequest_InfoType = 1 //自定义宏
	ShowRequest_SYSTEM_MACRO ShowRequest_InfoType = 2 //系统宏
	ShowRequest_FUNCTION     ShowRequest_InfoType = 3 //函数
	ShowRequest_ALIAS        ShowRequest_InfoType = 4 //别名
	ShowRequest_USER_TABLE   ShowRequest_InfoType = 5 // 用户自定义表
)

func (ShowRequest_InfoType) Descriptor 

func (ShowRequest_InfoType) Descriptor() protoreflect.EnumDescriptor

func (ShowRequest_InfoType) Enum 

func (x ShowRequest_InfoType) Enum() *ShowRequest_InfoType

func (ShowRequest_InfoType) EnumDescriptor deprecated 

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

Deprecated: Use ShowRequest_InfoType.Descriptor instead.

func (ShowRequest_InfoType) Number 

func (x ShowRequest_InfoType) Number() protoreflect.EnumNumber

func (ShowRequest_InfoType) String 

func (x ShowRequest_InfoType) String() string

func (ShowRequest_InfoType) Type 

func (ShowRequest_InfoType) Type() protoreflect.EnumType

type ShowResponse 

type ShowResponse struct {
	Details []*structpb.Struct `protobuf:"bytes,1,rep,name=details,proto3" json:"details,omitempty"`
	Status  *StatusCode        `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowResponse) Descriptor deprecated 

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

Deprecated: Use ShowResponse.ProtoReflect.Descriptor instead.

func (*ShowResponse) GetDetails 

func (x *ShowResponse) GetDetails() []*structpb.Struct

func (*ShowResponse) GetStatus 

func (x *ShowResponse) GetStatus() *StatusCode

func (*ShowResponse) ProtoMessage 

func (*ShowResponse) ProtoMessage()

func (*ShowResponse) ProtoReflect 

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

func (*ShowResponse) Reset 

func (x *ShowResponse) Reset()

func (*ShowResponse) String 

func (x *ShowResponse) String() string

type SourceConfigRequest 

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

func (*SourceConfigRequest) Descriptor deprecated 

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

Deprecated: Use SourceConfigRequest.ProtoReflect.Descriptor instead.

func (*SourceConfigRequest) ProtoMessage 

func (*SourceConfigRequest) ProtoMessage()

func (*SourceConfigRequest) ProtoReflect 

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

func (*SourceConfigRequest) Reset 

func (x *SourceConfigRequest) Reset()

func (*SourceConfigRequest) String 

func (x *SourceConfigRequest) String() string

type SourceConfigResponse 

type SourceConfigResponse struct {
	Default string              `protobuf:"bytes,1,opt,name=default,proto3" json:"default,omitempty"` //默认数据源
	Sources []*DataSourceConfig `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"`
	Status  *StatusCode         `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Pbe     string              `protobuf:"bytes,4,opt,name=pbe,proto3" json:"pbe,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceConfigResponse) Descriptor deprecated 

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

Deprecated: Use SourceConfigResponse.ProtoReflect.Descriptor instead.

func (*SourceConfigResponse) GetDefault 

func (x *SourceConfigResponse) GetDefault() string

func (*SourceConfigResponse) GetPbe 

func (x *SourceConfigResponse) GetPbe() string

func (*SourceConfigResponse) GetSources 

func (x *SourceConfigResponse) GetSources() []*DataSourceConfig

func (*SourceConfigResponse) GetStatus 

func (x *SourceConfigResponse) GetStatus() *StatusCode

func (*SourceConfigResponse) ProtoMessage 

func (*SourceConfigResponse) ProtoMessage()

func (*SourceConfigResponse) ProtoReflect 

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

func (*SourceConfigResponse) Reset 

func (x *SourceConfigResponse) Reset()

func (*SourceConfigResponse) String 

func (x *SourceConfigResponse) String() string

type StatusCode 

type StatusCode struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Details string `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

响应状态，使用场景：拿到响应后先看 code，如果正常再去读StatusCode以外的其他信息；如果不正常，可以通过 message 和 details 查看不正常的详细说明 gRPC 服务的响应状态

func (*StatusCode) Descriptor deprecated 

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

Deprecated: Use StatusCode.ProtoReflect.Descriptor instead.

func (*StatusCode) GetCode 

func (x *StatusCode) GetCode() int32

func (*StatusCode) GetDetails 

func (x *StatusCode) GetDetails() string

func (*StatusCode) GetMessage 

func (x *StatusCode) GetMessage() string

func (*StatusCode) ProtoMessage 

func (*StatusCode) ProtoMessage()

func (*StatusCode) ProtoReflect 

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

func (*StatusCode) Reset 

func (x *StatusCode) Reset()

func (*StatusCode) String 

func (x *StatusCode) String() string

type StatusRequest 

type StatusRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) GetJobId 

func (x *StatusRequest) GetJobId() string

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

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

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) String 

func (x *StatusRequest) String() string

type StatusResponse 

type StatusResponse struct {
	Status    *StatusCode              `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	JobStatus StatusResponse_JobStatus `protobuf:"varint,2,opt,name=job_status,json=jobStatus,proto3,enum=StatusResponse_JobStatus" json:"job_status,omitempty"` //任务状态
	Total     int32                    `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`
	Details   *structpb.Struct         `protobuf:"bytes,4,opt,name=details,proto3" json:"details,omitempty"` // 查询任务的内部细节，类型可以确定
	Message   string                   `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetDetails 

func (x *StatusResponse) GetDetails() *structpb.Struct

func (*StatusResponse) GetJobStatus 

func (x *StatusResponse) GetJobStatus() StatusResponse_JobStatus

func (*StatusResponse) GetMessage 

func (x *StatusResponse) GetMessage() string

func (*StatusResponse) GetStatus 

func (x *StatusResponse) GetStatus() *StatusCode

func (*StatusResponse) GetTotal 

func (x *StatusResponse) GetTotal() int32

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type StatusResponse_JobStatus 

type StatusResponse_JobStatus int32
const (
	StatusResponse_UNKNOWN  StatusResponse_JobStatus = 0
	StatusResponse_INIT     StatusResponse_JobStatus = 1
	StatusResponse_RUNNING  StatusResponse_JobStatus = 2
	StatusResponse_SUCCESS  StatusResponse_JobStatus = 3
	StatusResponse_CANCELED StatusResponse_JobStatus = 4
	StatusResponse_FAILED   StatusResponse_JobStatus = 5
	StatusResponse_TIMEOUT  StatusResponse_JobStatus = 6
)

func (StatusResponse_JobStatus) Descriptor 

func (StatusResponse_JobStatus) Descriptor() protoreflect.EnumDescriptor

func (StatusResponse_JobStatus) Enum 

func (x StatusResponse_JobStatus) Enum() *StatusResponse_JobStatus

func (StatusResponse_JobStatus) EnumDescriptor deprecated 

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

Deprecated: Use StatusResponse_JobStatus.Descriptor instead.

func (StatusResponse_JobStatus) Number 

func (x StatusResponse_JobStatus) Number() protoreflect.EnumNumber

func (StatusResponse_JobStatus) String 

func (x StatusResponse_JobStatus) String() string

func (StatusResponse_JobStatus) Type 

func (StatusResponse_JobStatus) Type() protoreflect.EnumType

type SyncResponse 

type SyncResponse struct {
	Status *StatusCode `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Info   []byte      `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncResponse) Descriptor deprecated 

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

Deprecated: Use SyncResponse.ProtoReflect.Descriptor instead.

func (*SyncResponse) GetInfo 

func (x *SyncResponse) GetInfo() []byte

func (*SyncResponse) GetStatus 

func (x *SyncResponse) GetStatus() *StatusCode

func (*SyncResponse) ProtoMessage 

func (*SyncResponse) ProtoMessage()

func (*SyncResponse) ProtoReflect 

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

func (*SyncResponse) Reset 

func (x *SyncResponse) Reset()

func (*SyncResponse) String 

func (x *SyncResponse) String() string

type TerminateRequest 

type TerminateRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminateRequest) Descriptor deprecated 

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

Deprecated: Use TerminateRequest.ProtoReflect.Descriptor instead.

func (*TerminateRequest) GetJobId 

func (x *TerminateRequest) GetJobId() string

func (*TerminateRequest) ProtoMessage 

func (*TerminateRequest) ProtoMessage()

func (*TerminateRequest) ProtoReflect 

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

func (*TerminateRequest) Reset 

func (x *TerminateRequest) Reset()

func (*TerminateRequest) String 

func (x *TerminateRequest) String() string

type TerminateResponse 

type TerminateResponse struct {
	Status *StatusCode `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminateResponse) Descriptor deprecated 

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

Deprecated: Use TerminateResponse.ProtoReflect.Descriptor instead.

func (*TerminateResponse) GetStatus 

func (x *TerminateResponse) GetStatus() *StatusCode

func (*TerminateResponse) ProtoMessage 

func (*TerminateResponse) ProtoMessage()

func (*TerminateResponse) ProtoReflect 

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

func (*TerminateResponse) Reset 

func (x *TerminateResponse) Reset()

func (*TerminateResponse) String 

func (x *TerminateResponse) String() string

type UnimplementedQSLEngineServer 

type UnimplementedQSLEngineServer struct {
}

UnimplementedQSLEngineServer must be embedded to have forward compatible implementations.

func (UnimplementedQSLEngineServer) GetFields 

func (UnimplementedQSLEngineServer) GetFields(context.Context, *FieldRequest) (*FieldResponse, error)

func (UnimplementedQSLEngineServer) GetResult 

func (UnimplementedQSLEngineServer) GetResult(context.Context, *ResultRequest) (*ResultResponse, error)

func (UnimplementedQSLEngineServer) GetShowInfo 

func (UnimplementedQSLEngineServer) GetShowInfo(context.Context, *ShowRequest) (*ShowResponse, error)

func (UnimplementedQSLEngineServer) GetSourceConfig 

func (UnimplementedQSLEngineServer) GetSourceConfig(context.Context, *SourceConfigRequest) (*SourceConfigResponse, error)

func (UnimplementedQSLEngineServer) GetStatus 

func (UnimplementedQSLEngineServer) GetStatus(context.Context, *StatusRequest) (*StatusResponse, error)

func (UnimplementedQSLEngineServer) GroupCount 

func (UnimplementedQSLEngineServer) GroupCount(context.Context, *SearchRequest) (*GroupCountResponse, error)

func (UnimplementedQSLEngineServer) Query 

func (UnimplementedQSLEngineServer) Query(context.Context, *SearchRequest) (*SearchResponse, error)

func (UnimplementedQSLEngineServer) SimpleQuery 

func (UnimplementedQSLEngineServer) SimpleQuery(context.Context, *SearchRequest) (*SyncResponse, error)

func (UnimplementedQSLEngineServer) Terminate 

func (UnimplementedQSLEngineServer) Terminate(context.Context, *TerminateRequest) (*TerminateResponse, error)

type UnsafeQSLEngineServer 

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

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

type WhiteListRule 

type WhiteListRule struct {
	Filters   []*Filter `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	LogScopes []LogType `protobuf:"varint,2,rep,packed,name=log_scopes,json=logScopes,proto3,enum=LogType" json:"log_scopes,omitempty"` // ["proc_create","net_connect"]
	// contains filtered or unexported fields
}

func (*WhiteListRule) Descriptor deprecated 

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

Deprecated: Use WhiteListRule.ProtoReflect.Descriptor instead.

func (*WhiteListRule) GetFilters 

func (x *WhiteListRule) GetFilters() []*Filter

func (*WhiteListRule) GetLogScopes 

func (x *WhiteListRule) GetLogScopes() []LogType

func (*WhiteListRule) ProtoMessage 

func (*WhiteListRule) ProtoMessage()

func (*WhiteListRule) ProtoReflect 

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

func (*WhiteListRule) Reset 

func (x *WhiteListRule) Reset()

func (*WhiteListRule) String 

func (x *WhiteListRule) String() string

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.