proto

package
v0.0.0-...-520c4d9 Latest Latest
Warning

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

 Go to latest Published: May 13, 2025 License: GPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	LogService_SubmitMetrics_FullMethodName = "/proto.LogService/SubmitMetrics"
	LogService_SubmitStream_FullMethodName  = "/proto.LogService/SubmitStream"
)
View Source 
const (
	CommandService_ExecuteCommand_FullMethodName = "/proto.CommandService/ExecuteCommand"
)
View Source 
const (
	StreamService_Stream_FullMethodName = "/proto.StreamService/Stream"
)

Variables

View Source 
var CommandService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.CommandService",
	HandlerType: (*CommandServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ExecuteCommand",
			Handler:    _CommandService_ExecuteCommand_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "command.proto",
}

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

View Source 
var File_command_proto protoreflect.FileDescriptor
View Source 
var File_log_proto protoreflect.FileDescriptor
View Source 
var File_meta_proto protoreflect.FileDescriptor
View Source 
var File_metric_proto protoreflect.FileDescriptor
View Source 
var File_process_proto protoreflect.FileDescriptor
View Source 
var File_stream_proto protoreflect.FileDescriptor
View Source 
var LogService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.LogService",
	HandlerType: (*LogServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SubmitMetrics",
			Handler:    _LogService_SubmitMetrics_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubmitStream",
			Handler:       _LogService_SubmitStream_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "log.proto",
}

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

View Source 
var StreamService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.StreamService",
	HandlerType: (*StreamServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Stream",
			Handler:       _StreamService_Stream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "stream.proto",
}

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

Functions

func RegisterCommandServiceServer 

func RegisterCommandServiceServer(s grpc.ServiceRegistrar, srv CommandServiceServer)

func RegisterLogServiceServer 

func RegisterLogServiceServer(s grpc.ServiceRegistrar, srv LogServiceServer)

func RegisterStreamServiceServer 

func RegisterStreamServiceServer(s grpc.ServiceRegistrar, srv StreamServiceServer)

Types

type CommandRequest 

type CommandRequest struct {
	AgentId     string   `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	CommandType string   `protobuf:"bytes,2,opt,name=command_type,json=commandType,proto3" json:"command_type,omitempty"` // "shell" or "ansible"
	Command     string   `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"`                            // Shell command (if type = shell) or playbook content (if type = ansible)
	Args        []string `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`                                  // Optional extra args
	// contains filtered or unexported fields
}

func (*CommandRequest) Descriptor deprecated 

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

Deprecated: Use CommandRequest.ProtoReflect.Descriptor instead.

func (*CommandRequest) GetAgentId 

func (x *CommandRequest) GetAgentId() string

func (*CommandRequest) GetArgs 

func (x *CommandRequest) GetArgs() []string

func (*CommandRequest) GetCommand 

func (x *CommandRequest) GetCommand() string

func (*CommandRequest) GetCommandType 

func (x *CommandRequest) GetCommandType() string

func (*CommandRequest) ProtoMessage 

func (*CommandRequest) ProtoMessage()

func (*CommandRequest) ProtoReflect 

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

func (*CommandRequest) Reset 

func (x *CommandRequest) Reset()

func (*CommandRequest) String 

func (x *CommandRequest) String() string

type CommandResponse 

type CommandResponse struct {
	Success      bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Output       string `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`                                 // stdout + stderr
	ErrorMessage string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` // if failed
	// contains filtered or unexported fields
}

func (*CommandResponse) Descriptor deprecated 

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

Deprecated: Use CommandResponse.ProtoReflect.Descriptor instead.

func (*CommandResponse) GetErrorMessage 

func (x *CommandResponse) GetErrorMessage() string

func (*CommandResponse) GetOutput 

func (x *CommandResponse) GetOutput() string

func (*CommandResponse) GetSuccess 

func (x *CommandResponse) GetSuccess() bool

func (*CommandResponse) ProtoMessage 

func (*CommandResponse) ProtoMessage()

func (*CommandResponse) ProtoReflect 

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

func (*CommandResponse) Reset 

func (x *CommandResponse) Reset()

func (*CommandResponse) String 

func (x *CommandResponse) String() string

type CommandServiceClient 

type CommandServiceClient interface {
	ExecuteCommand(ctx context.Context, in *CommandRequest, opts ...grpc.CallOption) (*CommandResponse, error)
}

CommandServiceClient is the client API for CommandService 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 NewCommandServiceClient 

func NewCommandServiceClient(cc grpc.ClientConnInterface) CommandServiceClient

type CommandServiceServer 

type CommandServiceServer interface {
	ExecuteCommand(context.Context, *CommandRequest) (*CommandResponse, error)
	// contains filtered or unexported methods
}

CommandServiceServer is the server API for CommandService service. All implementations must embed UnimplementedCommandServiceServer for forward compatibility.

type LogEntry 

type LogEntry struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Level     string                 `protobuf:"bytes,2,opt,name=level,proto3" json:"level,omitempty"`
	Message   string                 `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Source    string                 `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	Category  string                 `protobuf:"bytes,5,opt,name=category,proto3" json:"category,omitempty"`
	Pid       int32                  `protobuf:"varint,6,opt,name=pid,proto3" json:"pid,omitempty"`
	Fields    map[string]string      `` /* 139-byte string literal not displayed */
	Tags      map[string]string      `` /* 135-byte string literal not displayed */
	Meta      *LogMeta               `protobuf:"bytes,9,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntry) Descriptor deprecated 

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

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetCategory 

func (x *LogEntry) GetCategory() string

func (*LogEntry) GetFields 

func (x *LogEntry) GetFields() map[string]string

func (*LogEntry) GetLevel 

func (x *LogEntry) GetLevel() string

func (*LogEntry) GetMessage 

func (x *LogEntry) GetMessage() string

func (*LogEntry) GetMeta 

func (x *LogEntry) GetMeta() *LogMeta

func (*LogEntry) GetPid 

func (x *LogEntry) GetPid() int32

func (*LogEntry) GetSource 

func (x *LogEntry) GetSource() string

func (*LogEntry) GetTags 

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

func (*LogEntry) GetTimestamp 

func (x *LogEntry) GetTimestamp() *timestamppb.Timestamp

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect 

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

func (*LogEntry) Reset 

func (x *LogEntry) Reset()

func (*LogEntry) String 

func (x *LogEntry) String() string

type LogMeta 

type LogMeta struct {
	Platform      string            `protobuf:"bytes,1,opt,name=platform,proto3" json:"platform,omitempty"`
	AppName       string            `protobuf:"bytes,2,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	AppVersion    string            `protobuf:"bytes,3,opt,name=app_version,json=appVersion,proto3" json:"app_version,omitempty"`
	ContainerId   string            `protobuf:"bytes,4,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ContainerName string            `protobuf:"bytes,5,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"`
	Unit          string            `protobuf:"bytes,6,opt,name=unit,proto3" json:"unit,omitempty"`
	Service       string            `protobuf:"bytes,7,opt,name=service,proto3" json:"service,omitempty"`
	EventId       string            `protobuf:"bytes,8,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	User          string            `protobuf:"bytes,9,opt,name=user,proto3" json:"user,omitempty"`
	Executable    string            `protobuf:"bytes,10,opt,name=executable,proto3" json:"executable,omitempty"`
	Path          string            `protobuf:"bytes,11,opt,name=path,proto3" json:"path,omitempty"`
	Extra         map[string]string `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LogMeta) Descriptor deprecated 

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

Deprecated: Use LogMeta.ProtoReflect.Descriptor instead.

func (*LogMeta) GetAppName 

func (x *LogMeta) GetAppName() string

func (*LogMeta) GetAppVersion 

func (x *LogMeta) GetAppVersion() string

func (*LogMeta) GetContainerId 

func (x *LogMeta) GetContainerId() string

func (*LogMeta) GetContainerName 

func (x *LogMeta) GetContainerName() string

func (*LogMeta) GetEventId 

func (x *LogMeta) GetEventId() string

func (*LogMeta) GetExecutable 

func (x *LogMeta) GetExecutable() string

func (*LogMeta) GetExtra 

func (x *LogMeta) GetExtra() map[string]string

func (*LogMeta) GetPath 

func (x *LogMeta) GetPath() string

func (*LogMeta) GetPlatform 

func (x *LogMeta) GetPlatform() string

func (*LogMeta) GetService 

func (x *LogMeta) GetService() string

func (*LogMeta) GetUnit 

func (x *LogMeta) GetUnit() string

func (*LogMeta) GetUser 

func (x *LogMeta) GetUser() string

func (*LogMeta) ProtoMessage 

func (*LogMeta) ProtoMessage()

func (*LogMeta) ProtoReflect 

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

func (*LogMeta) Reset 

func (x *LogMeta) Reset()

func (*LogMeta) String 

func (x *LogMeta) String() string

type LogPayload 

type LogPayload struct {
	AgentId    string                 `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	HostId     string                 `protobuf:"bytes,2,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	Hostname   string                 `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	EndpointId string                 `protobuf:"bytes,4,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	Timestamp  *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Logs       []*LogEntry            `protobuf:"bytes,6,rep,name=logs,proto3" json:"logs,omitempty"`
	Meta       *Meta                  `protobuf:"bytes,7,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*LogPayload) Descriptor deprecated 

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

Deprecated: Use LogPayload.ProtoReflect.Descriptor instead.

func (*LogPayload) GetAgentId 

func (x *LogPayload) GetAgentId() string

func (*LogPayload) GetEndpointId 

func (x *LogPayload) GetEndpointId() string

func (*LogPayload) GetHostId 

func (x *LogPayload) GetHostId() string

func (*LogPayload) GetHostname 

func (x *LogPayload) GetHostname() string

func (*LogPayload) GetLogs 

func (x *LogPayload) GetLogs() []*LogEntry

func (*LogPayload) GetMeta 

func (x *LogPayload) GetMeta() *Meta

func (*LogPayload) GetTimestamp 

func (x *LogPayload) GetTimestamp() *timestamppb.Timestamp

func (*LogPayload) ProtoMessage 

func (*LogPayload) ProtoMessage()

func (*LogPayload) ProtoReflect 

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

func (*LogPayload) Reset 

func (x *LogPayload) Reset()

func (*LogPayload) String 

func (x *LogPayload) String() string

type LogResponse 

type LogResponse struct {
	Status     string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	StatusCode int32  `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	// contains filtered or unexported fields
}

func (*LogResponse) Descriptor deprecated 

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

Deprecated: Use LogResponse.ProtoReflect.Descriptor instead.

func (*LogResponse) GetStatus 

func (x *LogResponse) GetStatus() string

func (*LogResponse) GetStatusCode 

func (x *LogResponse) GetStatusCode() int32

func (*LogResponse) ProtoMessage 

func (*LogResponse) ProtoMessage()

func (*LogResponse) ProtoReflect 

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

func (*LogResponse) Reset 

func (x *LogResponse) Reset()

func (*LogResponse) String 

func (x *LogResponse) String() string

type LogServiceClient 

type LogServiceClient interface {
	SubmitMetrics(ctx context.Context, in *LogPayload, opts ...grpc.CallOption) (*LogResponse, error)
	SubmitStream(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[LogPayload, LogResponse], error)
}

LogServiceClient is the client API for LogService 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 NewLogServiceClient 

func NewLogServiceClient(cc grpc.ClientConnInterface) LogServiceClient

type LogServiceServer 

type LogServiceServer interface {
	SubmitMetrics(context.Context, *LogPayload) (*LogResponse, error)
	SubmitStream(grpc.ClientStreamingServer[LogPayload, LogResponse]) error
	// contains filtered or unexported methods
}

LogServiceServer is the server API for LogService service. All implementations must embed UnimplementedLogServiceServer for forward compatibility.

type LogService_SubmitStreamClient 

type LogService_SubmitStreamClient = grpc.ClientStreamingClient[LogPayload, LogResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type LogService_SubmitStreamServer 

type LogService_SubmitStreamServer = grpc.ClientStreamingServer[LogPayload, LogResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Meta 

type Meta struct {
	Hostname             string            `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	IpAddress            string            `protobuf:"bytes,2,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`
	Os                   string            `protobuf:"bytes,3,opt,name=os,proto3" json:"os,omitempty"`
	OsVersion            string            `protobuf:"bytes,4,opt,name=os_version,json=osVersion,proto3" json:"os_version,omitempty"`
	KernelVersion        string            `protobuf:"bytes,5,opt,name=kernel_version,json=kernelVersion,proto3" json:"kernel_version,omitempty"`
	Architecture         string            `protobuf:"bytes,6,opt,name=architecture,proto3" json:"architecture,omitempty"`
	CloudProvider        string            `protobuf:"bytes,7,opt,name=cloud_provider,json=cloudProvider,proto3" json:"cloud_provider,omitempty"`
	Region               string            `protobuf:"bytes,8,opt,name=region,proto3" json:"region,omitempty"`
	AvailabilityZone     string            `protobuf:"bytes,9,opt,name=availability_zone,json=availabilityZone,proto3" json:"availability_zone,omitempty"`
	InstanceId           string            `protobuf:"bytes,10,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	InstanceType         string            `protobuf:"bytes,11,opt,name=instance_type,json=instanceType,proto3" json:"instance_type,omitempty"`
	AccountId            string            `protobuf:"bytes,12,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	ProjectId            string            `protobuf:"bytes,13,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	ResourceGroup        string            `protobuf:"bytes,14,opt,name=resource_group,json=resourceGroup,proto3" json:"resource_group,omitempty"`
	VpcId                string            `protobuf:"bytes,15,opt,name=vpc_id,json=vpcId,proto3" json:"vpc_id,omitempty"`
	SubnetId             string            `protobuf:"bytes,16,opt,name=subnet_id,json=subnetId,proto3" json:"subnet_id,omitempty"`
	ImageId              string            `protobuf:"bytes,17,opt,name=image_id,json=imageId,proto3" json:"image_id,omitempty"`
	ServiceId            string            `protobuf:"bytes,18,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	ContainerId          string            `protobuf:"bytes,19,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ContainerName        string            `protobuf:"bytes,20,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"`
	PodName              string            `protobuf:"bytes,21,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	Namespace            string            `protobuf:"bytes,22,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ClusterName          string            `protobuf:"bytes,23,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	NodeName             string            `protobuf:"bytes,24,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	ContainerImageName   string            `protobuf:"bytes,25,opt,name=container_image_name,json=containerImageName,proto3" json:"container_image_name,omitempty"`
	ContainerImageId     string            `protobuf:"bytes,26,opt,name=container_image_id,json=containerImageId,proto3" json:"container_image_id,omitempty"`
	Application          string            `protobuf:"bytes,27,opt,name=application,proto3" json:"application,omitempty"`
	Environment          string            `protobuf:"bytes,28,opt,name=environment,proto3" json:"environment,omitempty"`
	Service              string            `protobuf:"bytes,29,opt,name=service,proto3" json:"service,omitempty"`
	Version              string            `protobuf:"bytes,30,opt,name=version,proto3" json:"version,omitempty"`
	DeploymentId         string            `protobuf:"bytes,31,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	PublicIp             string            `protobuf:"bytes,32,opt,name=public_ip,json=publicIp,proto3" json:"public_ip,omitempty"`
	PrivateIp            string            `protobuf:"bytes,33,opt,name=private_ip,json=privateIp,proto3" json:"private_ip,omitempty"`
	MacAddress           string            `protobuf:"bytes,34,opt,name=mac_address,json=macAddress,proto3" json:"mac_address,omitempty"`
	NetworkInterface     string            `protobuf:"bytes,35,opt,name=network_interface,json=networkInterface,proto3" json:"network_interface,omitempty"`
	Tags                 map[string]string `` /* 136-byte string literal not displayed */
	EndpointId           string            `protobuf:"bytes,37,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	Platform             string            `protobuf:"bytes,38,opt,name=platform,proto3" json:"platform,omitempty"`
	PlatformFamily       string            `protobuf:"bytes,39,opt,name=platform_family,json=platformFamily,proto3" json:"platform_family,omitempty"`
	PlatformVersion      string            `protobuf:"bytes,40,opt,name=platform_version,json=platformVersion,proto3" json:"platform_version,omitempty"`
	KernelArchitecture   string            `protobuf:"bytes,41,opt,name=kernel_architecture,json=kernelArchitecture,proto3" json:"kernel_architecture,omitempty"`
	VirtualizationSystem string            `protobuf:"bytes,42,opt,name=virtualization_system,json=virtualizationSystem,proto3" json:"virtualization_system,omitempty"`
	VirtualizationRole   string            `protobuf:"bytes,43,opt,name=virtualization_role,json=virtualizationRole,proto3" json:"virtualization_role,omitempty"`
	HostId               string            `protobuf:"bytes,44,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	AgentVersion         string            `protobuf:"bytes,45,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
	AgentId              string            `protobuf:"bytes,46,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Meta) Descriptor deprecated 

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

Deprecated: Use Meta.ProtoReflect.Descriptor instead.

func (*Meta) GetAccountId 

func (x *Meta) GetAccountId() string

func (*Meta) GetAgentId 

func (x *Meta) GetAgentId() string

func (*Meta) GetAgentVersion 

func (x *Meta) GetAgentVersion() string

func (*Meta) GetApplication 

func (x *Meta) GetApplication() string

func (*Meta) GetArchitecture 

func (x *Meta) GetArchitecture() string

func (*Meta) GetAvailabilityZone 

func (x *Meta) GetAvailabilityZone() string

func (*Meta) GetCloudProvider 

func (x *Meta) GetCloudProvider() string

func (*Meta) GetClusterName 

func (x *Meta) GetClusterName() string

func (*Meta) GetContainerId 

func (x *Meta) GetContainerId() string

func (*Meta) GetContainerImageId 

func (x *Meta) GetContainerImageId() string

func (*Meta) GetContainerImageName 

func (x *Meta) GetContainerImageName() string

func (*Meta) GetContainerName 

func (x *Meta) GetContainerName() string

func (*Meta) GetDeploymentId 

func (x *Meta) GetDeploymentId() string

func (*Meta) GetEndpointId 

func (x *Meta) GetEndpointId() string

func (*Meta) GetEnvironment 

func (x *Meta) GetEnvironment() string

func (*Meta) GetHostId 

func (x *Meta) GetHostId() string

func (*Meta) GetHostname 

func (x *Meta) GetHostname() string

func (*Meta) GetImageId 

func (x *Meta) GetImageId() string

func (*Meta) GetInstanceId 

func (x *Meta) GetInstanceId() string

func (*Meta) GetInstanceType 

func (x *Meta) GetInstanceType() string

func (*Meta) GetIpAddress 

func (x *Meta) GetIpAddress() string

func (*Meta) GetKernelArchitecture 

func (x *Meta) GetKernelArchitecture() string

func (*Meta) GetKernelVersion 

func (x *Meta) GetKernelVersion() string

func (*Meta) GetMacAddress 

func (x *Meta) GetMacAddress() string

func (*Meta) GetNamespace 

func (x *Meta) GetNamespace() string

func (*Meta) GetNetworkInterface 

func (x *Meta) GetNetworkInterface() string

func (*Meta) GetNodeName 

func (x *Meta) GetNodeName() string

func (*Meta) GetOs 

func (x *Meta) GetOs() string

func (*Meta) GetOsVersion 

func (x *Meta) GetOsVersion() string

func (*Meta) GetPlatform 

func (x *Meta) GetPlatform() string

func (*Meta) GetPlatformFamily 

func (x *Meta) GetPlatformFamily() string

func (*Meta) GetPlatformVersion 

func (x *Meta) GetPlatformVersion() string

func (*Meta) GetPodName 

func (x *Meta) GetPodName() string

func (*Meta) GetPrivateIp 

func (x *Meta) GetPrivateIp() string

func (*Meta) GetProjectId 

func (x *Meta) GetProjectId() string

func (*Meta) GetPublicIp 

func (x *Meta) GetPublicIp() string

func (*Meta) GetRegion 

func (x *Meta) GetRegion() string

func (*Meta) GetResourceGroup 

func (x *Meta) GetResourceGroup() string

func (*Meta) GetService 

func (x *Meta) GetService() string

func (*Meta) GetServiceId 

func (x *Meta) GetServiceId() string

func (*Meta) GetSubnetId 

func (x *Meta) GetSubnetId() string

func (*Meta) GetTags 

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

func (*Meta) GetVersion 

func (x *Meta) GetVersion() string

func (*Meta) GetVirtualizationRole 

func (x *Meta) GetVirtualizationRole() string

func (*Meta) GetVirtualizationSystem 

func (x *Meta) GetVirtualizationSystem() string

func (*Meta) GetVpcId 

func (x *Meta) GetVpcId() string

func (*Meta) ProtoMessage 

func (*Meta) ProtoMessage()

func (*Meta) ProtoReflect 

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

func (*Meta) Reset 

func (x *Meta) Reset()

func (*Meta) String 

func (x *Meta) String() string

type Metric 

type Metric struct {
	Namespace         string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Subnamespace      string                 `protobuf:"bytes,2,opt,name=subnamespace,proto3" json:"subnamespace,omitempty"`
	Name              string                 `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Timestamp         *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value             float64                `protobuf:"fixed64,5,opt,name=value,proto3" json:"value,omitempty"`
	StatisticValues   *StatisticValues       `protobuf:"bytes,6,opt,name=statistic_values,json=statisticValues,proto3" json:"statistic_values,omitempty"`
	Unit              string                 `protobuf:"bytes,7,opt,name=unit,proto3" json:"unit,omitempty"`
	Dimensions        map[string]string      `` /* 147-byte string literal not displayed */
	StorageResolution int32                  `protobuf:"varint,9,opt,name=storage_resolution,json=storageResolution,proto3" json:"storage_resolution,omitempty"`
	Type              string                 `protobuf:"bytes,10,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Metric) Descriptor deprecated 

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

Deprecated: Use Metric.ProtoReflect.Descriptor instead.

func (*Metric) GetDimensions 

func (x *Metric) GetDimensions() map[string]string

func (*Metric) GetName 

func (x *Metric) GetName() string

func (*Metric) GetNamespace 

func (x *Metric) GetNamespace() string

func (*Metric) GetStatisticValues 

func (x *Metric) GetStatisticValues() *StatisticValues

func (*Metric) GetStorageResolution 

func (x *Metric) GetStorageResolution() int32

func (*Metric) GetSubnamespace 

func (x *Metric) GetSubnamespace() string

func (*Metric) GetTimestamp 

func (x *Metric) GetTimestamp() *timestamppb.Timestamp

func (*Metric) GetType 

func (x *Metric) GetType() string

func (*Metric) GetUnit 

func (x *Metric) GetUnit() string

func (*Metric) GetValue 

func (x *Metric) GetValue() float64

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) ProtoReflect 

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

func (*Metric) Reset 

func (x *Metric) Reset()

func (*Metric) String 

func (x *Metric) String() string

type MetricPayload 

type MetricPayload struct {
	AgentId    string                 `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	HostId     string                 `protobuf:"bytes,2,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	Hostname   string                 `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	EndpointId string                 `protobuf:"bytes,4,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	Timestamp  *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Metrics    []*Metric              `protobuf:"bytes,6,rep,name=metrics,proto3" json:"metrics,omitempty"`
	Meta       *Meta                  `protobuf:"bytes,7,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricPayload) Descriptor deprecated 

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

Deprecated: Use MetricPayload.ProtoReflect.Descriptor instead.

func (*MetricPayload) GetAgentId 

func (x *MetricPayload) GetAgentId() string

func (*MetricPayload) GetEndpointId 

func (x *MetricPayload) GetEndpointId() string

func (*MetricPayload) GetHostId 

func (x *MetricPayload) GetHostId() string

func (*MetricPayload) GetHostname 

func (x *MetricPayload) GetHostname() string

func (*MetricPayload) GetMeta 

func (x *MetricPayload) GetMeta() *Meta

func (*MetricPayload) GetMetrics 

func (x *MetricPayload) GetMetrics() []*Metric

func (*MetricPayload) GetTimestamp 

func (x *MetricPayload) GetTimestamp() *timestamppb.Timestamp

func (*MetricPayload) ProtoMessage 

func (*MetricPayload) ProtoMessage()

func (*MetricPayload) ProtoReflect 

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

func (*MetricPayload) Reset 

func (x *MetricPayload) Reset()

func (*MetricPayload) String 

func (x *MetricPayload) String() string

type MetricWrapper 

type MetricWrapper struct {
	RawPayload []byte `protobuf:"bytes,1,opt,name=raw_payload,json=rawPayload,proto3" json:"raw_payload,omitempty"` // serialized MetricPayload manually
	// contains filtered or unexported fields
}

func (*MetricWrapper) Descriptor deprecated 

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

Deprecated: Use MetricWrapper.ProtoReflect.Descriptor instead.

func (*MetricWrapper) GetRawPayload 

func (x *MetricWrapper) GetRawPayload() []byte

func (*MetricWrapper) ProtoMessage 

func (*MetricWrapper) ProtoMessage()

func (*MetricWrapper) ProtoReflect 

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

func (*MetricWrapper) Reset 

func (x *MetricWrapper) Reset()

func (*MetricWrapper) String 

func (x *MetricWrapper) String() string

type ProcessInfo 

type ProcessInfo struct {
	Pid        int32                  `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Ppid       int32                  `protobuf:"varint,2,opt,name=ppid,proto3" json:"ppid,omitempty"`
	User       string                 `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	Executable string                 `protobuf:"bytes,4,opt,name=executable,proto3" json:"executable,omitempty"`
	Cmdline    string                 `protobuf:"bytes,5,opt,name=cmdline,proto3" json:"cmdline,omitempty"`
	CpuPercent float64                `protobuf:"fixed64,6,opt,name=cpu_percent,json=cpuPercent,proto3" json:"cpu_percent,omitempty"`
	MemPercent float64                `protobuf:"fixed64,7,opt,name=mem_percent,json=memPercent,proto3" json:"mem_percent,omitempty"`
	Threads    int32                  `protobuf:"varint,8,opt,name=threads,proto3" json:"threads,omitempty"`
	StartTime  *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	Tags       map[string]string      `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ProcessInfo) Descriptor deprecated 

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

Deprecated: Use ProcessInfo.ProtoReflect.Descriptor instead.

func (*ProcessInfo) GetCmdline 

func (x *ProcessInfo) GetCmdline() string

func (*ProcessInfo) GetCpuPercent 

func (x *ProcessInfo) GetCpuPercent() float64

func (*ProcessInfo) GetExecutable 

func (x *ProcessInfo) GetExecutable() string

func (*ProcessInfo) GetMemPercent 

func (x *ProcessInfo) GetMemPercent() float64

func (*ProcessInfo) GetPid 

func (x *ProcessInfo) GetPid() int32

func (*ProcessInfo) GetPpid 

func (x *ProcessInfo) GetPpid() int32

func (*ProcessInfo) GetStartTime 

func (x *ProcessInfo) GetStartTime() *timestamppb.Timestamp

func (*ProcessInfo) GetTags 

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

func (*ProcessInfo) GetThreads 

func (x *ProcessInfo) GetThreads() int32

func (*ProcessInfo) GetUser 

func (x *ProcessInfo) GetUser() string

func (*ProcessInfo) ProtoMessage 

func (*ProcessInfo) ProtoMessage()

func (*ProcessInfo) ProtoReflect 

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

func (*ProcessInfo) Reset 

func (x *ProcessInfo) Reset()

func (*ProcessInfo) String 

func (x *ProcessInfo) String() string

type ProcessPayload 

type ProcessPayload struct {
	AgentId    string                 `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	HostId     string                 `protobuf:"bytes,2,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	Hostname   string                 `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	EndpointId string                 `protobuf:"bytes,4,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"`
	Timestamp  *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Processes  []*ProcessInfo         `protobuf:"bytes,6,rep,name=processes,proto3" json:"processes,omitempty"`
	Meta       *Meta                  `protobuf:"bytes,7,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessPayload) Descriptor deprecated 

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

Deprecated: Use ProcessPayload.ProtoReflect.Descriptor instead.

func (*ProcessPayload) GetAgentId 

func (x *ProcessPayload) GetAgentId() string

func (*ProcessPayload) GetEndpointId 

func (x *ProcessPayload) GetEndpointId() string

func (*ProcessPayload) GetHostId 

func (x *ProcessPayload) GetHostId() string

func (*ProcessPayload) GetHostname 

func (x *ProcessPayload) GetHostname() string

func (*ProcessPayload) GetMeta 

func (x *ProcessPayload) GetMeta() *Meta

func (*ProcessPayload) GetProcesses 

func (x *ProcessPayload) GetProcesses() []*ProcessInfo

func (*ProcessPayload) GetTimestamp 

func (x *ProcessPayload) GetTimestamp() *timestamppb.Timestamp

func (*ProcessPayload) ProtoMessage 

func (*ProcessPayload) ProtoMessage()

func (*ProcessPayload) ProtoReflect 

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

func (*ProcessPayload) Reset 

func (x *ProcessPayload) Reset()

func (*ProcessPayload) String 

func (x *ProcessPayload) String() string

type ProcessWrapper 

type ProcessWrapper struct {
	RawPayload []byte `protobuf:"bytes,1,opt,name=raw_payload,json=rawPayload,proto3" json:"raw_payload,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessWrapper) Descriptor deprecated 

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

Deprecated: Use ProcessWrapper.ProtoReflect.Descriptor instead.

func (*ProcessWrapper) GetRawPayload 

func (x *ProcessWrapper) GetRawPayload() []byte

func (*ProcessWrapper) ProtoMessage 

func (*ProcessWrapper) ProtoMessage()

func (*ProcessWrapper) ProtoReflect 

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

func (*ProcessWrapper) Reset 

func (x *ProcessWrapper) Reset()

func (*ProcessWrapper) String 

func (x *ProcessWrapper) String() string

type StatisticValues 

type StatisticValues struct {
	Minimum     float64 `protobuf:"fixed64,1,opt,name=minimum,proto3" json:"minimum,omitempty"`
	Maximum     float64 `protobuf:"fixed64,2,opt,name=maximum,proto3" json:"maximum,omitempty"`
	SampleCount int32   `protobuf:"varint,3,opt,name=sample_count,json=sampleCount,proto3" json:"sample_count,omitempty"`
	Sum         float64 `protobuf:"fixed64,4,opt,name=sum,proto3" json:"sum,omitempty"`
	// contains filtered or unexported fields
}

func (*StatisticValues) Descriptor deprecated 

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

Deprecated: Use StatisticValues.ProtoReflect.Descriptor instead.

func (*StatisticValues) GetMaximum 

func (x *StatisticValues) GetMaximum() float64

func (*StatisticValues) GetMinimum 

func (x *StatisticValues) GetMinimum() float64

func (*StatisticValues) GetSampleCount 

func (x *StatisticValues) GetSampleCount() int32

func (*StatisticValues) GetSum 

func (x *StatisticValues) GetSum() float64

func (*StatisticValues) ProtoMessage 

func (*StatisticValues) ProtoMessage()

func (*StatisticValues) ProtoReflect 

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

func (*StatisticValues) Reset 

func (x *StatisticValues) Reset()

func (*StatisticValues) String 

func (x *StatisticValues) String() string

type StreamPayload 

type StreamPayload struct {

	// Types that are valid to be assigned to Payload:
	//
	//	*StreamPayload_Metric
	//	*StreamPayload_CommandRequest
	//	*StreamPayload_CommandResponse
	//	*StreamPayload_Process
	Payload isStreamPayload_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*StreamPayload) Descriptor deprecated 

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

Deprecated: Use StreamPayload.ProtoReflect.Descriptor instead.

func (*StreamPayload) GetCommandRequest 

func (x *StreamPayload) GetCommandRequest() *CommandRequest

func (*StreamPayload) GetCommandResponse 

func (x *StreamPayload) GetCommandResponse() *CommandResponse

func (*StreamPayload) GetMetric 

func (x *StreamPayload) GetMetric() *MetricWrapper

func (*StreamPayload) GetPayload 

func (x *StreamPayload) GetPayload() isStreamPayload_Payload

func (*StreamPayload) GetProcess 

func (x *StreamPayload) GetProcess() *ProcessWrapper

func (*StreamPayload) ProtoMessage 

func (*StreamPayload) ProtoMessage()

func (*StreamPayload) ProtoReflect 

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

func (*StreamPayload) Reset 

func (x *StreamPayload) Reset()

func (*StreamPayload) String 

func (x *StreamPayload) String() string

type StreamPayload_CommandRequest 

type StreamPayload_CommandRequest struct {
	CommandRequest *CommandRequest `protobuf:"bytes,2,opt,name=command_request,json=commandRequest,proto3,oneof"`
}

type StreamPayload_CommandResponse 

type StreamPayload_CommandResponse struct {
	CommandResponse *CommandResponse `protobuf:"bytes,3,opt,name=command_response,json=commandResponse,proto3,oneof"`
}

type StreamPayload_Metric 

type StreamPayload_Metric struct {
	Metric *MetricWrapper `protobuf:"bytes,1,opt,name=metric,proto3,oneof"`
}

type StreamPayload_Process 

type StreamPayload_Process struct {
	Process *ProcessWrapper `protobuf:"bytes,5,opt,name=process,proto3,oneof"`
}

type StreamResponse 

type StreamResponse struct {
	Status     string          `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	StatusCode int32           `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Command    *CommandRequest `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"` // optional
	// contains filtered or unexported fields
}

func (*StreamResponse) Descriptor deprecated 

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

Deprecated: Use StreamResponse.ProtoReflect.Descriptor instead.

func (*StreamResponse) GetCommand 

func (x *StreamResponse) GetCommand() *CommandRequest

func (*StreamResponse) GetStatus 

func (x *StreamResponse) GetStatus() string

func (*StreamResponse) GetStatusCode 

func (x *StreamResponse) GetStatusCode() int32

func (*StreamResponse) ProtoMessage 

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) ProtoReflect 

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

func (*StreamResponse) Reset 

func (x *StreamResponse) Reset()

func (*StreamResponse) String 

func (x *StreamResponse) String() string

type StreamServiceClient 

type StreamServiceClient interface {
	Stream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[StreamPayload, StreamResponse], error)
}

StreamServiceClient is the client API for StreamService 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 NewStreamServiceClient 

func NewStreamServiceClient(cc grpc.ClientConnInterface) StreamServiceClient

type StreamServiceServer 

type StreamServiceServer interface {
	Stream(grpc.BidiStreamingServer[StreamPayload, StreamResponse]) error
	// contains filtered or unexported methods
}

StreamServiceServer is the server API for StreamService service. All implementations must embed UnimplementedStreamServiceServer for forward compatibility.

type StreamService_StreamClient 

type StreamService_StreamClient = grpc.BidiStreamingClient[StreamPayload, StreamResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StreamService_StreamServer 

type StreamService_StreamServer = grpc.BidiStreamingServer[StreamPayload, StreamResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedCommandServiceServer 

type UnimplementedCommandServiceServer struct{}

UnimplementedCommandServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedCommandServiceServer) ExecuteCommand 

func (UnimplementedCommandServiceServer) ExecuteCommand(context.Context, *CommandRequest) (*CommandResponse, error)

type UnimplementedLogServiceServer 

type UnimplementedLogServiceServer struct{}

UnimplementedLogServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedLogServiceServer) SubmitMetrics 

func (UnimplementedLogServiceServer) SubmitMetrics(context.Context, *LogPayload) (*LogResponse, error)

func (UnimplementedLogServiceServer) SubmitStream 

func (UnimplementedLogServiceServer) SubmitStream(grpc.ClientStreamingServer[LogPayload, LogResponse]) error

type UnimplementedStreamServiceServer 

type UnimplementedStreamServiceServer struct{}

UnimplementedStreamServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedStreamServiceServer) Stream 

func (UnimplementedStreamServiceServer) Stream(grpc.BidiStreamingServer[StreamPayload, StreamResponse]) error

type UnsafeCommandServiceServer 

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

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

type UnsafeLogServiceServer 

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

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

type UnsafeStreamServiceServer 

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

UnsafeStreamServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamServiceServer 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.