pb

package
v0.0.0-...-5c7ffcf Latest Latest
Warning

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

 Go to latest Published: Jul 2, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_registry_pb_registry_for_agent_proto protoreflect.FileDescriptor
View Source 
var File_registry_pb_registry_for_prod_proto protoreflect.FileDescriptor
View Source 
var RegistryServiceForAgent_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "io.holoinsight.server.registry.grpc.agent.RegistryServiceForAgent",
	HandlerType: (*RegistryServiceForAgentServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ping",
			Handler:    _RegistryServiceForAgent_Ping_Handler,
		},
		{
			MethodName: "register_agent",
			Handler:    _RegistryServiceForAgent_RegisterAgent_Handler,
		},
		{
			MethodName: "send_agent_heartbeat",
			Handler:    _RegistryServiceForAgent_SendAgentHeartbeat_Handler,
		},
		{
			MethodName: "send_run_stats",
			Handler:    _RegistryServiceForAgent_SendRunStats_Handler,
		},
		{
			MethodName: "send_run_events",
			Handler:    _RegistryServiceForAgent_SendRunEvents_Handler,
		},
		{
			MethodName: "get_control_configs",
			Handler:    _RegistryServiceForAgent_GetControlConfigs_Handler,
		},
		{
			MethodName: "get_collect_tasks",
			Handler:    _RegistryServiceForAgent_GetCollectTasks_Handler,
		},
		{
			MethodName: "meta_full_sync",
			Handler:    _RegistryServiceForAgent_MetaFullSync_Handler,
		},
		{
			MethodName: "meta_delta_sync",
			Handler:    _RegistryServiceForAgent_MetaDeltaSync_Handler,
		},
		{
			MethodName: "report_events",
			Handler:    _RegistryServiceForAgent_ReportEvents_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "bi_streams",
			Handler:       _RegistryServiceForAgent_BiStreams_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "registry/pb/registry-for-agent.proto",
}

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

Functions

func RegisterRegistryServiceForAgentServer 

func RegisterRegistryServiceForAgentServer(s grpc.ServiceRegistrar, srv RegistryServiceForAgentServer)

Types

type Agent 

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
}

func (*Agent) Descriptor deprecated 

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

Deprecated: Use Agent.ProtoReflect.Descriptor instead.

func (*Agent) GetHostname 

func (x *Agent) GetHostname() string

func (*Agent) GetId 

func (x *Agent) GetId() string

func (*Agent) GetIp 

func (x *Agent) GetIp() string

func (*Agent) GetOther 

func (x *Agent) GetOther() map[string]string

func (*Agent) ProtoMessage 

func (*Agent) ProtoMessage()

func (*Agent) ProtoReflect 

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

func (*Agent) Reset 

func (x *Agent) Reset()

func (*Agent) String 

func (x *Agent) String() string

type AgentK8SInfo 

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
}

func (*AgentK8SInfo) Descriptor deprecated 

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

Deprecated: Use AgentK8SInfo.ProtoReflect.Descriptor instead.

func (*AgentK8SInfo) GetHostIp 

func (x *AgentK8SInfo) GetHostIp() string

func (*AgentK8SInfo) GetNamespace 

func (x *AgentK8SInfo) GetNamespace() string

func (*AgentK8SInfo) GetNodeHostname 

func (x *AgentK8SInfo) GetNodeHostname() string

func (*AgentK8SInfo) GetPod 

func (x *AgentK8SInfo) GetPod() string

func (*AgentK8SInfo) ProtoMessage 

func (*AgentK8SInfo) ProtoMessage()

func (*AgentK8SInfo) ProtoReflect 

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

func (*AgentK8SInfo) Reset 

func (x *AgentK8SInfo) Reset()

func (*AgentK8SInfo) String 

func (x *AgentK8SInfo) String() string

type BasicConfig 

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
}

TODO 具体有哪些配置很大程度取决于agent 以及服务端想要试下怎样的控制能力, 需要在实践中修改 基础配置

func (*BasicConfig) Descriptor deprecated 

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

Deprecated: Use BasicConfig.ProtoReflect.Descriptor instead.

func (*BasicConfig) GetHeartbeatIntervalSeconds 

func (x *BasicConfig) GetHeartbeatIntervalSeconds() int32

func (*BasicConfig) GetReonnectInterval 

func (x *BasicConfig) GetReonnectInterval() int32

func (*BasicConfig) GetSyncConfigsIntervalSeconds 

func (x *BasicConfig) GetSyncConfigsIntervalSeconds() int32

func (*BasicConfig) ProtoMessage 

func (*BasicConfig) ProtoMessage()

func (*BasicConfig) ProtoReflect 

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

func (*BasicConfig) Reset 

func (x *BasicConfig) Reset()

func (*BasicConfig) String 

func (x *BasicConfig) String() string

type BiStreamClientHandshakeRequest 

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
}

func (*BiStreamClientHandshakeRequest) Descriptor deprecated 

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

Deprecated: Use BiStreamClientHandshakeRequest.ProtoReflect.Descriptor instead.

func (*BiStreamClientHandshakeRequest) GetAgentId 

func (x *BiStreamClientHandshakeRequest) GetAgentId() string

func (*BiStreamClientHandshakeRequest) GetVersion 

func (x *BiStreamClientHandshakeRequest) GetVersion() int64

func (*BiStreamClientHandshakeRequest) ProtoMessage 

func (*BiStreamClientHandshakeRequest) ProtoMessage()

func (*BiStreamClientHandshakeRequest) ProtoReflect 

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

func (*BiStreamClientHandshakeRequest) Reset 

func (x *BiStreamClientHandshakeRequest) Reset()

func (*BiStreamClientHandshakeRequest) String 

func (x *BiStreamClientHandshakeRequest) String() string

type BiStreamClientHandshakeResponse 

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

func (*BiStreamClientHandshakeResponse) Descriptor deprecated 

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

Deprecated: Use BiStreamClientHandshakeResponse.ProtoReflect.Descriptor instead.

func (*BiStreamClientHandshakeResponse) GetHeader 

func (x *BiStreamClientHandshakeResponse) GetHeader() *pb.CommonResponseHeader

func (*BiStreamClientHandshakeResponse) ProtoMessage 

func (*BiStreamClientHandshakeResponse) ProtoMessage()

func (*BiStreamClientHandshakeResponse) ProtoReflect 

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

func (*BiStreamClientHandshakeResponse) Reset 

func (x *BiStreamClientHandshakeResponse) Reset()

func (*BiStreamClientHandshakeResponse) String 

func (x *BiStreamClientHandshakeResponse) String() string

type CheckConfigTaskDistributionRequest 

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
}

func (*CheckConfigTaskDistributionRequest) Descriptor deprecated 

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

Deprecated: Use CheckConfigTaskDistributionRequest.ProtoReflect.Descriptor instead.

func (*CheckConfigTaskDistributionRequest) GetHeader 

func (x *CheckConfigTaskDistributionRequest) GetHeader() *pb.CommonRequestHeader

func (*CheckConfigTaskDistributionRequest) GetSubTasks 

func (x *CheckConfigTaskDistributionRequest) GetSubTasks() []*CheckConfigTaskDistributionRequest_SubTask

func (*CheckConfigTaskDistributionRequest) ProtoMessage 

func (*CheckConfigTaskDistributionRequest) ProtoMessage()

func (*CheckConfigTaskDistributionRequest) ProtoReflect 

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

func (*CheckConfigTaskDistributionRequest) Reset 

func (x *CheckConfigTaskDistributionRequest) Reset()

func (*CheckConfigTaskDistributionRequest) String 

func (x *CheckConfigTaskDistributionRequest) String() string

type CheckConfigTaskDistributionRequest_SubTask 

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
}

func (*CheckConfigTaskDistributionRequest_SubTask) Descriptor deprecated 

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

Deprecated: Use CheckConfigTaskDistributionRequest_SubTask.ProtoReflect.Descriptor instead.

func (*CheckConfigTaskDistributionRequest_SubTask) GetConfigKey 

func (x *CheckConfigTaskDistributionRequest_SubTask) GetConfigKey() string

func (*CheckConfigTaskDistributionRequest_SubTask) GetConfigVersion 

func (x *CheckConfigTaskDistributionRequest_SubTask) GetConfigVersion() string

func (*CheckConfigTaskDistributionRequest_SubTask) GetTargetKey 

func (x *CheckConfigTaskDistributionRequest_SubTask) GetTargetKey() string

func (*CheckConfigTaskDistributionRequest_SubTask) GetTargetVersion 

func (x *CheckConfigTaskDistributionRequest_SubTask) GetTargetVersion() string

func (*CheckConfigTaskDistributionRequest_SubTask) ProtoMessage 

func (*CheckConfigTaskDistributionRequest_SubTask) ProtoMessage()

func (*CheckConfigTaskDistributionRequest_SubTask) ProtoReflect 

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

func (*CheckConfigTaskDistributionRequest_SubTask) Reset 

func (x *CheckConfigTaskDistributionRequest_SubTask) Reset()

func (*CheckConfigTaskDistributionRequest_SubTask) String 

func (x *CheckConfigTaskDistributionRequest_SubTask) String() string

type CheckConfigTaskDistributionResponse 

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
}

func (*CheckConfigTaskDistributionResponse) Descriptor deprecated 

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

Deprecated: Use CheckConfigTaskDistributionResponse.ProtoReflect.Descriptor instead.

func (*CheckConfigTaskDistributionResponse) GetHeader 

func (x *CheckConfigTaskDistributionResponse) GetHeader() *pb.CommonResponseHeader

func (*CheckConfigTaskDistributionResponse) GetStatus 

func (x *CheckConfigTaskDistributionResponse) GetStatus() []int32

func (*CheckConfigTaskDistributionResponse) ProtoMessage 

func (*CheckConfigTaskDistributionResponse) ProtoMessage()

func (*CheckConfigTaskDistributionResponse) ProtoReflect 

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

func (*CheckConfigTaskDistributionResponse) Reset 

func (x *CheckConfigTaskDistributionResponse) Reset()

func (*CheckConfigTaskDistributionResponse) String 

func (x *CheckConfigTaskDistributionResponse) String() string

type CollectConfig 

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
}

一个采集配置

func (*CollectConfig) Descriptor deprecated 

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

Deprecated: Use CollectConfig.ProtoReflect.Descriptor instead.

func (*CollectConfig) GetContent 

func (x *CollectConfig) GetContent() []byte

func (*CollectConfig) GetKey 

func (x *CollectConfig) GetKey() string

func (*CollectConfig) GetType 

func (x *CollectConfig) GetType() string

func (*CollectConfig) GetVersion 

func (x *CollectConfig) GetVersion() string

func (*CollectConfig) ProtoMessage 

func (*CollectConfig) ProtoMessage()

func (*CollectConfig) ProtoReflect 

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

func (*CollectConfig) Reset 

func (x *CollectConfig) Reset()

func (*CollectConfig) String 

func (x *CollectConfig) String() string

type CollectConfigRunStats 

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
}

func (*CollectConfigRunStats) Descriptor deprecated 

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

Deprecated: Use CollectConfigRunStats.ProtoReflect.Descriptor instead.

func (*CollectConfigRunStats) GetStats 

func (x *CollectConfigRunStats) GetStats() map[string]uint64

func (*CollectConfigRunStats) GetTableName 

func (x *CollectConfigRunStats) GetTableName() string

func (*CollectConfigRunStats) ProtoMessage 

func (*CollectConfigRunStats) ProtoMessage()

func (*CollectConfigRunStats) ProtoReflect 

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

func (*CollectConfigRunStats) Reset 

func (x *CollectConfigRunStats) Reset()

func (*CollectConfigRunStats) String 

func (x *CollectConfigRunStats) String() string

type CollectConfigsBucket 

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
}

func (*CollectConfigsBucket) Descriptor deprecated 

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

Deprecated: Use CollectConfigsBucket.ProtoReflect.Descriptor instead.

func (*CollectConfigsBucket) GetCollectTasks 

func (x *CollectConfigsBucket) GetCollectTasks() []*CollectTask

func (*CollectConfigsBucket) GetState 

func (x *CollectConfigsBucket) GetState() string

func (*CollectConfigsBucket) ProtoMessage 

func (*CollectConfigsBucket) ProtoMessage()

func (*CollectConfigsBucket) ProtoReflect 

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

func (*CollectConfigsBucket) Reset 

func (x *CollectConfigsBucket) Reset()

func (*CollectConfigsBucket) String 

func (x *CollectConfigsBucket) String() string

type CollectTarget 

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
}

采集目标

func (*CollectTarget) Descriptor deprecated 

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

Deprecated: Use CollectTarget.ProtoReflect.Descriptor instead.

func (*CollectTarget) GetKey 

func (x *CollectTarget) GetKey() string

func (*CollectTarget) GetMeta 

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

func (*CollectTarget) GetType 

func (x *CollectTarget) GetType() string

func (*CollectTarget) GetVersion 

func (x *CollectTarget) GetVersion() string

func (*CollectTarget) ProtoMessage 

func (*CollectTarget) ProtoMessage()

func (*CollectTarget) ProtoReflect 

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

func (*CollectTarget) Reset 

func (x *CollectTarget) Reset()

func (*CollectTarget) String 

func (x *CollectTarget) String() string

type CollectTask 

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
}

一个采集任务 = 采集配置 + 采集目标 的结合体

func (*CollectTask) Descriptor deprecated 

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

Deprecated: Use CollectTask.ProtoReflect.Descriptor instead.

func (*CollectTask) GetCollectConfigKey 

func (x *CollectTask) GetCollectConfigKey() string

func (*CollectTask) GetCollectTargetKey 

func (x *CollectTask) GetCollectTargetKey() string

func (*CollectTask) GetKey 

func (x *CollectTask) GetKey() string

func (*CollectTask) ProtoMessage 

func (*CollectTask) ProtoMessage()

func (*CollectTask) ProtoReflect 

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

func (*CollectTask) Reset 

func (x *CollectTask) Reset()

func (*CollectTask) String 

func (x *CollectTask) String() string

type CollectTask2 

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
}

func (*CollectTask2) Descriptor deprecated 

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

Deprecated: Use CollectTask2.ProtoReflect.Descriptor instead.

func (*CollectTask2) GetConfig 

func (x *CollectTask2) GetConfig() *CollectConfig

func (*CollectTask2) GetTarget 

func (x *CollectTask2) GetTarget() *CollectTarget

func (*CollectTask2) GetVersion 

func (x *CollectTask2) GetVersion() string

func (*CollectTask2) ProtoMessage 

func (*CollectTask2) ProtoMessage()

func (*CollectTask2) ProtoReflect 

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

func (*CollectTask2) Reset 

func (x *CollectTask2) Reset()

func (*CollectTask2) String 

func (x *CollectTask2) String() string

type DebugConfig 

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
}

调试相关的配置

func (*DebugConfig) Descriptor deprecated 

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

Deprecated: Use DebugConfig.ProtoReflect.Descriptor instead.

func (*DebugConfig) GetLogVerbose 

func (x *DebugConfig) GetLogVerbose() bool

func (*DebugConfig) GetReportDisable 

func (x *DebugConfig) GetReportDisable() bool

func (*DebugConfig) GetReportProcessingErrorCount 

func (x *DebugConfig) GetReportProcessingErrorCount() int32

func (*DebugConfig) ProtoMessage 

func (*DebugConfig) ProtoMessage()

func (*DebugConfig) ProtoReflect 

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

func (*DebugConfig) Reset 

func (x *DebugConfig) Reset()

func (*DebugConfig) String 

func (x *DebugConfig) String() string

type DryRunRequest 

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
}

dry run

func (*DryRunRequest) Descriptor deprecated 

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

Deprecated: Use DryRunRequest.ProtoReflect.Descriptor instead.

func (*DryRunRequest) GetConfig 

func (x *DryRunRequest) GetConfig() *DryRunRequest_CollectConfig

func (*DryRunRequest) GetHeader 

func (x *DryRunRequest) GetHeader() *pb.CommonRequestHeader

func (*DryRunRequest) GetInput 

func (x *DryRunRequest) GetInput() *DryRunRequest_Input

func (*DryRunRequest) GetTarget 

func (x *DryRunRequest) GetTarget() *TargetIdentifier

func (*DryRunRequest) ProtoMessage 

func (*DryRunRequest) ProtoMessage()

func (*DryRunRequest) ProtoReflect 

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

func (*DryRunRequest) Reset 

func (x *DryRunRequest) Reset()

func (*DryRunRequest) String 

func (x *DryRunRequest) String() string

type DryRunRequest_CollectConfig 

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
}

func (*DryRunRequest_CollectConfig) Descriptor deprecated 

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

Deprecated: Use DryRunRequest_CollectConfig.ProtoReflect.Descriptor instead.

func (*DryRunRequest_CollectConfig) GetTableName 

func (x *DryRunRequest_CollectConfig) GetTableName() string

func (*DryRunRequest_CollectConfig) GetTemp 

func (x *DryRunRequest_CollectConfig) GetTemp() *DryRunRequest_CollectConfigTemp

func (*DryRunRequest_CollectConfig) GetType 

func (x *DryRunRequest_CollectConfig) GetType() string

func (*DryRunRequest_CollectConfig) ProtoMessage 

func (*DryRunRequest_CollectConfig) ProtoMessage()

func (*DryRunRequest_CollectConfig) ProtoReflect 

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

func (*DryRunRequest_CollectConfig) Reset 

func (x *DryRunRequest_CollectConfig) Reset()

func (*DryRunRequest_CollectConfig) String 

func (x *DryRunRequest_CollectConfig) String() string

type DryRunRequest_CollectConfigTemp 

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
}

message InputRead {}

func (*DryRunRequest_CollectConfigTemp) Descriptor deprecated 

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

Deprecated: Use DryRunRequest_CollectConfigTemp.ProtoReflect.Descriptor instead.

func (*DryRunRequest_CollectConfigTemp) GetCollectRange 

func (x *DryRunRequest_CollectConfigTemp) GetCollectRange() string

func (*DryRunRequest_CollectConfigTemp) GetExecutorSelector 

func (x *DryRunRequest_CollectConfigTemp) GetExecutorSelector() string

func (*DryRunRequest_CollectConfigTemp) GetJson 

func (x *DryRunRequest_CollectConfigTemp) GetJson() string

func (*DryRunRequest_CollectConfigTemp) GetType 

func (x *DryRunRequest_CollectConfigTemp) GetType() string

func (*DryRunRequest_CollectConfigTemp) ProtoMessage 

func (*DryRunRequest_CollectConfigTemp) ProtoMessage()

func (*DryRunRequest_CollectConfigTemp) ProtoReflect 

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

func (*DryRunRequest_CollectConfigTemp) Reset 

func (x *DryRunRequest_CollectConfigTemp) Reset()

func (*DryRunRequest_CollectConfigTemp) String 

func (x *DryRunRequest_CollectConfigTemp) String() string

type DryRunRequest_Input 

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
}

func (*DryRunRequest_Input) Descriptor deprecated 

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

Deprecated: Use DryRunRequest_Input.ProtoReflect.Descriptor instead.

func (*DryRunRequest_Input) GetPlain 

func (x *DryRunRequest_Input) GetPlain() *DryRunRequest_InputPlain

func (*DryRunRequest_Input) GetType 

func (x *DryRunRequest_Input) GetType() string

func (*DryRunRequest_Input) ProtoMessage 

func (*DryRunRequest_Input) ProtoMessage()

func (*DryRunRequest_Input) ProtoReflect 

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

func (*DryRunRequest_Input) Reset 

func (x *DryRunRequest_Input) Reset()

func (*DryRunRequest_Input) String 

func (x *DryRunRequest_Input) String() string

type DryRunRequest_InputPlain 

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
}

func (*DryRunRequest_InputPlain) Descriptor deprecated 

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

Deprecated: Use DryRunRequest_InputPlain.ProtoReflect.Descriptor instead.

func (*DryRunRequest_InputPlain) GetLines 

func (x *DryRunRequest_InputPlain) GetLines() []string

func (*DryRunRequest_InputPlain) GetTimezone 

func (x *DryRunRequest_InputPlain) GetTimezone() string

func (*DryRunRequest_InputPlain) ProtoMessage 

func (*DryRunRequest_InputPlain) ProtoMessage()

func (*DryRunRequest_InputPlain) ProtoReflect 

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

func (*DryRunRequest_InputPlain) Reset 

func (x *DryRunRequest_InputPlain) Reset()

func (*DryRunRequest_InputPlain) String 

func (x *DryRunRequest_InputPlain) String() string

type DryRunResponse 

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
}

func (*DryRunResponse) Descriptor deprecated 

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

Deprecated: Use DryRunResponse.ProtoReflect.Descriptor instead.

func (*DryRunResponse) GetEvent 

func (x *DryRunResponse) GetEvent() *DryRunResponse_Event

func (*DryRunResponse) GetGroupResults 

func (x *DryRunResponse) GetGroupResults() []*DryRunResponse_GroupResult

func (*DryRunResponse) GetHeader 

func (x *DryRunResponse) GetHeader() *pb.CommonResponseHeader

func (*DryRunResponse) ProtoMessage 

func (*DryRunResponse) ProtoMessage()

func (*DryRunResponse) ProtoReflect 

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

func (*DryRunResponse) Reset 

func (x *DryRunResponse) Reset()

func (*DryRunResponse) String 

func (x *DryRunResponse) String() string

type DryRunResponse_Event 

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
}

func (*DryRunResponse_Event) Descriptor deprecated 

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

Deprecated: Use DryRunResponse_Event.ProtoReflect.Descriptor instead.

func (*DryRunResponse_Event) GetChildren 

func (x *DryRunResponse_Event) GetChildren() []*DryRunResponse_Event

func (*DryRunResponse_Event) GetMessage 

func (x *DryRunResponse_Event) GetMessage() []*DryRunResponse_Message

func (*DryRunResponse_Event) GetParams 

func (x *DryRunResponse_Event) GetParams() map[string]string

func (*DryRunResponse_Event) GetTitle 

func (x *DryRunResponse_Event) GetTitle() string

func (*DryRunResponse_Event) ProtoMessage 

func (*DryRunResponse_Event) ProtoMessage()

func (*DryRunResponse_Event) ProtoReflect 

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

func (*DryRunResponse_Event) Reset 

func (x *DryRunResponse_Event) Reset()

func (*DryRunResponse_Event) String 

func (x *DryRunResponse_Event) String() string

type DryRunResponse_GroupResult 

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
}

func (*DryRunResponse_GroupResult) Descriptor deprecated 

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

Deprecated: Use DryRunResponse_GroupResult.ProtoReflect.Descriptor instead.

func (*DryRunResponse_GroupResult) GetGroupBy 

func (x *DryRunResponse_GroupResult) GetGroupBy() map[string]string

func (*DryRunResponse_GroupResult) GetGroupLines 

func (x *DryRunResponse_GroupResult) GetGroupLines() []string

func (*DryRunResponse_GroupResult) GetSelectedValues 

func (x *DryRunResponse_GroupResult) GetSelectedValues() map[string]float64

func (*DryRunResponse_GroupResult) GetSuccess 

func (x *DryRunResponse_GroupResult) GetSuccess() bool

func (*DryRunResponse_GroupResult) ProtoMessage 

func (*DryRunResponse_GroupResult) ProtoMessage()

func (*DryRunResponse_GroupResult) ProtoReflect 

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

func (*DryRunResponse_GroupResult) Reset 

func (x *DryRunResponse_GroupResult) Reset()

func (*DryRunResponse_GroupResult) String 

func (x *DryRunResponse_GroupResult) String() string

type DryRunResponse_Message 

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
}

func (*DryRunResponse_Message) Descriptor deprecated 

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

Deprecated: Use DryRunResponse_Message.ProtoReflect.Descriptor instead.

func (*DryRunResponse_Message) GetContent 

func (x *DryRunResponse_Message) GetContent() string

func (*DryRunResponse_Message) GetLevel 

func (x *DryRunResponse_Message) GetLevel() string

func (*DryRunResponse_Message) ProtoMessage 

func (*DryRunResponse_Message) ProtoMessage()

func (*DryRunResponse_Message) ProtoReflect 

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

func (*DryRunResponse_Message) Reset 

func (x *DryRunResponse_Message) Reset()

func (*DryRunResponse_Message) String 

func (x *DryRunResponse_Message) String() string

type GetCollectTasksRequest 

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
}

同步配置的请求 之类展开说一下同步配置的细节: 1. 该接口做的是全量同步 2. 最简单的做法是返回的配置是一个数组 [{...}] 3. 但显然这样返回的内容会有点多, 每次哪怕只有1个元素变了, 也要返回所有元素 (这在域外可能是可以接受的, 配置少), 但在主站是不太好的 4. 这在公有云上也不太好, 因为SLB可能是按流量收费的 5. 所以要像办法减少传输的数据量, 只传输必要的数据(但方案又不能太复杂 于是有了如下的buckets分桶方案 1. 将配置分在若干个桶里即 map<string, [{}]>, agent不用管桶的key是如何决定的, 对agent来说就是一个字符串而已 2. registry侧决定桶的key的具体取值, 比如在主站(对于vessel)可以取agentIp, 按agentIp分桶, 对于域外, 如果认为配置数不多, 那么可以总是取为 "", 这样相当于不分桶 3. registry会保证, 对于同一个配置始终是在一个桶里, 也就是说这个分配的算法是不能改变的 4. 该方案实际上只是通过分桶减少了发生改变时需要传递的数据量, 但并没有完全减少不必要的传输 5. 想做到理想的完全避免不必要的传输, 则双方需要交换 task keys, 通过对比新旧 task keys 决定出哪些 tasks 需要变更; 这个流程比较繁琐, 在云上不一定要实现

func (*GetCollectTasksRequest) Descriptor deprecated 

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

Deprecated: Use GetCollectTasksRequest.ProtoReflect.Descriptor instead.

func (*GetCollectTasksRequest) GetAgentId 

func (x *GetCollectTasksRequest) GetAgentId() string

func (*GetCollectTasksRequest) GetBuckets 

func (x *GetCollectTasksRequest) GetBuckets() map[string]string

func (*GetCollectTasksRequest) GetHeader 

func (x *GetCollectTasksRequest) GetHeader() *pb.CommonRequestHeader

func (*GetCollectTasksRequest) ProtoMessage 

func (*GetCollectTasksRequest) ProtoMessage()

func (*GetCollectTasksRequest) ProtoReflect 

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

func (*GetCollectTasksRequest) Reset 

func (x *GetCollectTasksRequest) Reset()

func (*GetCollectTasksRequest) String 

func (x *GetCollectTasksRequest) String() string

type GetCollectTasksResponse 

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
}

func (*GetCollectTasksResponse) Descriptor deprecated 

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

Deprecated: Use GetCollectTasksResponse.ProtoReflect.Descriptor instead.

func (*GetCollectTasksResponse) GetBuckets 

func (x *GetCollectTasksResponse) GetBuckets() map[string]*CollectConfigsBucket

func (*GetCollectTasksResponse) GetCollectConfigs 

func (x *GetCollectTasksResponse) GetCollectConfigs() map[string]*CollectConfig

func (*GetCollectTasksResponse) GetCollectTargets 

func (x *GetCollectTasksResponse) GetCollectTargets() map[string]*CollectTarget

func (*GetCollectTasksResponse) GetHeader 

func (x *GetCollectTasksResponse) GetHeader() *pb.CommonResponseHeader

func (*GetCollectTasksResponse) ProtoMessage 

func (*GetCollectTasksResponse) ProtoMessage()

func (*GetCollectTasksResponse) ProtoReflect 

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

func (*GetCollectTasksResponse) Reset 

func (x *GetCollectTasksResponse) Reset()

func (*GetCollectTasksResponse) String 

func (x *GetCollectTasksResponse) String() string

type GetControlConfigsRequest 

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
}

func (*GetControlConfigsRequest) Descriptor deprecated 

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

Deprecated: Use GetControlConfigsRequest.ProtoReflect.Descriptor instead.

func (*GetControlConfigsRequest) GetAgentId 

func (x *GetControlConfigsRequest) GetAgentId() string

func (*GetControlConfigsRequest) GetHeader 

func (x *GetControlConfigsRequest) GetHeader() *pb.CommonRequestHeader

func (*GetControlConfigsRequest) ProtoMessage 

func (*GetControlConfigsRequest) ProtoMessage()

func (*GetControlConfigsRequest) ProtoReflect 

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

func (*GetControlConfigsRequest) Reset 

func (x *GetControlConfigsRequest) Reset()

func (*GetControlConfigsRequest) String 

func (x *GetControlConfigsRequest) String() string

type GetControlConfigsResponse 

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
}

func (*GetControlConfigsResponse) Descriptor deprecated 

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

Deprecated: Use GetControlConfigsResponse.ProtoReflect.Descriptor instead.

func (*GetControlConfigsResponse) GetBasicConfig 

func (x *GetControlConfigsResponse) GetBasicConfig() *BasicConfig

func (*GetControlConfigsResponse) GetDebugConfig 

func (x *GetControlConfigsResponse) GetDebugConfig() *DebugConfig

func (*GetControlConfigsResponse) GetHeader 

func (x *GetControlConfigsResponse) GetHeader() *pb.CommonResponseHeader

func (*GetControlConfigsResponse) ProtoMessage 

func (*GetControlConfigsResponse) ProtoMessage()

func (*GetControlConfigsResponse) ProtoReflect 

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

func (*GetControlConfigsResponse) Reset 

func (x *GetControlConfigsResponse) Reset()

func (*GetControlConfigsResponse) String 

func (x *GetControlConfigsResponse) String() string

type HttpProxyRequest 

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
}

func (*HttpProxyRequest) Descriptor deprecated 

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

Deprecated: Use HttpProxyRequest.ProtoReflect.Descriptor instead.

func (*HttpProxyRequest) GetAgentId 

func (x *HttpProxyRequest) GetAgentId() string

func (*HttpProxyRequest) GetBody 

func (x *HttpProxyRequest) GetBody() []byte

func (*HttpProxyRequest) GetHeader 

func (x *HttpProxyRequest) GetHeader() *pb.CommonRequestHeader

func (*HttpProxyRequest) GetHeaders 

func (x *HttpProxyRequest) GetHeaders() map[string]string

func (*HttpProxyRequest) GetMethod 

func (x *HttpProxyRequest) GetMethod() string

func (*HttpProxyRequest) GetUrl 

func (x *HttpProxyRequest) GetUrl() string

func (*HttpProxyRequest) ProtoMessage 

func (*HttpProxyRequest) ProtoMessage()

func (*HttpProxyRequest) ProtoReflect 

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

func (*HttpProxyRequest) Reset 

func (x *HttpProxyRequest) Reset()

func (*HttpProxyRequest) String 

func (x *HttpProxyRequest) String() string

type HttpProxyResponse 

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
}

func (*HttpProxyResponse) Descriptor deprecated 

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

Deprecated: Use HttpProxyResponse.ProtoReflect.Descriptor instead.

func (*HttpProxyResponse) GetBody 

func (x *HttpProxyResponse) GetBody() []byte

func (*HttpProxyResponse) GetCode 

func (x *HttpProxyResponse) GetCode() int32

func (*HttpProxyResponse) GetCost 

func (x *HttpProxyResponse) GetCost() int32

func (*HttpProxyResponse) GetHeader 

func (x *HttpProxyResponse) GetHeader() *pb.CommonResponseHeader

func (*HttpProxyResponse) GetHeaders 

func (x *HttpProxyResponse) GetHeaders() map[string]string

func (*HttpProxyResponse) ProtoMessage 

func (*HttpProxyResponse) ProtoMessage()

func (*HttpProxyResponse) ProtoReflect 

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

func (*HttpProxyResponse) Reset 

func (x *HttpProxyResponse) Reset()

func (*HttpProxyResponse) String 

func (x *HttpProxyResponse) String() string

type InspectRequest 

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
}

func (*InspectRequest) Descriptor deprecated 

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

Deprecated: Use InspectRequest.ProtoReflect.Descriptor instead.

func (*InspectRequest) GetAgentId 

func (x *InspectRequest) GetAgentId() string

func (*InspectRequest) GetHeader 

func (x *InspectRequest) GetHeader() *pb.CommonRequestHeader

func (*InspectRequest) ProtoMessage 

func (*InspectRequest) ProtoMessage()

func (*InspectRequest) ProtoReflect 

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

func (*InspectRequest) Reset 

func (x *InspectRequest) Reset()

func (*InspectRequest) String 

func (x *InspectRequest) String() string

type InspectResponse 

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
}

func (*InspectResponse) Descriptor deprecated 

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

Deprecated: Use InspectResponse.ProtoReflect.Descriptor instead.

func (*InspectResponse) GetHeader 

func (x *InspectResponse) GetHeader() *pb.CommonResponseHeader

func (*InspectResponse) GetResult 

func (x *InspectResponse) GetResult() string

func (*InspectResponse) ProtoMessage 

func (*InspectResponse) ProtoMessage()

func (*InspectResponse) ProtoReflect 

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

func (*InspectResponse) Reset 

func (x *InspectResponse) Reset()

func (*InspectResponse) String 

func (x *InspectResponse) String() string

type ListFilesRequest 

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
}

func (*ListFilesRequest) Descriptor deprecated 

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

Deprecated: Use ListFilesRequest.ProtoReflect.Descriptor instead.

func (*ListFilesRequest) GetAgentId 

func (x *ListFilesRequest) GetAgentId() string

func (*ListFilesRequest) GetHeader 

func (x *ListFilesRequest) GetHeader() *pb.CommonRequestHeader

func (*ListFilesRequest) GetIncludeExts 

func (x *ListFilesRequest) GetIncludeExts() []string

func (*ListFilesRequest) GetIncludeParents 

func (x *ListFilesRequest) GetIncludeParents() bool

func (*ListFilesRequest) GetMaxDepth 

func (x *ListFilesRequest) GetMaxDepth() int32

func (*ListFilesRequest) GetName 

func (x *ListFilesRequest) GetName() string

func (*ListFilesRequest) ProtoMessage 

func (*ListFilesRequest) ProtoMessage()

func (*ListFilesRequest) ProtoReflect 

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

func (*ListFilesRequest) Reset 

func (x *ListFilesRequest) Reset()

func (*ListFilesRequest) String 

func (x *ListFilesRequest) String() string

type ListFilesResponse 

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
}

func (*ListFilesResponse) Descriptor deprecated 

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

Deprecated: Use ListFilesResponse.ProtoReflect.Descriptor instead.

func (*ListFilesResponse) GetHeader 

func (x *ListFilesResponse) GetHeader() *pb.CommonResponseHeader

func (*ListFilesResponse) GetNodes 

func (x *ListFilesResponse) GetNodes() []*pb.FileNode

func (*ListFilesResponse) ProtoMessage 

func (*ListFilesResponse) ProtoMessage()

func (*ListFilesResponse) ProtoReflect 

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

func (*ListFilesResponse) Reset 

func (x *ListFilesResponse) Reset()

func (*ListFilesResponse) String 

func (x *ListFilesResponse) String() string

type MatchFilesRequest 

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
}

func (*MatchFilesRequest) Descriptor deprecated 

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

Deprecated: Use MatchFilesRequest.ProtoReflect.Descriptor instead.

func (*MatchFilesRequest) GetAgentId 

func (x *MatchFilesRequest) GetAgentId() string

func (*MatchFilesRequest) GetDir 

func (x *MatchFilesRequest) GetDir() string

func (*MatchFilesRequest) GetHeader 

func (x *MatchFilesRequest) GetHeader() *pb.CommonRequestHeader

func (*MatchFilesRequest) GetMaxMatched 

func (x *MatchFilesRequest) GetMaxMatched() int32

func (*MatchFilesRequest) GetMaxVisited 

func (x *MatchFilesRequest) GetMaxVisited() int32

func (*MatchFilesRequest) GetPattern 

func (x *MatchFilesRequest) GetPattern() string

func (*MatchFilesRequest) GetType 

func (x *MatchFilesRequest) GetType() string

func (*MatchFilesRequest) ProtoMessage 

func (*MatchFilesRequest) ProtoMessage()

func (*MatchFilesRequest) ProtoReflect 

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

func (*MatchFilesRequest) Reset 

func (x *MatchFilesRequest) Reset()

func (*MatchFilesRequest) String 

func (x *MatchFilesRequest) String() string

type MatchFilesResponse 

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
}

func (*MatchFilesResponse) Descriptor deprecated 

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

Deprecated: Use MatchFilesResponse.ProtoReflect.Descriptor instead.

func (*MatchFilesResponse) GetFiles 

func (x *MatchFilesResponse) GetFiles() []string

func (*MatchFilesResponse) GetHeader 

func (x *MatchFilesResponse) GetHeader() *pb.CommonResponseHeader

func (*MatchFilesResponse) GetVisited 

func (x *MatchFilesResponse) GetVisited() int32

func (*MatchFilesResponse) ProtoMessage 

func (*MatchFilesResponse) ProtoMessage()

func (*MatchFilesResponse) ProtoReflect 

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

func (*MatchFilesResponse) Reset 

func (x *MatchFilesResponse) Reset()

func (*MatchFilesResponse) String 

func (x *MatchFilesResponse) String() string

type MetaSync 

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

func (*MetaSync) Descriptor deprecated 

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

Deprecated: Use MetaSync.ProtoReflect.Descriptor instead.

func (*MetaSync) ProtoMessage 

func (*MetaSync) ProtoMessage()

func (*MetaSync) ProtoReflect 

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

func (*MetaSync) Reset 

func (x *MetaSync) Reset()

func (*MetaSync) String 

func (x *MetaSync) String() string

type MetaSync_DeltaSyncRequest 

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
}

func (*MetaSync_DeltaSyncRequest) Descriptor deprecated 

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

Deprecated: Use MetaSync_DeltaSyncRequest.ProtoReflect.Descriptor instead.

func (*MetaSync_DeltaSyncRequest) GetAdd 

func (x *MetaSync_DeltaSyncRequest) GetAdd() []*MetaSync_Resource

func (*MetaSync_DeltaSyncRequest) GetCluster 

func (x *MetaSync_DeltaSyncRequest) GetCluster() string

func (*MetaSync_DeltaSyncRequest) GetDel 

func (x *MetaSync_DeltaSyncRequest) GetDel() []*MetaSync_Resource

func (*MetaSync_DeltaSyncRequest) GetHeader 

func (x *MetaSync_DeltaSyncRequest) GetHeader() *pb.CommonRequestHeader

func (*MetaSync_DeltaSyncRequest) GetType 

func (x *MetaSync_DeltaSyncRequest) GetType() string

func (*MetaSync_DeltaSyncRequest) GetWorkspace 

func (x *MetaSync_DeltaSyncRequest) GetWorkspace() string

func (*MetaSync_DeltaSyncRequest) ProtoMessage 

func (*MetaSync_DeltaSyncRequest) ProtoMessage()

func (*MetaSync_DeltaSyncRequest) ProtoReflect 

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

func (*MetaSync_DeltaSyncRequest) Reset 

func (x *MetaSync_DeltaSyncRequest) Reset()

func (*MetaSync_DeltaSyncRequest) String 

func (x *MetaSync_DeltaSyncRequest) String() string

type MetaSync_FullSyncRequest 

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
}

func (*MetaSync_FullSyncRequest) Descriptor deprecated 

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

Deprecated: Use MetaSync_FullSyncRequest.ProtoReflect.Descriptor instead.

func (*MetaSync_FullSyncRequest) GetCluster 

func (x *MetaSync_FullSyncRequest) GetCluster() string

func (*MetaSync_FullSyncRequest) GetHeader 

func (x *MetaSync_FullSyncRequest) GetHeader() *pb.CommonRequestHeader

func (*MetaSync_FullSyncRequest) GetResource 

func (x *MetaSync_FullSyncRequest) GetResource() []*MetaSync_Resource

func (*MetaSync_FullSyncRequest) GetType 

func (x *MetaSync_FullSyncRequest) GetType() string

func (*MetaSync_FullSyncRequest) GetWorkspace 

func (x *MetaSync_FullSyncRequest) GetWorkspace() string

func (*MetaSync_FullSyncRequest) ProtoMessage 

func (*MetaSync_FullSyncRequest) ProtoMessage()

func (*MetaSync_FullSyncRequest) ProtoReflect 

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

func (*MetaSync_FullSyncRequest) Reset 

func (x *MetaSync_FullSyncRequest) Reset()

func (*MetaSync_FullSyncRequest) String 

func (x *MetaSync_FullSyncRequest) String() string

type MetaSync_Resource 

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
}

func (*MetaSync_Resource) Descriptor deprecated 

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

Deprecated: Use MetaSync_Resource.ProtoReflect.Descriptor instead.

func (*MetaSync_Resource) GetAnnotations 

func (x *MetaSync_Resource) GetAnnotations() map[string]string

func (*MetaSync_Resource) GetApp 

func (x *MetaSync_Resource) GetApp() string

func (*MetaSync_Resource) GetHostIP 

func (x *MetaSync_Resource) GetHostIP() string

func (*MetaSync_Resource) GetHostname 

func (x *MetaSync_Resource) GetHostname() string

func (*MetaSync_Resource) GetIp 

func (x *MetaSync_Resource) GetIp() string

func (*MetaSync_Resource) GetLabels 

func (x *MetaSync_Resource) GetLabels() map[string]string

func (*MetaSync_Resource) GetName 

func (x *MetaSync_Resource) GetName() string

func (*MetaSync_Resource) GetNamespace 

func (x *MetaSync_Resource) GetNamespace() string

func (*MetaSync_Resource) GetSpec 

func (x *MetaSync_Resource) GetSpec() map[string]string

func (*MetaSync_Resource) ProtoMessage 

func (*MetaSync_Resource) ProtoMessage()

func (*MetaSync_Resource) ProtoReflect 

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

func (*MetaSync_Resource) Reset 

func (x *MetaSync_Resource) Reset()

func (*MetaSync_Resource) String 

func (x *MetaSync_Resource) String() string

type NotifyCollectConfigUpdatedRequest 

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
}

通知配置变更

func (*NotifyCollectConfigUpdatedRequest) Descriptor deprecated 

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

Deprecated: Use NotifyCollectConfigUpdatedRequest.ProtoReflect.Descriptor instead.

func (*NotifyCollectConfigUpdatedRequest) GetHeader 

func (x *NotifyCollectConfigUpdatedRequest) GetHeader() *pb.CommonRequestHeader

func (*NotifyCollectConfigUpdatedRequest) GetIds 

func (x *NotifyCollectConfigUpdatedRequest) GetIds() []string

func (*NotifyCollectConfigUpdatedRequest) GetTableNames 

func (x *NotifyCollectConfigUpdatedRequest) GetTableNames() []string

func (*NotifyCollectConfigUpdatedRequest) ProtoMessage 

func (*NotifyCollectConfigUpdatedRequest) ProtoMessage()

func (*NotifyCollectConfigUpdatedRequest) ProtoReflect 

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

func (*NotifyCollectConfigUpdatedRequest) Reset 

func (x *NotifyCollectConfigUpdatedRequest) Reset()

func (*NotifyCollectConfigUpdatedRequest) String 

func (x *NotifyCollectConfigUpdatedRequest) String() string

type NotifyCollectConfigUpdatedResponse 

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

func (*NotifyCollectConfigUpdatedResponse) Descriptor deprecated 

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

Deprecated: Use NotifyCollectConfigUpdatedResponse.ProtoReflect.Descriptor instead.

func (*NotifyCollectConfigUpdatedResponse) GetHeader 

func (x *NotifyCollectConfigUpdatedResponse) GetHeader() *pb.CommonResponseHeader

func (*NotifyCollectConfigUpdatedResponse) ProtoMessage 

func (*NotifyCollectConfigUpdatedResponse) ProtoMessage()

func (*NotifyCollectConfigUpdatedResponse) ProtoReflect 

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

func (*NotifyCollectConfigUpdatedResponse) Reset 

func (x *NotifyCollectConfigUpdatedResponse) Reset()

func (*NotifyCollectConfigUpdatedResponse) String 

func (x *NotifyCollectConfigUpdatedResponse) String() string

type PreviewFileRequest 

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
}

func (*PreviewFileRequest) Descriptor deprecated 

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

Deprecated: Use PreviewFileRequest.ProtoReflect.Descriptor instead.

func (*PreviewFileRequest) GetAgentId 

func (x *PreviewFileRequest) GetAgentId() string

func (*PreviewFileRequest) GetCharset 

func (x *PreviewFileRequest) GetCharset() string

func (*PreviewFileRequest) GetHeader 

func (x *PreviewFileRequest) GetHeader() *pb.CommonRequestHeader

func (*PreviewFileRequest) GetMaxBytes 

func (x *PreviewFileRequest) GetMaxBytes() int32

func (*PreviewFileRequest) GetMaxLines 

func (x *PreviewFileRequest) GetMaxLines() int32

func (*PreviewFileRequest) GetPath 

func (x *PreviewFileRequest) GetPath() string

func (*PreviewFileRequest) ProtoMessage 

func (*PreviewFileRequest) ProtoMessage()

func (*PreviewFileRequest) ProtoReflect 

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

func (*PreviewFileRequest) Reset 

func (x *PreviewFileRequest) Reset()

func (*PreviewFileRequest) String 

func (x *PreviewFileRequest) String() string

type PreviewFileResponse 

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
}

func (*PreviewFileResponse) Descriptor deprecated 

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

Deprecated: Use PreviewFileResponse.ProtoReflect.Descriptor instead.

func (*PreviewFileResponse) GetCharset 

func (x *PreviewFileResponse) GetCharset() string

func (*PreviewFileResponse) GetContent 

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

func (*PreviewFileResponse) GetHeader 

func (x *PreviewFileResponse) GetHeader() *pb.CommonResponseHeader

func (*PreviewFileResponse) GetTimezone 

func (x *PreviewFileResponse) GetTimezone() string

func (*PreviewFileResponse) ProtoMessage 

func (*PreviewFileResponse) ProtoMessage()

func (*PreviewFileResponse) ProtoReflect 

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

func (*PreviewFileResponse) Reset 

func (x *PreviewFileResponse) Reset()

func (*PreviewFileResponse) String 

func (x *PreviewFileResponse) String() string

type ProcessingError 

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

描述一个采集过程中的错误

func (*ProcessingError) Descriptor deprecated 

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

Deprecated: Use ProcessingError.ProtoReflect.Descriptor instead.

func (*ProcessingError) GetMessage 

func (x *ProcessingError) GetMessage() string

func (*ProcessingError) ProtoMessage 

func (*ProcessingError) ProtoMessage()

func (*ProcessingError) ProtoReflect 

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

func (*ProcessingError) Reset 

func (x *ProcessingError) Reset()

func (*ProcessingError) String 

func (x *ProcessingError) String() string

type RegisterAgentRequest 

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
}

func (*RegisterAgentRequest) Descriptor deprecated 

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

Deprecated: Use RegisterAgentRequest.ProtoReflect.Descriptor instead.

func (*RegisterAgentRequest) GetAgentId 

func (x *RegisterAgentRequest) GetAgentId() string

func (*RegisterAgentRequest) GetAgentVersion 

func (x *RegisterAgentRequest) GetAgentVersion() string

func (*RegisterAgentRequest) GetApp 

func (x *RegisterAgentRequest) GetApp() string

func (*RegisterAgentRequest) GetArch 

func (x *RegisterAgentRequest) GetArch() string

func (*RegisterAgentRequest) GetCluster 

func (x *RegisterAgentRequest) GetCluster() string

func (*RegisterAgentRequest) GetHeader 

func (x *RegisterAgentRequest) GetHeader() *pb.CommonRequestHeader

func (*RegisterAgentRequest) GetHostname 

func (x *RegisterAgentRequest) GetHostname() string

func (*RegisterAgentRequest) GetIp 

func (x *RegisterAgentRequest) GetIp() string

func (*RegisterAgentRequest) GetK8S 

func (x *RegisterAgentRequest) GetK8S() *AgentK8SInfo

func (*RegisterAgentRequest) GetLabels 

func (x *RegisterAgentRequest) GetLabels() map[string]string

func (*RegisterAgentRequest) GetMode 

func (x *RegisterAgentRequest) GetMode() string

func (*RegisterAgentRequest) GetOs 

func (x *RegisterAgentRequest) GetOs() string

func (*RegisterAgentRequest) GetWorkspace 

func (x *RegisterAgentRequest) GetWorkspace() string

func (*RegisterAgentRequest) ProtoMessage 

func (*RegisterAgentRequest) ProtoMessage()

func (*RegisterAgentRequest) ProtoReflect 

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

func (*RegisterAgentRequest) Reset 

func (x *RegisterAgentRequest) Reset()

func (*RegisterAgentRequest) String 

func (x *RegisterAgentRequest) String() string

type RegisterAgentResponse 

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
}

func (*RegisterAgentResponse) Descriptor deprecated 

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

Deprecated: Use RegisterAgentResponse.ProtoReflect.Descriptor instead.

func (*RegisterAgentResponse) GetHeader 

func (x *RegisterAgentResponse) GetHeader() *pb.CommonResponseHeader

func (*RegisterAgentResponse) GetTenant 

func (x *RegisterAgentResponse) GetTenant() string

func (*RegisterAgentResponse) ProtoMessage 

func (*RegisterAgentResponse) ProtoMessage()

func (*RegisterAgentResponse) ProtoReflect 

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

func (*RegisterAgentResponse) Reset 

func (x *RegisterAgentResponse) Reset()

func (*RegisterAgentResponse) String 

func (x *RegisterAgentResponse) String() string

type RegistryServiceForAgentClient 

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

RegistryServiceForAgentClient is the client API for RegistryServiceForAgent 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 NewRegistryServiceForAgentClient 

func NewRegistryServiceForAgentClient(cc grpc.ClientConnInterface) RegistryServiceForAgentClient

type RegistryServiceForAgentServer 

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

RegistryServiceForAgentServer is the server API for RegistryServiceForAgent service. All implementations should embed UnimplementedRegistryServiceForAgentServer for forward compatibility

type RegistryServiceForAgent_BiStreamsClient 

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

type RegistryServiceForAgent_BiStreamsServer 

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

type ReportEventRequest 

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
}

func (*ReportEventRequest) Descriptor deprecated 

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

Deprecated: Use ReportEventRequest.ProtoReflect.Descriptor instead.

func (*ReportEventRequest) GetEvents 

func (x *ReportEventRequest) GetEvents() []*ReportEventRequest_Event

func (*ReportEventRequest) GetHeader 

func (x *ReportEventRequest) GetHeader() *pb.CommonRequestHeader

func (*ReportEventRequest) ProtoMessage 

func (*ReportEventRequest) ProtoMessage()

func (*ReportEventRequest) ProtoReflect 

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

func (*ReportEventRequest) Reset 

func (x *ReportEventRequest) Reset()

func (*ReportEventRequest) String 

func (x *ReportEventRequest) String() string

type ReportEventRequest_Event 

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
}

func (*ReportEventRequest_Event) Descriptor deprecated 

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

Deprecated: Use ReportEventRequest_Event.ProtoReflect.Descriptor instead.

func (*ReportEventRequest_Event) GetBornTimestamp 

func (x *ReportEventRequest_Event) GetBornTimestamp() int64

func (*ReportEventRequest_Event) GetEventTimestamp 

func (x *ReportEventRequest_Event) GetEventTimestamp() int64

func (*ReportEventRequest_Event) GetEventType 

func (x *ReportEventRequest_Event) GetEventType() string

func (*ReportEventRequest_Event) GetJson 

func (x *ReportEventRequest_Event) GetJson() string

func (*ReportEventRequest_Event) GetLogs 

func (x *ReportEventRequest_Event) GetLogs() []string

func (*ReportEventRequest_Event) GetNumbers 

func (x *ReportEventRequest_Event) GetNumbers() map[string]int64

func (*ReportEventRequest_Event) GetPayloadType 

func (x *ReportEventRequest_Event) GetPayloadType() string

func (*ReportEventRequest_Event) GetStrings 

func (x *ReportEventRequest_Event) GetStrings() map[string]string

func (*ReportEventRequest_Event) GetTags 

func (x *ReportEventRequest_Event) GetTags() map[string]string

func (*ReportEventRequest_Event) ProtoMessage 

func (*ReportEventRequest_Event) ProtoMessage()

func (*ReportEventRequest_Event) ProtoReflect 

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

func (*ReportEventRequest_Event) Reset 

func (x *ReportEventRequest_Event) Reset()

func (*ReportEventRequest_Event) String 

func (x *ReportEventRequest_Event) String() string

type RunEvent 

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
}

func (*RunEvent) Descriptor deprecated 

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

Deprecated: Use RunEvent.ProtoReflect.Descriptor instead.

func (*RunEvent) GetMsg 

func (x *RunEvent) GetMsg() string

func (*RunEvent) GetTimestamp 

func (x *RunEvent) GetTimestamp() int64

func (*RunEvent) GetType 

func (x *RunEvent) GetType() string

func (*RunEvent) ProtoMessage 

func (*RunEvent) ProtoMessage()

func (*RunEvent) ProtoReflect 

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

func (*RunEvent) Reset 

func (x *RunEvent) Reset()

func (*RunEvent) String 

func (x *RunEvent) String() string

type RunEventsRequest 

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
}

func (*RunEventsRequest) Descriptor deprecated 

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

Deprecated: Use RunEventsRequest.ProtoReflect.Descriptor instead.

func (*RunEventsRequest) GetAgentId 

func (x *RunEventsRequest) GetAgentId() string

func (*RunEventsRequest) GetEvents 

func (x *RunEventsRequest) GetEvents() []*RunEvent

func (*RunEventsRequest) GetHeader 

func (x *RunEventsRequest) GetHeader() *pb.CommonRequestHeader

func (*RunEventsRequest) ProtoMessage 

func (*RunEventsRequest) ProtoMessage()

func (*RunEventsRequest) ProtoReflect 

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

func (*RunEventsRequest) Reset 

func (x *RunEventsRequest) Reset()

func (*RunEventsRequest) String 

func (x *RunEventsRequest) String() string

type RunEventsResponse 

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

func (*RunEventsResponse) Descriptor deprecated 

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

Deprecated: Use RunEventsResponse.ProtoReflect.Descriptor instead.

func (*RunEventsResponse) GetHeader 

func (x *RunEventsResponse) GetHeader() *pb.CommonRequestHeader

func (*RunEventsResponse) ProtoMessage 

func (*RunEventsResponse) ProtoMessage()

func (*RunEventsResponse) ProtoReflect 

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

func (*RunEventsResponse) Reset 

func (x *RunEventsResponse) Reset()

func (*RunEventsResponse) String 

func (x *RunEventsResponse) String() string

type RunStatsRequest 

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
}

todo 命名上用stats or metrics ? 目前只用两种指标

func (*RunStatsRequest) Descriptor deprecated 

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

Deprecated: Use RunStatsRequest.ProtoReflect.Descriptor instead.

func (*RunStatsRequest) GetAgentId 

func (x *RunStatsRequest) GetAgentId() string

func (*RunStatsRequest) GetAgentRunStats 

func (x *RunStatsRequest) GetAgentRunStats() map[string]uint64

func (*RunStatsRequest) GetCollectConfigRunStats 

func (x *RunStatsRequest) GetCollectConfigRunStats() []*CollectConfigRunStats

func (*RunStatsRequest) GetHeader 

func (x *RunStatsRequest) GetHeader() *pb.CommonRequestHeader

func (*RunStatsRequest) GetTimestamp 

func (x *RunStatsRequest) GetTimestamp() int64

func (*RunStatsRequest) ProtoMessage 

func (*RunStatsRequest) ProtoMessage()

func (*RunStatsRequest) ProtoReflect 

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

func (*RunStatsRequest) Reset 

func (x *RunStatsRequest) Reset()

func (*RunStatsRequest) String 

func (x *RunStatsRequest) String() string

type RunStatsResponse 

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

func (*RunStatsResponse) Descriptor deprecated 

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

Deprecated: Use RunStatsResponse.ProtoReflect.Descriptor instead.

func (*RunStatsResponse) GetHeader 

func (x *RunStatsResponse) GetHeader() *pb.CommonRequestHeader

func (*RunStatsResponse) ProtoMessage 

func (*RunStatsResponse) ProtoMessage()

func (*RunStatsResponse) ProtoReflect 

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

func (*RunStatsResponse) Reset 

func (x *RunStatsResponse) Reset()

func (*RunStatsResponse) String 

func (x *RunStatsResponse) String() string

type SendAgentHeartbeatRequest 

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
}

发送agent的心跳

func (*SendAgentHeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use SendAgentHeartbeatRequest.ProtoReflect.Descriptor instead.

func (*SendAgentHeartbeatRequest) GetAgentId 

func (x *SendAgentHeartbeatRequest) GetAgentId() string

func (*SendAgentHeartbeatRequest) GetHeader 

func (x *SendAgentHeartbeatRequest) GetHeader() *pb.CommonRequestHeader

func (*SendAgentHeartbeatRequest) ProtoMessage 

func (*SendAgentHeartbeatRequest) ProtoMessage()

func (*SendAgentHeartbeatRequest) ProtoReflect 

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

func (*SendAgentHeartbeatRequest) Reset 

func (x *SendAgentHeartbeatRequest) Reset()

func (*SendAgentHeartbeatRequest) String 

func (x *SendAgentHeartbeatRequest) String() string

type SendAgentHeartbeatResponse 

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

func (*SendAgentHeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use SendAgentHeartbeatResponse.ProtoReflect.Descriptor instead.

func (*SendAgentHeartbeatResponse) GetHeader 

func (x *SendAgentHeartbeatResponse) GetHeader() *pb.CommonResponseHeader

func (*SendAgentHeartbeatResponse) ProtoMessage 

func (*SendAgentHeartbeatResponse) ProtoMessage()

func (*SendAgentHeartbeatResponse) ProtoReflect 

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

func (*SendAgentHeartbeatResponse) Reset 

func (x *SendAgentHeartbeatResponse) Reset()

func (*SendAgentHeartbeatResponse) String 

func (x *SendAgentHeartbeatResponse) String() string

type SplitLogRequest 

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
}

试切分

func (*SplitLogRequest) Descriptor deprecated 

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

Deprecated: Use SplitLogRequest.ProtoReflect.Descriptor instead.

func (*SplitLogRequest) GetAgentId 

func (x *SplitLogRequest) GetAgentId() string

func (*SplitLogRequest) GetContent 

func (x *SplitLogRequest) GetContent() string

func (*SplitLogRequest) GetHeader 

func (x *SplitLogRequest) GetHeader() *pb.CommonRequestHeader

func (*SplitLogRequest) GetRegexp 

func (x *SplitLogRequest) GetRegexp() string

func (*SplitLogRequest) ProtoMessage 

func (*SplitLogRequest) ProtoMessage()

func (*SplitLogRequest) ProtoReflect 

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

func (*SplitLogRequest) Reset 

func (x *SplitLogRequest) Reset()

func (*SplitLogRequest) String 

func (x *SplitLogRequest) String() string

type SplitLogResponse 

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
}

func (*SplitLogResponse) Descriptor deprecated 

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

Deprecated: Use SplitLogResponse.ProtoReflect.Descriptor instead.

func (*SplitLogResponse) GetHeader 

func (x *SplitLogResponse) GetHeader() *pb.CommonResponseHeader

func (*SplitLogResponse) GetResult 

func (x *SplitLogResponse) GetResult() map[string]string

func (*SplitLogResponse) ProtoMessage 

func (*SplitLogResponse) ProtoMessage()

func (*SplitLogResponse) ProtoReflect 

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

func (*SplitLogResponse) Reset 

func (x *SplitLogResponse) Reset()

func (*SplitLogResponse) String 

func (x *SplitLogResponse) String() string

type TargetIdentifier 

type TargetIdentifier struct {
	Tenant   string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	TargetUk string `protobuf:"bytes,2,opt,name=target_uk,json=targetUk,proto3" json:"target_uk,omitempty"`
	// contains filtered or unexported fields
}

func (*TargetIdentifier) Descriptor deprecated 

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

Deprecated: Use TargetIdentifier.ProtoReflect.Descriptor instead.

func (*TargetIdentifier) GetTargetUk 

func (x *TargetIdentifier) GetTargetUk() string

func (*TargetIdentifier) GetTenant 

func (x *TargetIdentifier) GetTenant() string

func (*TargetIdentifier) ProtoMessage 

func (*TargetIdentifier) ProtoMessage()

func (*TargetIdentifier) ProtoReflect 

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

func (*TargetIdentifier) Reset 

func (x *TargetIdentifier) Reset()

func (*TargetIdentifier) String 

func (x *TargetIdentifier) String() string

type UnimplementedRegistryServiceForAgentServer 

type UnimplementedRegistryServiceForAgentServer struct {
}

UnimplementedRegistryServiceForAgentServer should be embedded to have forward compatible implementations.

func (UnimplementedRegistryServiceForAgentServer) BiStreams 

func (UnimplementedRegistryServiceForAgentServer) BiStreams(RegistryServiceForAgent_BiStreamsServer) error

func (UnimplementedRegistryServiceForAgentServer) GetCollectTasks 

func (UnimplementedRegistryServiceForAgentServer) GetCollectTasks(context.Context, *GetCollectTasksRequest) (*GetCollectTasksResponse, error)

func (UnimplementedRegistryServiceForAgentServer) GetControlConfigs 

func (UnimplementedRegistryServiceForAgentServer) GetControlConfigs(context.Context, *GetControlConfigsRequest) (*GetControlConfigsResponse, error)

func (UnimplementedRegistryServiceForAgentServer) MetaDeltaSync 

func (UnimplementedRegistryServiceForAgentServer) MetaDeltaSync(context.Context, *MetaSync_DeltaSyncRequest) (*emptypb.Empty, error)

func (UnimplementedRegistryServiceForAgentServer) MetaFullSync 

func (UnimplementedRegistryServiceForAgentServer) MetaFullSync(context.Context, *MetaSync_FullSyncRequest) (*emptypb.Empty, error)

func (UnimplementedRegistryServiceForAgentServer) Ping 

func (UnimplementedRegistryServiceForAgentServer) Ping(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedRegistryServiceForAgentServer) RegisterAgent 

func (UnimplementedRegistryServiceForAgentServer) RegisterAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error)

func (UnimplementedRegistryServiceForAgentServer) ReportEvents 

func (UnimplementedRegistryServiceForAgentServer) ReportEvents(context.Context, *ReportEventRequest) (*emptypb.Empty, error)

func (UnimplementedRegistryServiceForAgentServer) SendAgentHeartbeat 

func (UnimplementedRegistryServiceForAgentServer) SendAgentHeartbeat(context.Context, *SendAgentHeartbeatRequest) (*SendAgentHeartbeatResponse, error)

func (UnimplementedRegistryServiceForAgentServer) SendRunEvents 

func (UnimplementedRegistryServiceForAgentServer) SendRunEvents(context.Context, *RunEventsRequest) (*RunEventsResponse, error)

func (UnimplementedRegistryServiceForAgentServer) SendRunStats 

func (UnimplementedRegistryServiceForAgentServer) SendRunStats(context.Context, *RunStatsRequest) (*RunStatsResponse, error)

type UnsafeRegistryServiceForAgentServer 

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

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

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.