audit

package
v0.0.0-...-d04bc5a Latest Latest
Warning

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

 Go to latest Published: Dec 24, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	QueryType_name = map[int32]string{
		0:  "UNKNOWN",
		1:  "DQL",
		2:  "GRANT_PRIV",
		3:  "REVOKE_PRIV",
		4:  "SHOW_STMT",
		5:  "CREATE_USER",
		6:  "DROP_USER",
		7:  "ALTER_USER",
		8:  "CREATE_DATABASE",
		9:  "DROP_DATABASE",
		10: "CREATE_TABLE",
		11: "DROP_TABLE",
		12: "CREATE_VIEW",
		13: "EXPLAIN_STMT",
	}
	QueryType_value = map[string]int32{
		"UNKNOWN":         0,
		"DQL":             1,
		"GRANT_PRIV":      2,
		"REVOKE_PRIV":     3,
		"SHOW_STMT":       4,
		"CREATE_USER":     5,
		"DROP_USER":       6,
		"ALTER_USER":      7,
		"CREATE_DATABASE": 8,
		"DROP_DATABASE":   9,
		"CREATE_TABLE":    10,
		"DROP_TABLE":      11,
		"CREATE_VIEW":     12,
		"EXPLAIN_STMT":    13,
	}
)

Enum value maps for QueryType.

View Source 
var (
	EventName_name = map[int32]string{
		0:  "UNCATEGORIZED",
		1:  "RUN_SYNC_QUERY",
		2:  "RUN_ASYNC_QUERY",
		3:  "ASYNC_COMPLETE",
		4:  "SESSION_PARAMS",
		5:  "FETCH_RESULT",
		6:  "PLAN_DETAIL",
		7:  "DAG_DETAIL",
		8:  "CCL_DETAIL",
		9:  "RUN_SUB_DAG",
		10: "RUN_EXEC_PLAN",
		11: "CREATE_SESSION",
		12: "STOP_JOB",
		13: "JOIN_DETAIL",
		14: "IN_DETAIL",
		15: "SQL_DETAIL",
		16: "DUMP_FILE_DETAIL",
		17: "PUBLISH_DETAIL",
	}
	EventName_value = map[string]int32{
		"UNCATEGORIZED":    0,
		"RUN_SYNC_QUERY":   1,
		"RUN_ASYNC_QUERY":  2,
		"ASYNC_COMPLETE":   3,
		"SESSION_PARAMS":   4,
		"FETCH_RESULT":     5,
		"PLAN_DETAIL":      6,
		"DAG_DETAIL":       7,
		"CCL_DETAIL":       8,
		"RUN_SUB_DAG":      9,
		"RUN_EXEC_PLAN":    10,
		"CREATE_SESSION":   11,
		"STOP_JOB":         12,
		"JOIN_DETAIL":      13,
		"IN_DETAIL":        14,
		"SQL_DETAIL":       15,
		"DUMP_FILE_DETAIL": 16,
		"PUBLISH_DETAIL":   17,
	}
)

Enum value maps for EventName.

View Source 
var File_pkg_audit_audit_proto protoreflect.FileDescriptor
View Source 
var File_pkg_audit_common_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AsyncCompleteEvent 

type AsyncCompleteEvent struct {
	NumRows      int64 `protobuf:"varint,1,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	AffectedRows int64 `protobuf:"varint,2,opt,name=affected_rows,json=affectedRows,proto3" json:"affected_rows,omitempty"`
	// contains filtered or unexported fields
}

func (*AsyncCompleteEvent) Descriptor deprecated 

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

Deprecated: Use AsyncCompleteEvent.ProtoReflect.Descriptor instead.

func (*AsyncCompleteEvent) GetAffectedRows 

func (x *AsyncCompleteEvent) GetAffectedRows() int64

func (*AsyncCompleteEvent) GetNumRows 

func (x *AsyncCompleteEvent) GetNumRows() int64

func (*AsyncCompleteEvent) ProtoMessage 

func (*AsyncCompleteEvent) ProtoMessage()

func (*AsyncCompleteEvent) ProtoReflect 

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

func (*AsyncCompleteEvent) Reset 

func (x *AsyncCompleteEvent) Reset()

func (*AsyncCompleteEvent) String 

func (x *AsyncCompleteEvent) String() string

type AuditBody 

type AuditBody struct {

	// Types that are assignable to Body:
	//	*AuditBody_Uncategorized
	//	*AuditBody_RunSyncQuery
	//	*AuditBody_RunAsyncQuery
	//	*AuditBody_AsyncComplete
	//	*AuditBody_FetchResult
	//	*AuditBody_SessionParams
	//	*AuditBody_PlanDetail
	//	*AuditBody_DagDetail
	//	*AuditBody_CclDetail
	Body isAuditBody_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

func (*AuditBody) Descriptor deprecated 

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

Deprecated: Use AuditBody.ProtoReflect.Descriptor instead.

func (*AuditBody) GetAsyncComplete 

func (x *AuditBody) GetAsyncComplete() *AsyncCompleteEvent

func (*AuditBody) GetBody 

func (m *AuditBody) GetBody() isAuditBody_Body

func (*AuditBody) GetCclDetail 

func (x *AuditBody) GetCclDetail() *scql.SecurityConfig

func (*AuditBody) GetDagDetail 

func (x *AuditBody) GetDagDetail() *QueryDagDetail

func (*AuditBody) GetFetchResult 

func (x *AuditBody) GetFetchResult() *FetchResultEvent

func (*AuditBody) GetPlanDetail 

func (x *AuditBody) GetPlanDetail() *QueryPlanDetail

func (*AuditBody) GetRunAsyncQuery 

func (x *AuditBody) GetRunAsyncQuery() *RunAsyncQueryEvent

func (*AuditBody) GetRunSyncQuery 

func (x *AuditBody) GetRunSyncQuery() *RunSyncQueryEvent

func (*AuditBody) GetSessionParams 

func (x *AuditBody) GetSessionParams() *SessionParameters

func (*AuditBody) GetUncategorized 

func (x *AuditBody) GetUncategorized() *UncategorizedEvent

func (*AuditBody) ProtoMessage 

func (*AuditBody) ProtoMessage()

func (*AuditBody) ProtoReflect 

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

func (*AuditBody) Reset 

func (x *AuditBody) Reset()

func (*AuditBody) String 

func (x *AuditBody) String() string

type AuditBody_AsyncComplete 

type AuditBody_AsyncComplete struct {
	AsyncComplete *AsyncCompleteEvent `protobuf:"bytes,4,opt,name=async_complete,json=asyncComplete,proto3,oneof"`
}

type AuditBody_CclDetail 

type AuditBody_CclDetail struct {
	CclDetail *scql.SecurityConfig `protobuf:"bytes,9,opt,name=ccl_detail,json=cclDetail,proto3,oneof"`
}

type AuditBody_DagDetail 

type AuditBody_DagDetail struct {
	DagDetail *QueryDagDetail `protobuf:"bytes,8,opt,name=dag_detail,json=dagDetail,proto3,oneof"`
}

type AuditBody_FetchResult 

type AuditBody_FetchResult struct {
	FetchResult *FetchResultEvent `protobuf:"bytes,5,opt,name=fetch_result,json=fetchResult,proto3,oneof"`
}

type AuditBody_PlanDetail 

type AuditBody_PlanDetail struct {
	PlanDetail *QueryPlanDetail `protobuf:"bytes,7,opt,name=plan_detail,json=planDetail,proto3,oneof"`
}

type AuditBody_RunAsyncQuery 

type AuditBody_RunAsyncQuery struct {
	RunAsyncQuery *RunAsyncQueryEvent `protobuf:"bytes,3,opt,name=run_async_query,json=runAsyncQuery,proto3,oneof"`
}

type AuditBody_RunSyncQuery 

type AuditBody_RunSyncQuery struct {
	RunSyncQuery *RunSyncQueryEvent `protobuf:"bytes,2,opt,name=run_sync_query,json=runSyncQuery,proto3,oneof"`
}

type AuditBody_SessionParams 

type AuditBody_SessionParams struct {
	SessionParams *SessionParameters `protobuf:"bytes,6,opt,name=session_params,json=sessionParams,proto3,oneof"`
}

type AuditBody_Uncategorized 

type AuditBody_Uncategorized struct {
	Uncategorized *UncategorizedEvent `protobuf:"bytes,1,opt,name=uncategorized,proto3,oneof"`
}

type AuditHeader 

type AuditHeader struct {
	Time      *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	Status    *scql.Status           `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	EventName EventName              `protobuf:"varint,3,opt,name=event_name,json=eventName,proto3,enum=audit.pb.EventName" json:"event_name,omitempty"`
	SessionId string                 `protobuf:"bytes,4,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AuditHeader) Descriptor deprecated 

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

Deprecated: Use AuditHeader.ProtoReflect.Descriptor instead.

func (*AuditHeader) GetEventName 

func (x *AuditHeader) GetEventName() EventName

func (*AuditHeader) GetSessionId 

func (x *AuditHeader) GetSessionId() string

func (*AuditHeader) GetStatus 

func (x *AuditHeader) GetStatus() *scql.Status

func (*AuditHeader) GetTime 

func (x *AuditHeader) GetTime() *timestamppb.Timestamp

func (*AuditHeader) ProtoMessage 

func (*AuditHeader) ProtoMessage()

func (*AuditHeader) ProtoReflect 

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

func (*AuditHeader) Reset 

func (x *AuditHeader) Reset()

func (*AuditHeader) String 

func (x *AuditHeader) String() string

type AuditLog 

type AuditLog struct {
	Header *AuditHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Body   *AuditBody   `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*AuditLog) Descriptor deprecated 

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

Deprecated: Use AuditLog.ProtoReflect.Descriptor instead.

func (*AuditLog) GetBody 

func (x *AuditLog) GetBody() *AuditBody

func (*AuditLog) GetHeader 

func (x *AuditLog) GetHeader() *AuditHeader

func (*AuditLog) ProtoMessage 

func (*AuditLog) ProtoMessage()

func (*AuditLog) ProtoReflect 

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

func (*AuditLog) Reset 

func (x *AuditLog) Reset()

func (*AuditLog) String 

func (x *AuditLog) String() string

type EventName 

type EventName int32
const (
	EventName_UNCATEGORIZED    EventName = 0
	EventName_RUN_SYNC_QUERY   EventName = 1
	EventName_RUN_ASYNC_QUERY  EventName = 2
	EventName_ASYNC_COMPLETE   EventName = 3
	EventName_SESSION_PARAMS   EventName = 4
	EventName_FETCH_RESULT     EventName = 5
	EventName_PLAN_DETAIL      EventName = 6
	EventName_DAG_DETAIL       EventName = 7
	EventName_CCL_DETAIL       EventName = 8
	EventName_RUN_SUB_DAG      EventName = 9
	EventName_RUN_EXEC_PLAN    EventName = 10
	EventName_CREATE_SESSION   EventName = 11
	EventName_STOP_JOB         EventName = 12
	EventName_JOIN_DETAIL      EventName = 13
	EventName_IN_DETAIL        EventName = 14
	EventName_SQL_DETAIL       EventName = 15
	EventName_DUMP_FILE_DETAIL EventName = 16
	EventName_PUBLISH_DETAIL   EventName = 17
)

func (EventName) Descriptor 

func (EventName) Descriptor() protoreflect.EnumDescriptor

func (EventName) Enum 

func (x EventName) Enum() *EventName

func (EventName) EnumDescriptor deprecated 

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

Deprecated: Use EventName.Descriptor instead.

func (EventName) Number 

func (x EventName) Number() protoreflect.EnumNumber

func (EventName) String 

func (x EventName) String() string

func (EventName) Type 

func (EventName) Type() protoreflect.EnumType

type FetchResultEvent 

type FetchResultEvent struct {
	UserName     string `protobuf:"bytes,1,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	HostName     string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	SourceIp     string `protobuf:"bytes,3,opt,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`
	NumRows      int64  `protobuf:"varint,4,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	AffectedRows int64  `protobuf:"varint,5,opt,name=affected_rows,json=affectedRows,proto3" json:"affected_rows,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchResultEvent) Descriptor deprecated 

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

Deprecated: Use FetchResultEvent.ProtoReflect.Descriptor instead.

func (*FetchResultEvent) GetAffectedRows 

func (x *FetchResultEvent) GetAffectedRows() int64

func (*FetchResultEvent) GetHostName 

func (x *FetchResultEvent) GetHostName() string

func (*FetchResultEvent) GetNumRows 

func (x *FetchResultEvent) GetNumRows() int64

func (*FetchResultEvent) GetSourceIp 

func (x *FetchResultEvent) GetSourceIp() string

func (*FetchResultEvent) GetUserName 

func (x *FetchResultEvent) GetUserName() string

func (*FetchResultEvent) ProtoMessage 

func (*FetchResultEvent) ProtoMessage()

func (*FetchResultEvent) ProtoReflect 

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

func (*FetchResultEvent) Reset 

func (x *FetchResultEvent) Reset()

func (*FetchResultEvent) String 

func (x *FetchResultEvent) String() string

type NodeInfo 

type NodeInfo struct {
	Name    string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Inputs  map[string]*Strings `` /* 153-byte string literal not displayed */
	Outputs map[string]*Strings `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NodeInfo) Descriptor deprecated 

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

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetInputs 

func (x *NodeInfo) GetInputs() map[string]*Strings

func (*NodeInfo) GetName 

func (x *NodeInfo) GetName() string

func (*NodeInfo) GetOutputs 

func (x *NodeInfo) GetOutputs() map[string]*Strings

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect 

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

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) String 

func (x *NodeInfo) String() string

type QueryDagDetail 

type QueryDagDetail struct {
	PartyCode string      `protobuf:"bytes,1,opt,name=party_code,json=partyCode,proto3" json:"party_code,omitempty"`
	TargetUrl string      `protobuf:"bytes,2,opt,name=target_url,json=targetUrl,proto3" json:"target_url,omitempty"`
	DagId     int32       `protobuf:"varint,3,opt,name=dag_id,json=dagId,proto3" json:"dag_id,omitempty"`
	NodeList  []*NodeInfo `protobuf:"bytes,4,rep,name=node_list,json=nodeList,proto3" json:"node_list,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryDagDetail) Descriptor deprecated 

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

Deprecated: Use QueryDagDetail.ProtoReflect.Descriptor instead.

func (*QueryDagDetail) GetDagId 

func (x *QueryDagDetail) GetDagId() int32

func (*QueryDagDetail) GetNodeList 

func (x *QueryDagDetail) GetNodeList() []*NodeInfo

func (*QueryDagDetail) GetPartyCode 

func (x *QueryDagDetail) GetPartyCode() string

func (*QueryDagDetail) GetTargetUrl 

func (x *QueryDagDetail) GetTargetUrl() string

func (*QueryDagDetail) ProtoMessage 

func (*QueryDagDetail) ProtoMessage()

func (*QueryDagDetail) ProtoReflect 

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

func (*QueryDagDetail) Reset 

func (x *QueryDagDetail) Reset()

func (*QueryDagDetail) String 

func (x *QueryDagDetail) String() string

type QueryPlanDetail 

type QueryPlanDetail struct {
	PartyCode string      `protobuf:"bytes,1,opt,name=party_code,json=partyCode,proto3" json:"party_code,omitempty"`
	TargetUrl string      `protobuf:"bytes,2,opt,name=target_url,json=targetUrl,proto3" json:"target_url,omitempty"`
	NodeList  []*NodeInfo `protobuf:"bytes,3,rep,name=node_list,json=nodeList,proto3" json:"node_list,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryPlanDetail) Descriptor deprecated 

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

Deprecated: Use QueryPlanDetail.ProtoReflect.Descriptor instead.

func (*QueryPlanDetail) GetNodeList 

func (x *QueryPlanDetail) GetNodeList() []*NodeInfo

func (*QueryPlanDetail) GetPartyCode 

func (x *QueryPlanDetail) GetPartyCode() string

func (*QueryPlanDetail) GetTargetUrl 

func (x *QueryPlanDetail) GetTargetUrl() string

func (*QueryPlanDetail) ProtoMessage 

func (*QueryPlanDetail) ProtoMessage()

func (*QueryPlanDetail) ProtoReflect 

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

func (*QueryPlanDetail) Reset 

func (x *QueryPlanDetail) Reset()

func (*QueryPlanDetail) String 

func (x *QueryPlanDetail) String() string

type QueryType 

type QueryType int32
const (
	QueryType_UNKNOWN         QueryType = 0
	QueryType_DQL             QueryType = 1
	QueryType_GRANT_PRIV      QueryType = 2
	QueryType_REVOKE_PRIV     QueryType = 3
	QueryType_SHOW_STMT       QueryType = 4
	QueryType_CREATE_USER     QueryType = 5
	QueryType_DROP_USER       QueryType = 6
	QueryType_ALTER_USER      QueryType = 7
	QueryType_CREATE_DATABASE QueryType = 8
	QueryType_DROP_DATABASE   QueryType = 9
	QueryType_CREATE_TABLE    QueryType = 10
	QueryType_DROP_TABLE      QueryType = 11
	QueryType_CREATE_VIEW     QueryType = 12
	QueryType_EXPLAIN_STMT    QueryType = 13
)

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 RunAsyncQueryEvent 

type RunAsyncQueryEvent struct {
	UserName string    `protobuf:"bytes,1,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	HostName string    `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	SourceIp string    `protobuf:"bytes,3,opt,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`
	Query    string    `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	Type     QueryType `protobuf:"varint,5,opt,name=type,proto3,enum=audit.pb.QueryType" json:"type,omitempty"`
	CostTime int64     `protobuf:"varint,6,opt,name=cost_time,json=costTime,proto3" json:"cost_time,omitempty"`
	// contains filtered or unexported fields
}

func (*RunAsyncQueryEvent) Descriptor deprecated 

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

Deprecated: Use RunAsyncQueryEvent.ProtoReflect.Descriptor instead.

func (*RunAsyncQueryEvent) GetCostTime 

func (x *RunAsyncQueryEvent) GetCostTime() int64

func (*RunAsyncQueryEvent) GetHostName 

func (x *RunAsyncQueryEvent) GetHostName() string

func (*RunAsyncQueryEvent) GetQuery 

func (x *RunAsyncQueryEvent) GetQuery() string

func (*RunAsyncQueryEvent) GetSourceIp 

func (x *RunAsyncQueryEvent) GetSourceIp() string

func (*RunAsyncQueryEvent) GetType 

func (x *RunAsyncQueryEvent) GetType() QueryType

func (*RunAsyncQueryEvent) GetUserName 

func (x *RunAsyncQueryEvent) GetUserName() string

func (*RunAsyncQueryEvent) ProtoMessage 

func (*RunAsyncQueryEvent) ProtoMessage()

func (*RunAsyncQueryEvent) ProtoReflect 

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

func (*RunAsyncQueryEvent) Reset 

func (x *RunAsyncQueryEvent) Reset()

func (*RunAsyncQueryEvent) String 

func (x *RunAsyncQueryEvent) String() string

type RunSyncQueryEvent 

type RunSyncQueryEvent struct {
	UserName     string    `protobuf:"bytes,1,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	HostName     string    `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	SourceIp     string    `protobuf:"bytes,3,opt,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`
	Query        string    `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	Type         QueryType `protobuf:"varint,5,opt,name=type,proto3,enum=audit.pb.QueryType" json:"type,omitempty"`
	NumRows      int64     `protobuf:"varint,6,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	AffectedRows int64     `protobuf:"varint,7,opt,name=affected_rows,json=affectedRows,proto3" json:"affected_rows,omitempty"`
	CostTime     int64     `protobuf:"varint,8,opt,name=cost_time,json=costTime,proto3" json:"cost_time,omitempty"`
	// contains filtered or unexported fields
}

func (*RunSyncQueryEvent) Descriptor deprecated 

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

Deprecated: Use RunSyncQueryEvent.ProtoReflect.Descriptor instead.

func (*RunSyncQueryEvent) GetAffectedRows 

func (x *RunSyncQueryEvent) GetAffectedRows() int64

func (*RunSyncQueryEvent) GetCostTime 

func (x *RunSyncQueryEvent) GetCostTime() int64

func (*RunSyncQueryEvent) GetHostName 

func (x *RunSyncQueryEvent) GetHostName() string

func (*RunSyncQueryEvent) GetNumRows 

func (x *RunSyncQueryEvent) GetNumRows() int64

func (*RunSyncQueryEvent) GetQuery 

func (x *RunSyncQueryEvent) GetQuery() string

func (*RunSyncQueryEvent) GetSourceIp 

func (x *RunSyncQueryEvent) GetSourceIp() string

func (*RunSyncQueryEvent) GetType 

func (x *RunSyncQueryEvent) GetType() QueryType

func (*RunSyncQueryEvent) GetUserName 

func (x *RunSyncQueryEvent) GetUserName() string

func (*RunSyncQueryEvent) ProtoMessage 

func (*RunSyncQueryEvent) ProtoMessage()

func (*RunSyncQueryEvent) ProtoReflect 

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

func (*RunSyncQueryEvent) Reset 

func (x *RunSyncQueryEvent) Reset()

func (*RunSyncQueryEvent) String 

func (x *RunSyncQueryEvent) String() string

type SessionParameters 

type SessionParameters struct {
	Sync       bool                 `protobuf:"varint,1,opt,name=sync,proto3" json:"sync,omitempty"`
	Parameters *scql.JobStartParams `protobuf:"bytes,2,opt,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionParameters) Descriptor deprecated 

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

Deprecated: Use SessionParameters.ProtoReflect.Descriptor instead.

func (*SessionParameters) GetParameters 

func (x *SessionParameters) GetParameters() *scql.JobStartParams

func (*SessionParameters) GetSync 

func (x *SessionParameters) GetSync() bool

func (*SessionParameters) ProtoMessage 

func (*SessionParameters) ProtoMessage()

func (*SessionParameters) ProtoReflect 

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

func (*SessionParameters) Reset 

func (x *SessionParameters) Reset()

func (*SessionParameters) String 

func (x *SessionParameters) String() string

type Strings 

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

func (*Strings) Descriptor deprecated 

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

Deprecated: Use Strings.ProtoReflect.Descriptor instead.

func (*Strings) GetSs 

func (x *Strings) GetSs() []string

func (*Strings) ProtoMessage 

func (*Strings) ProtoMessage()

func (*Strings) ProtoReflect 

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

func (*Strings) Reset 

func (x *Strings) Reset()

func (*Strings) String 

func (x *Strings) String() string

type UncategorizedEvent 

type UncategorizedEvent struct {
	UrlPath  string `protobuf:"bytes,1,opt,name=url_path,json=urlPath,proto3" json:"url_path,omitempty"`
	SourceIp string `protobuf:"bytes,2,opt,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`
	// contains filtered or unexported fields
}

func (*UncategorizedEvent) Descriptor deprecated 

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

Deprecated: Use UncategorizedEvent.ProtoReflect.Descriptor instead.

func (*UncategorizedEvent) GetSourceIp 

func (x *UncategorizedEvent) GetSourceIp() string

func (*UncategorizedEvent) GetUrlPath 

func (x *UncategorizedEvent) GetUrlPath() string

func (*UncategorizedEvent) ProtoMessage 

func (*UncategorizedEvent) ProtoMessage()

func (*UncategorizedEvent) ProtoReflect 

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

func (*UncategorizedEvent) Reset 

func (x *UncategorizedEvent) Reset()

func (*UncategorizedEvent) String 

func (x *UncategorizedEvent) 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.