pb

type Agent struct {

	// 唯一识别该agent的id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// 该agent的ip
	Ip       string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// TODO 版本号
	// 其他扩展字段
	Other map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

type AgentK8SInfo struct {
	HostIp    string `protobuf:"bytes,1,opt,name=host_ip,json=hostIp,proto3" json:"host_ip,omitempty"`
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Pod       string `protobuf:"bytes,3,opt,name=pod,proto3" json:"pod,omitempty"`
	// for daemonset
	NodeHostname string `protobuf:"bytes,4,opt,name=node_hostname,json=nodeHostname,proto3" json:"node_hostname,omitempty"`
	// contains filtered or unexported fields
}

type BasicConfig struct {

	// 如果>0则每隔多少秒发一次心跳, 代码里会检查最小值是5s, 默认是60秒
	HeartbeatIntervalSeconds   int32 `` /* 136-byte string literal not displayed */
	ReonnectInterval           int32 `protobuf:"varint,2,opt,name=reonnect_interval,json=reonnectInterval,proto3" json:"reonnect_interval,omitempty"`
	SyncConfigsIntervalSeconds int32 `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

type BiStreamClientHandshakeRequest struct {
	AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Version int64  `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type BiStreamClientHandshakeResponse struct {
	Header *pb.CommonResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

type CheckConfigTaskDistributionRequest struct {
	Header   *pb.CommonRequestHeader                       `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	SubTasks []*CheckConfigTaskDistributionRequest_SubTask `protobuf:"bytes,2,rep,name=sub_tasks,json=subTasks,proto3" json:"sub_tasks,omitempty"`
	// contains filtered or unexported fields
}

type CheckConfigTaskDistributionRequest_SubTask struct {
	ConfigKey     string `protobuf:"bytes,1,opt,name=config_key,json=configKey,proto3" json:"config_key,omitempty"`
	ConfigVersion string `protobuf:"bytes,2,opt,name=config_version,json=configVersion,proto3" json:"config_version,omitempty"`
	TargetKey     string `protobuf:"bytes,3,opt,name=target_key,json=targetKey,proto3" json:"target_key,omitempty"`
	TargetVersion string `protobuf:"bytes,4,opt,name=target_version,json=targetVersion,proto3" json:"target_version,omitempty"`
	// contains filtered or unexported fields
}

type CheckConfigTaskDistributionResponse struct {
	Header *pb.CommonResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Status []int32                  `protobuf:"varint,2,rep,packed,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type CollectConfig struct {

	// 实际上也就是对应 table_name
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// 对于页面上一个配置对应的同一个采集目标, 如果内容发生变化则该version会更新
	// TODO 当用户拿着2个version, 怎么知道哪个是新的呢?
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// 用于描述content的类型
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// 配置内容, 可能是一个大json, 但总之使用bytes来描述
	Content []byte `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

type CollectConfigRunStats struct {

	// 采集配置表名
	TableName string            `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	Stats     map[string]uint64 `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CollectConfigsBucket struct {

	// 该bucket的状态
	State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// 属于该bucket的所有采集任务, 如果state与请求里的相同, 那么说明没有变化, 此时tasks为空
	CollectTasks []*CollectTask `protobuf:"bytes,2,rep,name=collect_tasks,json=collectTasks,proto3" json:"collect_tasks,omitempty"`
	// contains filtered or unexported fields
}

type CollectTarget struct {

	// TODO 元数据内容是否也可能变化?
	Key     string            `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Type    string            `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Version string            `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Meta    map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CollectTask struct {

	// 对于页面上一个配置对应的同一个采集目标, 即使配置或目标的**内容**发生了变化, 该key始终保持不变
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// 这里不指持有实际的采集配置和采集目标, 而是持有它们的key
	CollectConfigKey string `protobuf:"bytes,2,opt,name=collect_config_key,json=collectConfigKey,proto3" json:"collect_config_key,omitempty"`
	CollectTargetKey string `protobuf:"bytes,3,opt,name=collect_target_key,json=collectTargetKey,proto3" json:"collect_target_key,omitempty"`
	// contains filtered or unexported fields
}

type CollectTask2 struct {
	Config  *CollectConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Target  *CollectTarget `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	Version string         `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type DebugConfig struct {

	// 是否打印详细日志, 默认是false
	LogVerbose bool `protobuf:"varint,1,opt,name=log_verbose,json=logVerbose,proto3" json:"log_verbose,omitempty"`
	// 事件、指标上报相关，用于问题定位排查
	// 是否关闭该功能
	ReportDisable bool `protobuf:"varint,2,opt,name=reportDisable,proto3" json:"reportDisable,omitempty"`
	// 事件上报限流值。如果>0则表示允许每台agent每分钟上报多少条处理错误到服务端, 有助于排查问题(自助诊断), 程序内部可以再限制一个值, 默认是0
	ReportProcessingErrorCount int32 `protobuf:"varint,3,opt,name=reportProcessingErrorCount,proto3" json:"reportProcessingErrorCount,omitempty"`
	// contains filtered or unexported fields
}

type DryRunRequest struct {

	// common request header
	Header *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// 配置信息
	Config *DryRunRequest_CollectConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// 最终运行的目标, 在元数据里必须能找到
	Target *TargetIdentifier `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// 输入信息
	Input *DryRunRequest_Input `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	// contains filtered or unexported fields
}

type DryRunRequest_CollectConfig struct {

	// tableName: 从 db 里读取配置, 根据 tableName 匹配
	// temp:
	Type      string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	TableName string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// 字段对应 gaea_collect_config 里的 记录
	Temp *DryRunRequest_CollectConfigTemp `protobuf:"bytes,3,opt,name=temp,proto3" json:"temp,omitempty"`
	// contains filtered or unexported fields
}

type DryRunRequest_CollectConfigTemp struct {

	// 字段对应 gaea_collect_config 里的 字段
	Type             string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Json             string `protobuf:"bytes,2,opt,name=json,proto3" json:"json,omitempty"`
	ExecutorSelector string `protobuf:"bytes,3,opt,name=executor_selector,json=executorSelector,proto3" json:"executor_selector,omitempty"`
	CollectRange     string `protobuf:"bytes,4,opt,name=collect_range,json=collectRange,proto3" json:"collect_range,omitempty"`
	// contains filtered or unexported fields
}

type DryRunRequest_Input struct {

	// plain: 从请求里读
	// read: 从pod里读
	Type  string                    `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Plain *DryRunRequest_InputPlain `protobuf:"bytes,2,opt,name=plain,proto3" json:"plain,omitempty"`
	// contains filtered or unexported fields
}

type DryRunRequest_InputPlain struct {

	// 原始日志
	Lines []string `protobuf:"bytes,1,rep,name=lines,proto3" json:"lines,omitempty"`
	// Timezone to use when parsing timestamp of log lines.
	// Defaults to local timezone of agent.
	Timezone string `protobuf:"bytes,2,opt,name=timezone,proto3" json:"timezone,omitempty"`
	// contains filtered or unexported fields
}

type DryRunResponse struct {
	Header       *pb.CommonResponseHeader      `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Event        *DryRunResponse_Event         `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	GroupResults []*DryRunResponse_GroupResult `protobuf:"bytes,3,rep,name=group_results,json=groupResults,proto3" json:"group_results,omitempty"`
	// contains filtered or unexported fields
}

type DryRunResponse_Event struct {
	Title    string                    `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Params   map[string]string         `` /* 153-byte string literal not displayed */
	Message  []*DryRunResponse_Message `protobuf:"bytes,3,rep,name=message,proto3" json:"message,omitempty"`
	Children []*DryRunResponse_Event   `protobuf:"bytes,4,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

type DryRunResponse_GroupResult struct {
	GroupLines     []string           `protobuf:"bytes,1,rep,name=group_lines,json=groupLines,proto3" json:"group_lines,omitempty"`
	Success        bool               `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	SelectedValues map[string]float64 `` /* 193-byte string literal not displayed */
	GroupBy        map[string]string  `` /* 170-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DryRunResponse_Message struct {
	Level   string `protobuf:"bytes,1,opt,name=level,proto3" json:"level,omitempty"`
	Content string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

type GetCollectTasksRequest struct {
	Header  *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	AgentId string                  `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// agent持有的所有buckets的状态
	Buckets map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

type GetCollectTasksResponse struct {
	Header *pb.CommonResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// 返回每个bucket的最新状态, 如果bucket里的state与agent上的state相同, 那么说明该bucket没有任何变化
	// 此时其对应的 collect_tasks 也会为空
	Buckets map[string]*CollectConfigsBucket `` /* 155-byte string literal not displayed */
	// 引用的配置
	CollectConfigs map[string]*CollectConfig `` /* 191-byte string literal not displayed */
	// 应用的采集目标, 绝大多数只会有一个目标, 就是本机
	CollectTargets map[string]*CollectTarget `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

type GetControlConfigsRequest struct {
	Header  *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	AgentId string                  `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// contains filtered or unexported fields
}

type GetControlConfigsResponse struct {
	Header      *pb.CommonResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	BasicConfig *BasicConfig             `protobuf:"bytes,2,opt,name=basic_config,json=basicConfig,proto3" json:"basic_config,omitempty"`
	DebugConfig *DebugConfig             `protobuf:"bytes,3,opt,name=debug_config,json=debugConfig,proto3" json:"debug_config,omitempty"`
	// contains filtered or unexported fields
}

type HttpProxyRequest struct {
	Header  *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	AgentId string                  `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// TargetIdentifier target = 3;
	Method  string            `protobuf:"bytes,4,opt,name=method,proto3" json:"method,omitempty"`
	Url     string            `protobuf:"bytes,5,opt,name=url,proto3" json:"url,omitempty"`
	Headers map[string]string `` /* 155-byte string literal not displayed */
	Body    []byte            `protobuf:"bytes,7,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type HttpProxyResponse struct {
	Header  *pb.CommonResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Code    int32                    `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	Headers map[string]string        `` /* 155-byte string literal not displayed */
	Body    []byte                   `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	Cost    int32                    `protobuf:"varint,5,opt,name=cost,proto3" json:"cost,omitempty"`
	// contains filtered or unexported fields
}

type InspectRequest struct {
	Header  *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	AgentId string                  `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// contains filtered or unexported fields
}

type InspectResponse struct {
	Header *pb.CommonResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Result string                   `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type ListFilesRequest struct {

	// request header
	Header *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// agent id
	AgentId string `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// dir path
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// max depths
	MaxDepth    int32    `protobuf:"varint,4,opt,name=max_depth,json=maxDepth,proto3" json:"max_depth,omitempty"`
	IncludeExts []string `protobuf:"bytes,5,rep,name=include_exts,json=includeExts,proto3" json:"include_exts,omitempty"`
	// 如果为true则显示父目录
	IncludeParents bool `protobuf:"varint,6,opt,name=include_parents,json=includeParents,proto3" json:"include_parents,omitempty"`
	// contains filtered or unexported fields
}

type ListFilesResponse struct {
	Header *pb.CommonResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Nodes  []*pb.FileNode           `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

type MatchFilesRequest struct {
	Header  *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	AgentId string                  `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// path/format/glob/regexp
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// used when type in (path,format,glob,regexp)
	Pattern string `protobuf:"bytes,4,opt,name=pattern,proto3" json:"pattern,omitempty"`
	// used when type=regexp
	Dir string `protobuf:"bytes,5,opt,name=dir,proto3" json:"dir,omitempty"`
	// used when glob&regexp
	MaxVisited int32 `protobuf:"varint,6,opt,name=maxVisited,proto3" json:"maxVisited,omitempty"`
	// used when glob&regexp
	MaxMatched int32 `protobuf:"varint,7,opt,name=maxMatched,proto3" json:"maxMatched,omitempty"`
	// contains filtered or unexported fields
}

type MatchFilesResponse struct {
	Header  *pb.CommonResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Files   []string                 `protobuf:"bytes,2,rep,name=files,proto3" json:"files,omitempty"`
	Visited int32                    `protobuf:"varint,3,opt,name=visited,proto3" json:"visited,omitempty"`
	// contains filtered or unexported fields
}

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

type MetaSync_DeltaSyncRequest struct {
	Header *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// deprecated
	// string temp = 2;
	Workspace string               `protobuf:"bytes,3,opt,name=workspace,proto3" json:"workspace,omitempty"`
	Type      string               `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Add       []*MetaSync_Resource `protobuf:"bytes,5,rep,name=add,proto3" json:"add,omitempty"`
	Del       []*MetaSync_Resource `protobuf:"bytes,6,rep,name=del,proto3" json:"del,omitempty"`
	Cluster   string               `protobuf:"bytes,7,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

type MetaSync_FullSyncRequest struct {
	Header *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// deprecated
	// string temp = 2 ;
	Workspace string               `protobuf:"bytes,3,opt,name=workspace,proto3" json:"workspace,omitempty"`
	Type      string               `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Resource  []*MetaSync_Resource `protobuf:"bytes,5,rep,name=resource,proto3" json:"resource,omitempty"`
	Cluster   string               `protobuf:"bytes,6,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

type MetaSync_Resource struct {
	Name        string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace   string            `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Labels      map[string]string `` /* 153-byte string literal not displayed */
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// 下面几个指标, 并不是每种 resource 都有
	App      string `protobuf:"bytes,5,opt,name=app,proto3" json:"app,omitempty"`
	Ip       string `protobuf:"bytes,6,opt,name=ip,proto3" json:"ip,omitempty"`
	Hostname string `protobuf:"bytes,7,opt,name=hostname,proto3" json:"hostname,omitempty"`
	HostIP   string `protobuf:"bytes,8,opt,name=hostIP,proto3" json:"hostIP,omitempty"`
	// 通用字段, 需要根据type来解释
	Spec map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

type NotifyCollectConfigUpdatedRequest struct {
	Header *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// 以下参数二选一
	// 涉及的id
	Ids []string `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
	// 变更的表名
	TableNames []string `protobuf:"bytes,3,rep,name=table_names,json=tableNames,proto3" json:"table_names,omitempty"`
	// contains filtered or unexported fields
}

type NotifyCollectConfigUpdatedResponse struct {
	Header *pb.CommonResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

type PreviewFileRequest struct {
	Header  *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	AgentId string                  `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// 日志路径
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// 如果没有提供编码则agent会猜测编码
	Charset string `protobuf:"bytes,4,opt,name=charset,proto3" json:"charset,omitempty"`
	// 最多的行数
	MaxLines int32 `protobuf:"varint,5,opt,name=maxLines,proto3" json:"maxLines,omitempty"`
	// 最多的字节数
	MaxBytes int32 `protobuf:"varint,6,opt,name=maxBytes,proto3" json:"maxBytes,omitempty"`
	// contains filtered or unexported fields
}

type PreviewFileResponse struct {
	Header *pb.CommonResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// parsed log lines
	Content []string `protobuf:"bytes,2,rep,name=content,proto3" json:"content,omitempty"`
	// detected charset by agent
	Charset string `protobuf:"bytes,3,opt,name=charset,proto3" json:"charset,omitempty"`
	// detected timezone by agent
	Timezone string `protobuf:"bytes,4,opt,name=timezone,proto3" json:"timezone,omitempty"`
	// contains filtered or unexported fields
}

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

type RegisterAgentRequest struct {
	Header *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// 唯一识别该agent的id
	AgentId      string `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	AgentVersion string `protobuf:"bytes,3,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
	// 该agent的ip, 对于多网卡的场景需要想办法取到正确的ip地址
	// 比如应该排除docker0网卡上的ip, 具体可以参考一些java的NetUtils类
	Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"`
	// 主机名, 启动时缓存, 不用考虑主机名变化的case
	Hostname string `protobuf:"bytes,5,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// 见 golang 的 runtime.GOOS
	Os string `protobuf:"bytes,6,opt,name=os,proto3" json:"os,omitempty"`
	// 见 golang 的 runtime.GOARCH
	Arch string `protobuf:"bytes,7,opt,name=arch,proto3" json:"arch,omitempty"`
	// 其他扩展字段
	// TODO 具体有哪些以及来源都要明确文档
	// 比如我可以想到的, 如果发现用户跑在aws下
	// aws.instanceId
	// aws.type 规格, t3.large TODO 是不是叫这个名字 可能是有个专门的单词的
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// 关联的app
	App string `protobuf:"bytes,9,opt,name=app,proto3" json:"app,omitempty"`
	// k8s 场景下使用
	K8S *AgentK8SInfo `protobuf:"bytes,10,opt,name=k8s,proto3" json:"k8s,omitempty"`
	// sidecar daemonset clusteragent
	Mode      string `protobuf:"bytes,11,opt,name=mode,proto3" json:"mode,omitempty"`
	Workspace string `protobuf:"bytes,12,opt,name=workspace,proto3" json:"workspace,omitempty"`
	Cluster   string `protobuf:"bytes,13,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

type RegisterAgentResponse struct {
	Header *pb.CommonResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Tenant string                   `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// contains filtered or unexported fields
}

type RegistryServiceForAgentClient interface {
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// 向服务端注册一个agent, 每N时间执行一次, 携带的信息比较多
	RegisterAgent(ctx context.Context, in *RegisterAgentRequest, opts ...grpc.CallOption) (*RegisterAgentResponse, error)
	// 发送Agent心跳
	SendAgentHeartbeat(ctx context.Context, in *SendAgentHeartbeatRequest, opts ...grpc.CallOption) (*SendAgentHeartbeatResponse, error)
	// 发送Agent运行状态统计信息
	SendRunStats(ctx context.Context, in *RunStatsRequest, opts ...grpc.CallOption) (*RunStatsResponse, error)
	// 发送Agent运行状态事件信息
	SendRunEvents(ctx context.Context, in *RunEventsRequest, opts ...grpc.CallOption) (*RunEventsResponse, error)
	// 查询registry对该agent的控制参数
	GetControlConfigs(ctx context.Context, in *GetControlConfigsRequest, opts ...grpc.CallOption) (*GetControlConfigsResponse, error)
	// 查询采集配置
	GetCollectTasks(ctx context.Context, in *GetCollectTasksRequest, opts ...grpc.CallOption) (*GetCollectTasksResponse, error)
	// 双向流 用于实现反向调用, 实现 reverse rpc on grpc
	BiStreams(ctx context.Context, opts ...grpc.CallOption) (RegistryServiceForAgent_BiStreamsClient, error)
	MetaFullSync(ctx context.Context, in *MetaSync_FullSyncRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	MetaDeltaSync(ctx context.Context, in *MetaSync_DeltaSyncRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReportEvents(ctx context.Context, in *ReportEventRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type RegistryServiceForAgentServer interface {
	Ping(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// 向服务端注册一个agent, 每N时间执行一次, 携带的信息比较多
	RegisterAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error)
	// 发送Agent心跳
	SendAgentHeartbeat(context.Context, *SendAgentHeartbeatRequest) (*SendAgentHeartbeatResponse, error)
	// 发送Agent运行状态统计信息
	SendRunStats(context.Context, *RunStatsRequest) (*RunStatsResponse, error)
	// 发送Agent运行状态事件信息
	SendRunEvents(context.Context, *RunEventsRequest) (*RunEventsResponse, error)
	// 查询registry对该agent的控制参数
	GetControlConfigs(context.Context, *GetControlConfigsRequest) (*GetControlConfigsResponse, error)
	// 查询采集配置
	GetCollectTasks(context.Context, *GetCollectTasksRequest) (*GetCollectTasksResponse, error)
	// 双向流 用于实现反向调用, 实现 reverse rpc on grpc
	BiStreams(RegistryServiceForAgent_BiStreamsServer) error
	MetaFullSync(context.Context, *MetaSync_FullSyncRequest) (*emptypb.Empty, error)
	MetaDeltaSync(context.Context, *MetaSync_DeltaSyncRequest) (*emptypb.Empty, error)
	ReportEvents(context.Context, *ReportEventRequest) (*emptypb.Empty, error)
}

type RegistryServiceForAgent_BiStreamsClient interface {
	Send(*pb.GenericRpcCommand) error
	Recv() (*pb.GenericRpcCommand, error)
	grpc.ClientStream
}

type RegistryServiceForAgent_BiStreamsServer interface {
	Send(*pb.GenericRpcCommand) error
	Recv() (*pb.GenericRpcCommand, error)
	grpc.ServerStream
}

type ReportEventRequest struct {
	Header *pb.CommonRequestHeader     `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Events []*ReportEventRequest_Event `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type ReportEventRequest_Event struct {

	// event time
	BornTimestamp  int64 `protobuf:"varint,1,opt,name=born_timestamp,json=bornTimestamp,proto3" json:"born_timestamp,omitempty"`
	EventTimestamp int64 `protobuf:"varint,2,opt,name=event_timestamp,json=eventTimestamp,proto3" json:"event_timestamp,omitempty"`
	// event type: STAT/DIGEST/DEBUG
	// STAT: reports some Statistical indicators. strings must be empty.
	// DIGEST: reports important events when running. It can have numbers and strings
	// DEBUG: like digest, but only reported when debug mode is enabled.
	// LOG: logs
	EventType string `protobuf:"bytes,3,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	// event payload type
	PayloadType string `protobuf:"bytes,4,opt,name=payload_type,json=payloadType,proto3" json:"payload_type,omitempty"`
	// event tags, such tenant,agentIp,targetIp
	// event tags, numbers, and strings maps must have different keys.
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// event numbers
	Numbers map[string]int64 `` /* 156-byte string literal not displayed */
	// event strings
	Strings map[string]string `` /* 155-byte string literal not displayed */
	Logs    []string          `protobuf:"bytes,8,rep,name=logs,proto3" json:"logs,omitempty"`
	Json    string            `protobuf:"bytes,9,opt,name=json,proto3" json:"json,omitempty"`
	// contains filtered or unexported fields
}

type RunEvent struct {
	Type      string `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty"`
	Msg       string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	Timestamp int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type RunEventsRequest struct {
	Header  *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	AgentId string                  `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// key-eventType, value-eventMsg
	Events []*RunEvent `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type RunEventsResponse struct {
	Header *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

type RunStatsRequest struct {
	Header                *pb.CommonRequestHeader  `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	AgentId               string                   `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Timestamp             int64                    `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	AgentRunStats         map[string]uint64        `` /* 191-byte string literal not displayed */
	CollectConfigRunStats []*CollectConfigRunStats `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

type RunStatsResponse struct {
	Header *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

type SendAgentHeartbeatRequest struct {
	Header  *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	AgentId string                  `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// contains filtered or unexported fields
}

type SendAgentHeartbeatResponse struct {
	Header *pb.CommonResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

type SplitLogRequest struct {
	Header  *pb.CommonRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	AgentId string                  `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Content string                  `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	Regexp  string                  `protobuf:"bytes,4,opt,name=regexp,proto3" json:"regexp,omitempty"`
	// contains filtered or unexported fields
}

type SplitLogResponse struct {
	Header *pb.CommonResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Result map[string]string        `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}