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

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

func (SearchRequest_QueryType) EnumDescriptor deprecated

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

Deprecated: Use SearchRequest_QueryType.Descriptor instead.

func (SearchRequest_QueryType) Number

func (SearchRequest_QueryType) String

func (x SearchRequest_QueryType) String() string

func (SearchRequest_QueryType) Type

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

func (ShowRequest_InfoType) EnumDescriptor deprecated

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

Deprecated: Use ShowRequest_InfoType.Descriptor instead.

func (ShowRequest_InfoType) Number

func (ShowRequest_InfoType) String

func (x ShowRequest_InfoType) String() string

func (ShowRequest_InfoType) Type

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

func (StatusResponse_JobStatus) EnumDescriptor deprecated

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

Deprecated: Use StatusResponse_JobStatus.Descriptor instead.

func (StatusResponse_JobStatus) Number

func (StatusResponse_JobStatus) String

func (x StatusResponse_JobStatus) String() string

func (StatusResponse_JobStatus) Type

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

func (UnimplementedQSLEngineServer) GetShowInfo

func (UnimplementedQSLEngineServer) GetSourceConfig

func (UnimplementedQSLEngineServer) GetStatus

func (UnimplementedQSLEngineServer) GroupCount

func (UnimplementedQSLEngineServer) Query

func (UnimplementedQSLEngineServer) SimpleQuery

func (UnimplementedQSLEngineServer) Terminate

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL