agent

package
v0.0.0-...-f219ead Latest Latest
Warning

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

Go to latest
Published: Sep 6, 2024 License: AGPL-3.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	AgentCommandStatus_name = map[int32]string{
		0: "NOT_EXECUTED",
		1: "QUEUE",
		2: "PENDING",
		3: "EXECUTED",
		4: "ERROR",
	}
	AgentCommandStatus_value = map[string]int32{
		"NOT_EXECUTED": 0,
		"QUEUE":        1,
		"PENDING":      2,
		"EXECUTED":     3,
		"ERROR":        4,
	}
)

Enum value maps for AgentCommandStatus.

View Source
var (
	MalwareStatus_name = map[int32]string{
		0: "NEW",
		1: "DELETED",
		2: "EXCLUDED",
		3: "RESTORED",
	}
	MalwareStatus_value = map[string]int32{
		"NEW":      0,
		"DELETED":  1,
		"EXCLUDED": 2,
		"RESTORED": 3,
	}
)

Enum value maps for MalwareStatus.

View Source
var (
	CollectorModule_name = map[int32]string{
		0: "AS_400",
	}
	CollectorModule_value = map[string]int32{
		"AS_400": 0,
	}
)

Enum value maps for CollectorModule.

View Source
var (
	Status_name = map[int32]string{
		0: "ONLINE",
		1: "OFFLINE",
		2: "UNKNOWN",
	}
	Status_value = map[string]int32{
		"ONLINE":  0,
		"OFFLINE": 1,
		"UNKNOWN": 2,
	}
)

Enum value maps for Status.

View Source
var (
	ConnectorType_name = map[int32]string{
		0: "AGENT",
		1: "COLLECTOR",
	}
	ConnectorType_value = map[string]int32{
		"AGENT":     0,
		"COLLECTOR": 1,
	}
)

Enum value maps for ConnectorType.

View Source
var (
	CacheAgent     map[uint]string
	CacheCollector map[uint]string
)
View Source
var AgentConfigService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "agent.AgentConfigService",
	HandlerType: (*AgentConfigServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetAgentConfig",
			Handler:    _AgentConfigService_GetAgentConfig_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "AgentModuleUpdateStream",
			Handler:       _AgentConfigService_AgentModuleUpdateStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "agent_config.proto",
}

AgentConfigService_ServiceDesc is the grpc.ServiceDesc for AgentConfigService 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 AgentGroupService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "agent.AgentGroupService",
	HandlerType: (*AgentGroupServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateGroup",
			Handler:    _AgentGroupService_CreateGroup_Handler,
		},
		{
			MethodName: "EditGroup",
			Handler:    _AgentGroupService_EditGroup_Handler,
		},
		{
			MethodName: "ListGroups",
			Handler:    _AgentGroupService_ListGroups_Handler,
		},
		{
			MethodName: "DeleteGroup",
			Handler:    _AgentGroupService_DeleteGroup_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "agent.proto",
}

AgentGroupService_ServiceDesc is the grpc.ServiceDesc for AgentGroupService 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 AgentMalwareService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "agent.AgentMalwareService",
	HandlerType: (*AgentMalwareServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetAgentExclusions",
			Handler:    _AgentMalwareService_GetAgentExclusions_Handler,
		},
		{
			MethodName: "ListAgentMalware",
			Handler:    _AgentMalwareService_ListAgentMalware_Handler,
		},
		{
			MethodName: "ListAgentMalwareHistory",
			Handler:    _AgentMalwareService_ListAgentMalwareHistory_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CreateNewMalwareEntry",
			Handler:       _AgentMalwareService_CreateNewMalwareEntry_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "ChangeMalwareStatus",
			Handler:       _AgentMalwareService_ChangeMalwareStatus_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "agent_malware.proto",
}

AgentMalwareService_ServiceDesc is the grpc.ServiceDesc for AgentMalwareService 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 AgentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "agent.AgentService",
	HandlerType: (*AgentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterAgent",
			Handler:    _AgentService_RegisterAgent_Handler,
		},
		{
			MethodName: "DeleteAgent",
			Handler:    _AgentService_DeleteAgent_Handler,
		},
		{
			MethodName: "ListAgents",
			Handler:    _AgentService_ListAgents_Handler,
		},
		{
			MethodName: "UpdateAgentType",
			Handler:    _AgentService_UpdateAgentType_Handler,
		},
		{
			MethodName: "UpdateAgentGroup",
			Handler:    _AgentService_UpdateAgentGroup_Handler,
		},
		{
			MethodName: "ListAgentCommands",
			Handler:    _AgentService_ListAgentCommands_Handler,
		},
		{
			MethodName: "GetAgentByHostname",
			Handler:    _AgentService_GetAgentByHostname_Handler,
		},
		{
			MethodName: "ListAgentsWithCommands",
			Handler:    _AgentService_ListAgentsWithCommands_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "AgentStream",
			Handler:       _AgentService_AgentStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "agent.proto",
}

AgentService_ServiceDesc is the grpc.ServiceDesc for AgentService 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 AgentTypeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "agent.AgentTypeService",
	HandlerType: (*AgentTypeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListAgentTypes",
			Handler:    _AgentTypeService_ListAgentTypes_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "agent.proto",
}

AgentTypeService_ServiceDesc is the grpc.ServiceDesc for AgentTypeService 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 CollectorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "agent.CollectorService",
	HandlerType: (*CollectorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterCollector",
			Handler:    _CollectorService_RegisterCollector_Handler,
		},
		{
			MethodName: "DeleteCollector",
			Handler:    _CollectorService_DeleteCollector_Handler,
		},
		{
			MethodName: "ListCollector",
			Handler:    _CollectorService_ListCollector_Handler,
		},
		{
			MethodName: "ListCollectorHostnames",
			Handler:    _CollectorService_ListCollectorHostnames_Handler,
		},
		{
			MethodName: "GetCollectorsByHostnameAndModule",
			Handler:    _CollectorService_GetCollectorsByHostnameAndModule_Handler,
		},
		{
			MethodName: "GetCollectorConfig",
			Handler:    _CollectorService_GetCollectorConfig_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CollectorStream",
			Handler:       _CollectorService_CollectorStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "collector.proto",
}

CollectorService_ServiceDesc is the grpc.ServiceDesc for CollectorService 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_agent_config_proto protoreflect.FileDescriptor
View Source
var File_agent_malware_proto protoreflect.FileDescriptor
View Source
var File_agent_proto protoreflect.FileDescriptor
View Source
var File_collector_proto protoreflect.FileDescriptor
View Source
var File_common_proto protoreflect.FileDescriptor
View Source
var PanelCollectorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "agent.PanelCollectorService",
	HandlerType: (*PanelCollectorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterCollectorConfig",
			Handler:    _PanelCollectorService_RegisterCollectorConfig_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "collector.proto",
}

PanelCollectorService_ServiceDesc is the grpc.ServiceDesc for PanelCollectorService 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 PanelService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "agent.PanelService",
	HandlerType: (*PanelServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ProcessCommand",
			Handler:       _PanelService_ProcessCommand_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "agent.proto",
}

PanelService_ServiceDesc is the grpc.ServiceDesc for PanelService 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 PingService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "agent.PingService",
	HandlerType: (*PingServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Ping",
			Handler:       _PingService_Ping_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "ping.proto",
}

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

Functions

func RegisterAgentConfigServiceServer

func RegisterAgentConfigServiceServer(s grpc.ServiceRegistrar, srv AgentConfigServiceServer)

func RegisterAgentGroupServiceServer

func RegisterAgentGroupServiceServer(s grpc.ServiceRegistrar, srv AgentGroupServiceServer)

func RegisterAgentMalwareServiceServer

func RegisterAgentMalwareServiceServer(s grpc.ServiceRegistrar, srv AgentMalwareServiceServer)

func RegisterAgentServiceServer

func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)

func RegisterAgentTypeServiceServer

func RegisterAgentTypeServiceServer(s grpc.ServiceRegistrar, srv AgentTypeServiceServer)

func RegisterCollectorServiceServer

func RegisterCollectorServiceServer(s grpc.ServiceRegistrar, srv CollectorServiceServer)

func RegisterPanelCollectorServiceServer

func RegisterPanelCollectorServiceServer(s grpc.ServiceRegistrar, srv PanelCollectorServiceServer)

func RegisterPanelServiceServer

func RegisterPanelServiceServer(s grpc.ServiceRegistrar, srv PanelServiceServer)

func RegisterPingServiceServer

func RegisterPingServiceServer(s grpc.ServiceRegistrar, srv PingServiceServer)

Types

type Agent

type Agent struct {
	Ip             string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Hostname       string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Os             string `protobuf:"bytes,3,opt,name=os,proto3" json:"os,omitempty"`
	Status         Status `protobuf:"varint,4,opt,name=status,proto3,enum=agent.Status" json:"status,omitempty"`
	Platform       string `protobuf:"bytes,5,opt,name=platform,proto3" json:"platform,omitempty"`
	Version        string `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"`
	AgentKey       string `protobuf:"bytes,7,opt,name=agent_key,json=agentKey,proto3" json:"agent_key,omitempty"`
	Id             uint32 `protobuf:"varint,8,opt,name=id,proto3" json:"id,omitempty"`
	LastSeen       string `protobuf:"bytes,9,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	Mac            string `protobuf:"bytes,10,opt,name=mac,proto3" json:"mac,omitempty"`
	OsMajorVersion string `protobuf:"bytes,11,opt,name=os_major_version,json=osMajorVersion,proto3" json:"os_major_version,omitempty"`
	OsMinorVersion string `protobuf:"bytes,12,opt,name=os_minor_version,json=osMinorVersion,proto3" json:"os_minor_version,omitempty"`
	Aliases        string `protobuf:"bytes,13,opt,name=aliases,proto3" json:"aliases,omitempty"`
	Addresses      string `protobuf:"bytes,14,opt,name=addresses,proto3" json:"addresses,omitempty"`
	// contains filtered or unexported fields
}

func (*Agent) Descriptor deprecated

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

Deprecated: Use Agent.ProtoReflect.Descriptor instead.

func (*Agent) GetAddresses

func (x *Agent) GetAddresses() string

func (*Agent) GetAgentKey

func (x *Agent) GetAgentKey() string

func (*Agent) GetAliases

func (x *Agent) GetAliases() string

func (*Agent) GetHostname

func (x *Agent) GetHostname() string

func (*Agent) GetId

func (x *Agent) GetId() uint32

func (*Agent) GetIp

func (x *Agent) GetIp() string

func (*Agent) GetLastSeen

func (x *Agent) GetLastSeen() string

func (*Agent) GetMac

func (x *Agent) GetMac() string

func (*Agent) GetOs

func (x *Agent) GetOs() string

func (*Agent) GetOsMajorVersion

func (x *Agent) GetOsMajorVersion() string

func (*Agent) GetOsMinorVersion

func (x *Agent) GetOsMinorVersion() string

func (*Agent) GetPlatform

func (x *Agent) GetPlatform() string

func (*Agent) GetStatus

func (x *Agent) GetStatus() Status

func (*Agent) GetVersion

func (x *Agent) GetVersion() 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 AgentCommand

type AgentCommand struct {
	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt     *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	AgentId       uint32                 `protobuf:"varint,3,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Command       string                 `protobuf:"bytes,4,opt,name=command,proto3" json:"command,omitempty"`
	CommandStatus AgentCommandStatus     `` /* 131-byte string literal not displayed */
	Result        string                 `protobuf:"bytes,6,opt,name=result,proto3" json:"result,omitempty"`
	ExecutedBy    string                 `protobuf:"bytes,7,opt,name=executed_by,json=executedBy,proto3" json:"executed_by,omitempty"`
	CmdId         string                 `protobuf:"bytes,8,opt,name=cmd_id,json=cmdId,proto3" json:"cmd_id,omitempty"`
	Agent         *Agent                 `protobuf:"bytes,9,opt,name=agent,proto3" json:"agent,omitempty"`
	Reason        string                 `protobuf:"bytes,10,opt,name=reason,proto3" json:"reason,omitempty"`
	OriginType    string                 `protobuf:"bytes,11,opt,name=origin_type,json=originType,proto3" json:"origin_type,omitempty"`
	OriginId      string                 `protobuf:"bytes,12,opt,name=origin_id,json=originId,proto3" json:"origin_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentCommand) Descriptor deprecated

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

Deprecated: Use AgentCommand.ProtoReflect.Descriptor instead.

func (*AgentCommand) GetAgent

func (x *AgentCommand) GetAgent() *Agent

func (*AgentCommand) GetAgentId

func (x *AgentCommand) GetAgentId() uint32

func (*AgentCommand) GetCmdId

func (x *AgentCommand) GetCmdId() string

func (*AgentCommand) GetCommand

func (x *AgentCommand) GetCommand() string

func (*AgentCommand) GetCommandStatus

func (x *AgentCommand) GetCommandStatus() AgentCommandStatus

func (*AgentCommand) GetCreatedAt

func (x *AgentCommand) GetCreatedAt() *timestamppb.Timestamp

func (*AgentCommand) GetExecutedBy

func (x *AgentCommand) GetExecutedBy() string

func (*AgentCommand) GetOriginId

func (x *AgentCommand) GetOriginId() string

func (*AgentCommand) GetOriginType

func (x *AgentCommand) GetOriginType() string

func (*AgentCommand) GetReason

func (x *AgentCommand) GetReason() string

func (*AgentCommand) GetResult

func (x *AgentCommand) GetResult() string

func (*AgentCommand) GetUpdatedAt

func (x *AgentCommand) GetUpdatedAt() *timestamppb.Timestamp

func (*AgentCommand) ProtoMessage

func (*AgentCommand) ProtoMessage()

func (*AgentCommand) ProtoReflect

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

func (*AgentCommand) Reset

func (x *AgentCommand) Reset()

func (*AgentCommand) String

func (x *AgentCommand) String() string

type AgentCommandStatus

type AgentCommandStatus int32
const (
	AgentCommandStatus_NOT_EXECUTED AgentCommandStatus = 0
	AgentCommandStatus_QUEUE        AgentCommandStatus = 1
	AgentCommandStatus_PENDING      AgentCommandStatus = 2
	AgentCommandStatus_EXECUTED     AgentCommandStatus = 3
	AgentCommandStatus_ERROR        AgentCommandStatus = 4
)

func (AgentCommandStatus) Descriptor

func (AgentCommandStatus) Enum

func (AgentCommandStatus) EnumDescriptor deprecated

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

Deprecated: Use AgentCommandStatus.Descriptor instead.

func (AgentCommandStatus) Number

func (AgentCommandStatus) String

func (x AgentCommandStatus) String() string

func (AgentCommandStatus) Type

type AgentConfigServiceClient

type AgentConfigServiceClient interface {
	GetAgentConfig(ctx context.Context, in *ListAgentsModulesRequest, opts ...grpc.CallOption) (*ListAgentsModulesResponse, error)
	AgentModuleUpdateStream(ctx context.Context, opts ...grpc.CallOption) (AgentConfigService_AgentModuleUpdateStreamClient, error)
}

AgentConfigServiceClient is the client API for AgentConfigService 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.

type AgentConfigServiceServer

type AgentConfigServiceServer interface {
	GetAgentConfig(context.Context, *ListAgentsModulesRequest) (*ListAgentsModulesResponse, error)
	AgentModuleUpdateStream(AgentConfigService_AgentModuleUpdateStreamServer) error
	// contains filtered or unexported methods
}

AgentConfigServiceServer is the server API for AgentConfigService service. All implementations must embed UnimplementedAgentConfigServiceServer for forward compatibility

type AgentConfigService_AgentModuleUpdateStreamClient

type AgentConfigService_AgentModuleUpdateStreamClient interface {
	Send(*AgentModuleConfiguration) error
	Recv() (*UpdateConfigResponse, error)
	grpc.ClientStream
}

type AgentConfigService_AgentModuleUpdateStreamServer

type AgentConfigService_AgentModuleUpdateStreamServer interface {
	Send(*UpdateConfigResponse) error
	Recv() (*AgentModuleConfiguration, error)
	grpc.ServerStream
}

type AgentDelete

type AgentDelete struct {
	DeletedBy string `protobuf:"bytes,1,opt,name=deleted_by,json=deletedBy,proto3" json:"deleted_by,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentDelete) Descriptor deprecated

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

Deprecated: Use AgentDelete.ProtoReflect.Descriptor instead.

func (*AgentDelete) GetDeletedBy

func (x *AgentDelete) GetDeletedBy() string

func (*AgentDelete) ProtoMessage

func (*AgentDelete) ProtoMessage()

func (*AgentDelete) ProtoReflect

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

func (*AgentDelete) Reset

func (x *AgentDelete) Reset()

func (*AgentDelete) String

func (x *AgentDelete) String() string

type AgentGroup

type AgentGroup struct {
	Id               uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	GroupName        string `protobuf:"bytes,2,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	GroupDescription string `protobuf:"bytes,3,opt,name=group_description,json=groupDescription,proto3" json:"group_description,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentGroup) Descriptor deprecated

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

Deprecated: Use AgentGroup.ProtoReflect.Descriptor instead.

func (*AgentGroup) GetGroupDescription

func (x *AgentGroup) GetGroupDescription() string

func (*AgentGroup) GetGroupName

func (x *AgentGroup) GetGroupName() string

func (*AgentGroup) GetId

func (x *AgentGroup) GetId() uint32

func (*AgentGroup) ProtoMessage

func (*AgentGroup) ProtoMessage()

func (*AgentGroup) ProtoReflect

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

func (*AgentGroup) Reset

func (x *AgentGroup) Reset()

func (*AgentGroup) String

func (x *AgentGroup) String() string

type AgentGroupServiceClient

type AgentGroupServiceClient interface {
	CreateGroup(ctx context.Context, in *AgentGroup, opts ...grpc.CallOption) (*AgentGroup, error)
	EditGroup(ctx context.Context, in *AgentGroup, opts ...grpc.CallOption) (*AgentGroup, error)
	ListGroups(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListAgentsGroupResponse, error)
	DeleteGroup(ctx context.Context, in *Id, opts ...grpc.CallOption) (*Id, error)
}

AgentGroupServiceClient is the client API for AgentGroupService 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.

type AgentGroupServiceServer

type AgentGroupServiceServer interface {
	CreateGroup(context.Context, *AgentGroup) (*AgentGroup, error)
	EditGroup(context.Context, *AgentGroup) (*AgentGroup, error)
	ListGroups(context.Context, *ListRequest) (*ListAgentsGroupResponse, error)
	DeleteGroup(context.Context, *Id) (*Id, error)
	// contains filtered or unexported methods
}

AgentGroupServiceServer is the server API for AgentGroupService service. All implementations must embed UnimplementedAgentGroupServiceServer for forward compatibility

type AgentGroupUpdate

type AgentGroupUpdate struct {
	AgentId    uint32 `protobuf:"varint,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	AgentGroup uint32 `protobuf:"varint,3,opt,name=agent_group,json=agentGroup,proto3" json:"agent_group,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentGroupUpdate) Descriptor deprecated

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

Deprecated: Use AgentGroupUpdate.ProtoReflect.Descriptor instead.

func (*AgentGroupUpdate) GetAgentGroup

func (x *AgentGroupUpdate) GetAgentGroup() uint32

func (*AgentGroupUpdate) GetAgentId

func (x *AgentGroupUpdate) GetAgentId() uint32

func (*AgentGroupUpdate) ProtoMessage

func (*AgentGroupUpdate) ProtoMessage()

func (*AgentGroupUpdate) ProtoReflect

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

func (*AgentGroupUpdate) Reset

func (x *AgentGroupUpdate) Reset()

func (*AgentGroupUpdate) String

func (x *AgentGroupUpdate) String() string

type AgentMalwareDetection

type AgentMalwareDetection struct {
	Id          int64         `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	AgentId     uint32        `protobuf:"varint,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	FilePath    string        `protobuf:"bytes,3,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	Sha256      string        `protobuf:"bytes,4,opt,name=sha256,proto3" json:"sha256,omitempty"`
	Md5         string        `protobuf:"bytes,5,opt,name=md5,proto3" json:"md5,omitempty"`
	Description string        `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	Status      MalwareStatus `protobuf:"varint,7,opt,name=status,proto3,enum=agent.MalwareStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentMalwareDetection) Descriptor deprecated

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

Deprecated: Use AgentMalwareDetection.ProtoReflect.Descriptor instead.

func (*AgentMalwareDetection) GetAgentId

func (x *AgentMalwareDetection) GetAgentId() uint32

func (*AgentMalwareDetection) GetDescription

func (x *AgentMalwareDetection) GetDescription() string

func (*AgentMalwareDetection) GetFilePath

func (x *AgentMalwareDetection) GetFilePath() string

func (*AgentMalwareDetection) GetId

func (x *AgentMalwareDetection) GetId() int64

func (*AgentMalwareDetection) GetMd5

func (x *AgentMalwareDetection) GetMd5() string

func (*AgentMalwareDetection) GetSha256

func (x *AgentMalwareDetection) GetSha256() string

func (*AgentMalwareDetection) GetStatus

func (x *AgentMalwareDetection) GetStatus() MalwareStatus

func (*AgentMalwareDetection) ProtoMessage

func (*AgentMalwareDetection) ProtoMessage()

func (*AgentMalwareDetection) ProtoReflect

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

func (*AgentMalwareDetection) Reset

func (x *AgentMalwareDetection) Reset()

func (*AgentMalwareDetection) String

func (x *AgentMalwareDetection) String() string

type AgentMalwareExclusion

type AgentMalwareExclusion struct {
	Id                 int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	ExcludeFilePath    string `protobuf:"bytes,2,opt,name=exclude_file_path,json=excludeFilePath,proto3" json:"exclude_file_path,omitempty"`
	ExcludedBy         string `protobuf:"bytes,3,opt,name=excluded_by,json=excludedBy,proto3" json:"excluded_by,omitempty"`
	ExcludeDescription string `protobuf:"bytes,4,opt,name=exclude_description,json=excludeDescription,proto3" json:"exclude_description,omitempty"`
	AgentId            int64  `protobuf:"varint,5,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentMalwareExclusion) Descriptor deprecated

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

Deprecated: Use AgentMalwareExclusion.ProtoReflect.Descriptor instead.

func (*AgentMalwareExclusion) GetAgentId

func (x *AgentMalwareExclusion) GetAgentId() int64

func (*AgentMalwareExclusion) GetExcludeDescription

func (x *AgentMalwareExclusion) GetExcludeDescription() string

func (*AgentMalwareExclusion) GetExcludeFilePath

func (x *AgentMalwareExclusion) GetExcludeFilePath() string

func (*AgentMalwareExclusion) GetExcludedBy

func (x *AgentMalwareExclusion) GetExcludedBy() string

func (*AgentMalwareExclusion) GetId

func (x *AgentMalwareExclusion) GetId() int64

func (*AgentMalwareExclusion) ProtoMessage

func (*AgentMalwareExclusion) ProtoMessage()

func (*AgentMalwareExclusion) ProtoReflect

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

func (*AgentMalwareExclusion) Reset

func (x *AgentMalwareExclusion) Reset()

func (*AgentMalwareExclusion) String

func (x *AgentMalwareExclusion) String() string

type AgentMalwareHistory

type AgentMalwareHistory struct {
	Id         int64         `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	MalwareId  uint32        `protobuf:"varint,2,opt,name=malware_id,json=malwareId,proto3" json:"malware_id,omitempty"`
	PrevStatus MalwareStatus `protobuf:"varint,3,opt,name=prev_status,json=prevStatus,proto3,enum=agent.MalwareStatus" json:"prev_status,omitempty"`
	ToStatus   MalwareStatus `protobuf:"varint,4,opt,name=to_status,json=toStatus,proto3,enum=agent.MalwareStatus" json:"to_status,omitempty"`
	ChangedBy  string        `protobuf:"bytes,5,opt,name=changed_by,json=changedBy,proto3" json:"changed_by,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentMalwareHistory) Descriptor deprecated

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

Deprecated: Use AgentMalwareHistory.ProtoReflect.Descriptor instead.

func (*AgentMalwareHistory) GetChangedBy

func (x *AgentMalwareHistory) GetChangedBy() string

func (*AgentMalwareHistory) GetId

func (x *AgentMalwareHistory) GetId() int64

func (*AgentMalwareHistory) GetMalwareId

func (x *AgentMalwareHistory) GetMalwareId() uint32

func (*AgentMalwareHistory) GetPrevStatus

func (x *AgentMalwareHistory) GetPrevStatus() MalwareStatus

func (*AgentMalwareHistory) GetToStatus

func (x *AgentMalwareHistory) GetToStatus() MalwareStatus

func (*AgentMalwareHistory) ProtoMessage

func (*AgentMalwareHistory) ProtoMessage()

func (*AgentMalwareHistory) ProtoReflect

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

func (*AgentMalwareHistory) Reset

func (x *AgentMalwareHistory) Reset()

func (*AgentMalwareHistory) String

func (x *AgentMalwareHistory) String() string

type AgentMalwareServiceClient

type AgentMalwareServiceClient interface {
	GetAgentExclusions(ctx context.Context, in *ListExclusionRequest, opts ...grpc.CallOption) (*ListExclusionResponse, error)
	CreateNewMalwareEntry(ctx context.Context, opts ...grpc.CallOption) (AgentMalwareService_CreateNewMalwareEntryClient, error)
	ChangeMalwareStatus(ctx context.Context, opts ...grpc.CallOption) (AgentMalwareService_ChangeMalwareStatusClient, error)
	ListAgentMalware(ctx context.Context, in *ListMalwareRequest, opts ...grpc.CallOption) (*ListMalwareResponse, error)
	ListAgentMalwareHistory(ctx context.Context, in *ListMalwareHistoryRequest, opts ...grpc.CallOption) (*ListMalwareHistoryResponse, error)
}

AgentMalwareServiceClient is the client API for AgentMalwareService 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.

type AgentMalwareServiceServer

type AgentMalwareServiceServer interface {
	GetAgentExclusions(context.Context, *ListExclusionRequest) (*ListExclusionResponse, error)
	CreateNewMalwareEntry(AgentMalwareService_CreateNewMalwareEntryServer) error
	ChangeMalwareStatus(AgentMalwareService_ChangeMalwareStatusServer) error
	ListAgentMalware(context.Context, *ListMalwareRequest) (*ListMalwareResponse, error)
	ListAgentMalwareHistory(context.Context, *ListMalwareHistoryRequest) (*ListMalwareHistoryResponse, error)
	// contains filtered or unexported methods
}

AgentMalwareServiceServer is the server API for AgentMalwareService service. All implementations must embed UnimplementedAgentMalwareServiceServer for forward compatibility

type AgentMalwareService_ChangeMalwareStatusClient

type AgentMalwareService_ChangeMalwareStatusClient interface {
	Send(*ChangeStatusRequest) error
	Recv() (*AgentMalwareDetection, error)
	grpc.ClientStream
}

type AgentMalwareService_ChangeMalwareStatusServer

type AgentMalwareService_ChangeMalwareStatusServer interface {
	Send(*AgentMalwareDetection) error
	Recv() (*ChangeStatusRequest, error)
	grpc.ServerStream
}

type AgentMalwareService_CreateNewMalwareEntryClient

type AgentMalwareService_CreateNewMalwareEntryClient interface {
	Send(*AgentMalwareDetection) error
	Recv() (*AgentMalwareDetection, error)
	grpc.ClientStream
}

type AgentMalwareService_CreateNewMalwareEntryServer

type AgentMalwareService_CreateNewMalwareEntryServer interface {
	Send(*AgentMalwareDetection) error
	Recv() (*AgentMalwareDetection, error)
	grpc.ServerStream
}

type AgentModule

type AgentModule struct {
	Id            uint32                      `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	AgentId       uint32                      `protobuf:"varint,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	ShortName     string                      `protobuf:"bytes,3,opt,name=short_name,json=shortName,proto3" json:"short_name,omitempty"`
	LargeName     string                      `protobuf:"bytes,4,opt,name=large_name,json=largeName,proto3" json:"large_name,omitempty"`
	Description   string                      `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	Enabled       bool                        `protobuf:"varint,6,opt,name=enabled,proto3" json:"enabled,omitempty"`
	AllowDisabled bool                        `protobuf:"varint,7,opt,name=allow_disabled,json=allowDisabled,proto3" json:"allow_disabled,omitempty"`
	ModuleConfigs []*AgentModuleConfiguration `protobuf:"bytes,8,rep,name=module_configs,json=moduleConfigs,proto3" json:"module_configs,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentModule) Descriptor deprecated

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

Deprecated: Use AgentModule.ProtoReflect.Descriptor instead.

func (*AgentModule) GetAgentId

func (x *AgentModule) GetAgentId() uint32

func (*AgentModule) GetAllowDisabled

func (x *AgentModule) GetAllowDisabled() bool

func (*AgentModule) GetDescription

func (x *AgentModule) GetDescription() string

func (*AgentModule) GetEnabled

func (x *AgentModule) GetEnabled() bool

func (*AgentModule) GetId

func (x *AgentModule) GetId() uint32

func (*AgentModule) GetLargeName

func (x *AgentModule) GetLargeName() string

func (*AgentModule) GetModuleConfigs

func (x *AgentModule) GetModuleConfigs() []*AgentModuleConfiguration

func (*AgentModule) GetShortName

func (x *AgentModule) GetShortName() string

func (*AgentModule) ProtoMessage

func (*AgentModule) ProtoMessage()

func (*AgentModule) ProtoReflect

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

func (*AgentModule) Reset

func (x *AgentModule) Reset()

func (*AgentModule) String

func (x *AgentModule) String() string

type AgentModuleConfiguration

type AgentModuleConfiguration struct {
	Id              uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	AgentModuleId   uint32 `protobuf:"varint,2,opt,name=agent_module_id,json=agentModuleId,proto3" json:"agent_module_id,omitempty"`
	ShortName       string `protobuf:"bytes,3,opt,name=short_name,json=shortName,proto3" json:"short_name,omitempty"`
	ConfKey         string `protobuf:"bytes,4,opt,name=conf_key,json=confKey,proto3" json:"conf_key,omitempty"`
	ConfValue       string `protobuf:"bytes,5,opt,name=conf_value,json=confValue,proto3" json:"conf_value,omitempty"`
	ConfName        string `protobuf:"bytes,6,opt,name=conf_name,json=confName,proto3" json:"conf_name,omitempty"`
	ConfDescription string `protobuf:"bytes,7,opt,name=conf_description,json=confDescription,proto3" json:"conf_description,omitempty"`
	ConfDatatype    string `protobuf:"bytes,8,opt,name=conf_datatype,json=confDatatype,proto3" json:"conf_datatype,omitempty"`
	ConfRequired    bool   `protobuf:"varint,9,opt,name=conf_required,json=confRequired,proto3" json:"conf_required,omitempty"`
	ConfRegex       string `protobuf:"bytes,10,opt,name=conf_regex,json=confRegex,proto3" json:"conf_regex,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentModuleConfiguration) Descriptor deprecated

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

Deprecated: Use AgentModuleConfiguration.ProtoReflect.Descriptor instead.

func (*AgentModuleConfiguration) GetAgentModuleId

func (x *AgentModuleConfiguration) GetAgentModuleId() uint32

func (*AgentModuleConfiguration) GetConfDatatype

func (x *AgentModuleConfiguration) GetConfDatatype() string

func (*AgentModuleConfiguration) GetConfDescription

func (x *AgentModuleConfiguration) GetConfDescription() string

func (*AgentModuleConfiguration) GetConfKey

func (x *AgentModuleConfiguration) GetConfKey() string

func (*AgentModuleConfiguration) GetConfName

func (x *AgentModuleConfiguration) GetConfName() string

func (*AgentModuleConfiguration) GetConfRegex

func (x *AgentModuleConfiguration) GetConfRegex() string

func (*AgentModuleConfiguration) GetConfRequired

func (x *AgentModuleConfiguration) GetConfRequired() bool

func (*AgentModuleConfiguration) GetConfValue

func (x *AgentModuleConfiguration) GetConfValue() string

func (*AgentModuleConfiguration) GetId

func (x *AgentModuleConfiguration) GetId() uint32

func (*AgentModuleConfiguration) GetShortName

func (x *AgentModuleConfiguration) GetShortName() string

func (*AgentModuleConfiguration) ProtoMessage

func (*AgentModuleConfiguration) ProtoMessage()

func (*AgentModuleConfiguration) ProtoReflect

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

func (*AgentModuleConfiguration) Reset

func (x *AgentModuleConfiguration) Reset()

func (*AgentModuleConfiguration) String

func (x *AgentModuleConfiguration) String() string

type AgentRequest

type AgentRequest struct {
	Ip             string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Hostname       string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Os             string `protobuf:"bytes,3,opt,name=os,proto3" json:"os,omitempty"`
	Platform       string `protobuf:"bytes,4,opt,name=platform,proto3" json:"platform,omitempty"`
	Version        string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	RegisterBy     string `protobuf:"bytes,6,opt,name=register_by,json=registerBy,proto3" json:"register_by,omitempty"`
	Mac            string `protobuf:"bytes,7,opt,name=mac,proto3" json:"mac,omitempty"`
	OsMajorVersion string `protobuf:"bytes,8,opt,name=os_major_version,json=osMajorVersion,proto3" json:"os_major_version,omitempty"`
	OsMinorVersion string `protobuf:"bytes,9,opt,name=os_minor_version,json=osMinorVersion,proto3" json:"os_minor_version,omitempty"`
	Aliases        string `protobuf:"bytes,10,opt,name=aliases,proto3" json:"aliases,omitempty"`
	Addresses      string `protobuf:"bytes,11,opt,name=addresses,proto3" json:"addresses,omitempty"` // IP secondary ips
	// contains filtered or unexported fields
}

func (*AgentRequest) Descriptor deprecated

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

Deprecated: Use AgentRequest.ProtoReflect.Descriptor instead.

func (*AgentRequest) GetAddresses

func (x *AgentRequest) GetAddresses() string

func (*AgentRequest) GetAliases

func (x *AgentRequest) GetAliases() string

func (*AgentRequest) GetHostname

func (x *AgentRequest) GetHostname() string

func (*AgentRequest) GetIp

func (x *AgentRequest) GetIp() string

func (*AgentRequest) GetMac

func (x *AgentRequest) GetMac() string

func (*AgentRequest) GetOs

func (x *AgentRequest) GetOs() string

func (*AgentRequest) GetOsMajorVersion

func (x *AgentRequest) GetOsMajorVersion() string

func (*AgentRequest) GetOsMinorVersion

func (x *AgentRequest) GetOsMinorVersion() string

func (*AgentRequest) GetPlatform

func (x *AgentRequest) GetPlatform() string

func (*AgentRequest) GetRegisterBy

func (x *AgentRequest) GetRegisterBy() string

func (*AgentRequest) GetVersion

func (x *AgentRequest) GetVersion() string

func (*AgentRequest) ProtoMessage

func (*AgentRequest) ProtoMessage()

func (*AgentRequest) ProtoReflect

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

func (*AgentRequest) Reset

func (x *AgentRequest) Reset()

func (*AgentRequest) String

func (x *AgentRequest) String() string

type AgentServiceClient

type AgentServiceClient interface {
	RegisterAgent(ctx context.Context, in *AgentRequest, opts ...grpc.CallOption) (*AuthResponse, error)
	DeleteAgent(ctx context.Context, in *AgentDelete, opts ...grpc.CallOption) (*AuthResponse, error)
	ListAgents(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListAgentsResponse, error)
	AgentStream(ctx context.Context, opts ...grpc.CallOption) (AgentService_AgentStreamClient, error)
	UpdateAgentType(ctx context.Context, in *AgentTypeUpdate, opts ...grpc.CallOption) (*Agent, error)
	UpdateAgentGroup(ctx context.Context, in *AgentGroupUpdate, opts ...grpc.CallOption) (*Agent, error)
	ListAgentCommands(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListAgentsCommandsResponse, error)
	GetAgentByHostname(ctx context.Context, in *Hostname, opts ...grpc.CallOption) (*Agent, error)
	ListAgentsWithCommands(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListAgentsResponse, error)
}

AgentServiceClient is the client API for AgentService 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.

type AgentServiceServer

type AgentServiceServer interface {
	RegisterAgent(context.Context, *AgentRequest) (*AuthResponse, error)
	DeleteAgent(context.Context, *AgentDelete) (*AuthResponse, error)
	ListAgents(context.Context, *ListRequest) (*ListAgentsResponse, error)
	AgentStream(AgentService_AgentStreamServer) error
	UpdateAgentType(context.Context, *AgentTypeUpdate) (*Agent, error)
	UpdateAgentGroup(context.Context, *AgentGroupUpdate) (*Agent, error)
	ListAgentCommands(context.Context, *ListRequest) (*ListAgentsCommandsResponse, error)
	GetAgentByHostname(context.Context, *Hostname) (*Agent, error)
	ListAgentsWithCommands(context.Context, *ListRequest) (*ListAgentsResponse, error)
	// contains filtered or unexported methods
}

AgentServiceServer is the server API for AgentService service. All implementations must embed UnimplementedAgentServiceServer for forward compatibility

type AgentService_AgentStreamClient

type AgentService_AgentStreamClient interface {
	Send(*BidirectionalStream) error
	Recv() (*BidirectionalStream, error)
	grpc.ClientStream
}

type AgentService_AgentStreamServer

type AgentService_AgentStreamServer interface {
	Send(*BidirectionalStream) error
	Recv() (*BidirectionalStream, error)
	grpc.ServerStream
}

type AgentType

type AgentType struct {
	Id       uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	TypeName string `protobuf:"bytes,2,opt,name=type_name,json=typeName,proto3" json:"type_name,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentType) Descriptor deprecated

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

Deprecated: Use AgentType.ProtoReflect.Descriptor instead.

func (*AgentType) GetId

func (x *AgentType) GetId() uint32

func (*AgentType) GetTypeName

func (x *AgentType) GetTypeName() string

func (*AgentType) ProtoMessage

func (*AgentType) ProtoMessage()

func (*AgentType) ProtoReflect

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

func (*AgentType) Reset

func (x *AgentType) Reset()

func (*AgentType) String

func (x *AgentType) String() string

type AgentTypeServiceClient

type AgentTypeServiceClient interface {
	ListAgentTypes(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListAgentsTypeResponse, error)
}

AgentTypeServiceClient is the client API for AgentTypeService 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.

type AgentTypeServiceServer

type AgentTypeServiceServer interface {
	ListAgentTypes(context.Context, *ListRequest) (*ListAgentsTypeResponse, error)
	// contains filtered or unexported methods
}

AgentTypeServiceServer is the server API for AgentTypeService service. All implementations must embed UnimplementedAgentTypeServiceServer for forward compatibility

type AgentTypeUpdate

type AgentTypeUpdate struct {
	AgentId   uint32 `protobuf:"varint,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	AgentType uint32 `protobuf:"varint,2,opt,name=agent_type,json=agentType,proto3" json:"agent_type,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentTypeUpdate) Descriptor deprecated

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

Deprecated: Use AgentTypeUpdate.ProtoReflect.Descriptor instead.

func (*AgentTypeUpdate) GetAgentId

func (x *AgentTypeUpdate) GetAgentId() uint32

func (*AgentTypeUpdate) GetAgentType

func (x *AgentTypeUpdate) GetAgentType() uint32

func (*AgentTypeUpdate) ProtoMessage

func (*AgentTypeUpdate) ProtoMessage()

func (*AgentTypeUpdate) ProtoReflect

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

func (*AgentTypeUpdate) Reset

func (x *AgentTypeUpdate) Reset()

func (*AgentTypeUpdate) String

func (x *AgentTypeUpdate) String() string

type AuthResponse

type AuthResponse struct {
	Id  uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthResponse) Descriptor deprecated

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

Deprecated: Use AuthResponse.ProtoReflect.Descriptor instead.

func (*AuthResponse) GetId

func (x *AuthResponse) GetId() uint32

func (*AuthResponse) GetKey

func (x *AuthResponse) GetKey() string

func (*AuthResponse) ProtoMessage

func (*AuthResponse) ProtoMessage()

func (*AuthResponse) ProtoReflect

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

func (*AuthResponse) Reset

func (x *AuthResponse) Reset()

func (*AuthResponse) String

func (x *AuthResponse) String() string

type BidirectionalStream

type BidirectionalStream struct {

	// Types that are assignable to StreamMessage:
	//
	//	*BidirectionalStream_Command
	//	*BidirectionalStream_Result
	StreamMessage isBidirectionalStream_StreamMessage `protobuf_oneof:"stream_message"`
	// contains filtered or unexported fields
}

func (*BidirectionalStream) Descriptor deprecated

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

Deprecated: Use BidirectionalStream.ProtoReflect.Descriptor instead.

func (*BidirectionalStream) GetCommand

func (x *BidirectionalStream) GetCommand() *UtmCommand

func (*BidirectionalStream) GetResult

func (x *BidirectionalStream) GetResult() *CommandResult

func (*BidirectionalStream) GetStreamMessage

func (m *BidirectionalStream) GetStreamMessage() isBidirectionalStream_StreamMessage

func (*BidirectionalStream) ProtoMessage

func (*BidirectionalStream) ProtoMessage()

func (*BidirectionalStream) ProtoReflect

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

func (*BidirectionalStream) Reset

func (x *BidirectionalStream) Reset()

func (*BidirectionalStream) String

func (x *BidirectionalStream) String() string

type BidirectionalStream_Command

type BidirectionalStream_Command struct {
	Command *UtmCommand `protobuf:"bytes,1,opt,name=command,proto3,oneof"`
}

type BidirectionalStream_Result

type BidirectionalStream_Result struct {
	Result *CommandResult `protobuf:"bytes,2,opt,name=result,proto3,oneof"`
}

type ChangeStatusRequest

type ChangeStatusRequest struct {
	MalwareId string        `protobuf:"bytes,1,opt,name=malware_id,json=malwareId,proto3" json:"malware_id,omitempty"`
	Status    MalwareStatus `protobuf:"varint,2,opt,name=status,proto3,enum=agent.MalwareStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeStatusRequest) Descriptor deprecated

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

Deprecated: Use ChangeStatusRequest.ProtoReflect.Descriptor instead.

func (*ChangeStatusRequest) GetMalwareId

func (x *ChangeStatusRequest) GetMalwareId() string

func (*ChangeStatusRequest) GetStatus

func (x *ChangeStatusRequest) GetStatus() MalwareStatus

func (*ChangeStatusRequest) ProtoMessage

func (*ChangeStatusRequest) ProtoMessage()

func (*ChangeStatusRequest) ProtoReflect

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

func (*ChangeStatusRequest) Reset

func (x *ChangeStatusRequest) Reset()

func (*ChangeStatusRequest) String

func (x *ChangeStatusRequest) String() string

type Collector

type Collector struct {
	Id           int32                   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Status       Status                  `protobuf:"varint,2,opt,name=status,proto3,enum=agent.Status" json:"status,omitempty"`
	CollectorKey string                  `protobuf:"bytes,3,opt,name=collector_key,json=collectorKey,proto3" json:"collector_key,omitempty"`
	Ip           string                  `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"`
	Hostname     string                  `protobuf:"bytes,5,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Version      string                  `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"`
	Module       CollectorModule         `protobuf:"varint,7,opt,name=module,proto3,enum=agent.CollectorModule" json:"module,omitempty"`
	Groups       []*CollectorConfigGroup `protobuf:"bytes,8,rep,name=groups,proto3" json:"groups,omitempty"`
	LastSeen     string                  `protobuf:"bytes,9,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	// contains filtered or unexported fields
}

func (*Collector) Descriptor deprecated

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

Deprecated: Use Collector.ProtoReflect.Descriptor instead.

func (*Collector) GetCollectorKey

func (x *Collector) GetCollectorKey() string

func (*Collector) GetGroups

func (x *Collector) GetGroups() []*CollectorConfigGroup

func (*Collector) GetHostname

func (x *Collector) GetHostname() string

func (*Collector) GetId

func (x *Collector) GetId() int32

func (*Collector) GetIp

func (x *Collector) GetIp() string

func (*Collector) GetLastSeen

func (x *Collector) GetLastSeen() string

func (*Collector) GetModule

func (x *Collector) GetModule() CollectorModule

func (*Collector) GetStatus

func (x *Collector) GetStatus() Status

func (*Collector) GetVersion

func (x *Collector) GetVersion() string

func (*Collector) ProtoMessage

func (*Collector) ProtoMessage()

func (*Collector) ProtoReflect

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

func (*Collector) Reset

func (x *Collector) Reset()

func (*Collector) String

func (x *Collector) String() string

type CollectorConfig

type CollectorConfig struct {
	CollectorKey string                  `protobuf:"bytes,1,opt,name=collector_key,json=collectorKey,proto3" json:"collector_key,omitempty"`
	Groups       []*CollectorConfigGroup `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups,omitempty"`
	RequestId    string                  `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectorConfig) Descriptor deprecated

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

Deprecated: Use CollectorConfig.ProtoReflect.Descriptor instead.

func (*CollectorConfig) GetCollectorKey

func (x *CollectorConfig) GetCollectorKey() string

func (*CollectorConfig) GetGroups

func (x *CollectorConfig) GetGroups() []*CollectorConfigGroup

func (*CollectorConfig) GetRequestId

func (x *CollectorConfig) GetRequestId() string

func (*CollectorConfig) ProtoMessage

func (*CollectorConfig) ProtoMessage()

func (*CollectorConfig) ProtoReflect

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

func (*CollectorConfig) Reset

func (x *CollectorConfig) Reset()

func (*CollectorConfig) String

func (x *CollectorConfig) String() string

type CollectorConfigGroup

type CollectorConfigGroup struct {
	Id               int32                           `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	GroupName        string                          `protobuf:"bytes,3,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	GroupDescription string                          `protobuf:"bytes,4,opt,name=group_description,json=groupDescription,proto3" json:"group_description,omitempty"`
	Configurations   []*CollectorGroupConfigurations `protobuf:"bytes,5,rep,name=configurations,proto3" json:"configurations,omitempty"`
	CollectorId      int32                           `protobuf:"varint,6,opt,name=collector_id,json=collectorId,proto3" json:"collector_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectorConfigGroup) Descriptor deprecated

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

Deprecated: Use CollectorConfigGroup.ProtoReflect.Descriptor instead.

func (*CollectorConfigGroup) GetCollectorId

func (x *CollectorConfigGroup) GetCollectorId() int32

func (*CollectorConfigGroup) GetConfigurations

func (x *CollectorConfigGroup) GetConfigurations() []*CollectorGroupConfigurations

func (*CollectorConfigGroup) GetGroupDescription

func (x *CollectorConfigGroup) GetGroupDescription() string

func (*CollectorConfigGroup) GetGroupName

func (x *CollectorConfigGroup) GetGroupName() string

func (*CollectorConfigGroup) GetId

func (x *CollectorConfigGroup) GetId() int32

func (*CollectorConfigGroup) ProtoMessage

func (*CollectorConfigGroup) ProtoMessage()

func (*CollectorConfigGroup) ProtoReflect

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

func (*CollectorConfigGroup) Reset

func (x *CollectorConfigGroup) Reset()

func (*CollectorConfigGroup) String

func (x *CollectorConfigGroup) String() string

type CollectorDelete

type CollectorDelete struct {
	DeletedBy string `protobuf:"bytes,1,opt,name=deleted_by,json=deletedBy,proto3" json:"deleted_by,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectorDelete) Descriptor deprecated

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

Deprecated: Use CollectorDelete.ProtoReflect.Descriptor instead.

func (*CollectorDelete) GetDeletedBy

func (x *CollectorDelete) GetDeletedBy() string

func (*CollectorDelete) ProtoMessage

func (*CollectorDelete) ProtoMessage()

func (*CollectorDelete) ProtoReflect

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

func (*CollectorDelete) Reset

func (x *CollectorDelete) Reset()

func (*CollectorDelete) String

func (x *CollectorDelete) String() string

type CollectorGroupConfigurations

type CollectorGroupConfigurations struct {
	GroupId         int32  `protobuf:"varint,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	ConfKey         string `protobuf:"bytes,3,opt,name=conf_key,json=confKey,proto3" json:"conf_key,omitempty"`
	ConfValue       string `protobuf:"bytes,4,opt,name=conf_value,json=confValue,proto3" json:"conf_value,omitempty"`
	ConfName        string `protobuf:"bytes,5,opt,name=conf_name,json=confName,proto3" json:"conf_name,omitempty"`
	ConfDescription string `protobuf:"bytes,6,opt,name=conf_description,json=confDescription,proto3" json:"conf_description,omitempty"`
	ConfDataType    string `protobuf:"bytes,7,opt,name=conf_data_type,json=confDataType,proto3" json:"conf_data_type,omitempty"`
	ConfRequired    bool   `protobuf:"varint,8,opt,name=conf_required,json=confRequired,proto3" json:"conf_required,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectorGroupConfigurations) Descriptor deprecated

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

Deprecated: Use CollectorGroupConfigurations.ProtoReflect.Descriptor instead.

func (*CollectorGroupConfigurations) GetConfDataType

func (x *CollectorGroupConfigurations) GetConfDataType() string

func (*CollectorGroupConfigurations) GetConfDescription

func (x *CollectorGroupConfigurations) GetConfDescription() string

func (*CollectorGroupConfigurations) GetConfKey

func (x *CollectorGroupConfigurations) GetConfKey() string

func (*CollectorGroupConfigurations) GetConfName

func (x *CollectorGroupConfigurations) GetConfName() string

func (*CollectorGroupConfigurations) GetConfRequired

func (x *CollectorGroupConfigurations) GetConfRequired() bool

func (*CollectorGroupConfigurations) GetConfValue

func (x *CollectorGroupConfigurations) GetConfValue() string

func (*CollectorGroupConfigurations) GetGroupId

func (x *CollectorGroupConfigurations) GetGroupId() int32

func (*CollectorGroupConfigurations) ProtoMessage

func (*CollectorGroupConfigurations) ProtoMessage()

func (*CollectorGroupConfigurations) ProtoReflect

func (*CollectorGroupConfigurations) Reset

func (x *CollectorGroupConfigurations) Reset()

func (*CollectorGroupConfigurations) String

type CollectorHostnames

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

func (*CollectorHostnames) Descriptor deprecated

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

Deprecated: Use CollectorHostnames.ProtoReflect.Descriptor instead.

func (*CollectorHostnames) GetHostname

func (x *CollectorHostnames) GetHostname() []string

func (*CollectorHostnames) ProtoMessage

func (*CollectorHostnames) ProtoMessage()

func (*CollectorHostnames) ProtoReflect

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

func (*CollectorHostnames) Reset

func (x *CollectorHostnames) Reset()

func (*CollectorHostnames) String

func (x *CollectorHostnames) String() string

type CollectorMessages

type CollectorMessages struct {

	// Types that are assignable to StreamMessage:
	//
	//	*CollectorMessages_Config
	//	*CollectorMessages_Result
	StreamMessage isCollectorMessages_StreamMessage `protobuf_oneof:"stream_message"`
	// contains filtered or unexported fields
}

func (*CollectorMessages) Descriptor deprecated

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

Deprecated: Use CollectorMessages.ProtoReflect.Descriptor instead.

func (*CollectorMessages) GetConfig

func (x *CollectorMessages) GetConfig() *CollectorConfig

func (*CollectorMessages) GetResult

func (x *CollectorMessages) GetResult() *ConfigKnowledge

func (*CollectorMessages) GetStreamMessage

func (m *CollectorMessages) GetStreamMessage() isCollectorMessages_StreamMessage

func (*CollectorMessages) ProtoMessage

func (*CollectorMessages) ProtoMessage()

func (*CollectorMessages) ProtoReflect

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

func (*CollectorMessages) Reset

func (x *CollectorMessages) Reset()

func (*CollectorMessages) String

func (x *CollectorMessages) String() string

type CollectorMessages_Config

type CollectorMessages_Config struct {
	Config *CollectorConfig `protobuf:"bytes,1,opt,name=config,proto3,oneof"`
}

type CollectorMessages_Result

type CollectorMessages_Result struct {
	Result *ConfigKnowledge `protobuf:"bytes,2,opt,name=result,proto3,oneof"`
}

type CollectorModule

type CollectorModule int32
const (
	CollectorModule_AS_400 CollectorModule = 0
)

func (CollectorModule) Descriptor

func (CollectorModule) Enum

func (x CollectorModule) Enum() *CollectorModule

func (CollectorModule) EnumDescriptor deprecated

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

Deprecated: Use CollectorModule.Descriptor instead.

func (CollectorModule) Number

func (CollectorModule) String

func (x CollectorModule) String() string

func (CollectorModule) Type

type CollectorServiceClient

type CollectorServiceClient interface {
	RegisterCollector(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*AuthResponse, error)
	DeleteCollector(ctx context.Context, in *CollectorDelete, opts ...grpc.CallOption) (*AuthResponse, error)
	ListCollector(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListCollectorResponse, error)
	CollectorStream(ctx context.Context, opts ...grpc.CallOption) (CollectorService_CollectorStreamClient, error)
	ListCollectorHostnames(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*CollectorHostnames, error)
	GetCollectorsByHostnameAndModule(ctx context.Context, in *FilterByHostAndModule, opts ...grpc.CallOption) (*ListCollectorResponse, error)
	GetCollectorConfig(ctx context.Context, in *ConfigRequest, opts ...grpc.CallOption) (*CollectorConfig, error)
}

CollectorServiceClient is the client API for CollectorService 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.

type CollectorServiceServer

type CollectorServiceServer interface {
	RegisterCollector(context.Context, *RegisterRequest) (*AuthResponse, error)
	DeleteCollector(context.Context, *CollectorDelete) (*AuthResponse, error)
	ListCollector(context.Context, *ListRequest) (*ListCollectorResponse, error)
	CollectorStream(CollectorService_CollectorStreamServer) error
	ListCollectorHostnames(context.Context, *ListRequest) (*CollectorHostnames, error)
	GetCollectorsByHostnameAndModule(context.Context, *FilterByHostAndModule) (*ListCollectorResponse, error)
	GetCollectorConfig(context.Context, *ConfigRequest) (*CollectorConfig, error)
	// contains filtered or unexported methods
}

CollectorServiceServer is the server API for CollectorService service. All implementations must embed UnimplementedCollectorServiceServer for forward compatibility

type CollectorService_CollectorStreamClient

type CollectorService_CollectorStreamClient interface {
	Send(*CollectorMessages) error
	Recv() (*CollectorMessages, error)
	grpc.ClientStream
}

type CollectorService_CollectorStreamServer

type CollectorService_CollectorStreamServer interface {
	Send(*CollectorMessages) error
	Recv() (*CollectorMessages, error)
	grpc.ServerStream
}

type CommandResult

type CommandResult struct {
	AgentKey   string                 `protobuf:"bytes,1,opt,name=agent_key,json=agentKey,proto3" json:"agent_key,omitempty"`
	Result     string                 `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	ExecutedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=executed_at,json=executedAt,proto3" json:"executed_at,omitempty"`
	CmdId      string                 `protobuf:"bytes,4,opt,name=cmd_id,json=cmdId,proto3" json:"cmd_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandResult) Descriptor deprecated

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

Deprecated: Use CommandResult.ProtoReflect.Descriptor instead.

func (*CommandResult) GetAgentKey

func (x *CommandResult) GetAgentKey() string

func (*CommandResult) GetCmdId

func (x *CommandResult) GetCmdId() string

func (*CommandResult) GetExecutedAt

func (x *CommandResult) GetExecutedAt() *timestamppb.Timestamp

func (*CommandResult) GetResult

func (x *CommandResult) GetResult() string

func (*CommandResult) ProtoMessage

func (*CommandResult) ProtoMessage()

func (*CommandResult) ProtoReflect

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

func (*CommandResult) Reset

func (x *CommandResult) Reset()

func (*CommandResult) String

func (x *CommandResult) String() string

type ConfigKnowledge

type ConfigKnowledge struct {
	Accepted  string `protobuf:"bytes,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigKnowledge) Descriptor deprecated

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

Deprecated: Use ConfigKnowledge.ProtoReflect.Descriptor instead.

func (*ConfigKnowledge) GetAccepted

func (x *ConfigKnowledge) GetAccepted() string

func (*ConfigKnowledge) GetRequestId

func (x *ConfigKnowledge) GetRequestId() string

func (*ConfigKnowledge) ProtoMessage

func (*ConfigKnowledge) ProtoMessage()

func (*ConfigKnowledge) ProtoReflect

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

func (*ConfigKnowledge) Reset

func (x *ConfigKnowledge) Reset()

func (*ConfigKnowledge) String

func (x *ConfigKnowledge) String() string

type ConfigRequest

type ConfigRequest struct {
	Module CollectorModule `protobuf:"varint,1,opt,name=module,proto3,enum=agent.CollectorModule" json:"module,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigRequest) Descriptor deprecated

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

Deprecated: Use ConfigRequest.ProtoReflect.Descriptor instead.

func (*ConfigRequest) GetModule

func (x *ConfigRequest) GetModule() CollectorModule

func (*ConfigRequest) ProtoMessage

func (*ConfigRequest) ProtoMessage()

func (*ConfigRequest) ProtoReflect

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

func (*ConfigRequest) Reset

func (x *ConfigRequest) Reset()

func (*ConfigRequest) String

func (x *ConfigRequest) String() string

type ConnectorType

type ConnectorType int32
const (
	ConnectorType_AGENT     ConnectorType = 0
	ConnectorType_COLLECTOR ConnectorType = 1
)

func (ConnectorType) Descriptor

func (ConnectorType) Enum

func (x ConnectorType) Enum() *ConnectorType

func (ConnectorType) EnumDescriptor deprecated

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

Deprecated: Use ConnectorType.Descriptor instead.

func (ConnectorType) Number

func (ConnectorType) String

func (x ConnectorType) String() string

func (ConnectorType) Type

type FilterByHostAndModule

type FilterByHostAndModule struct {
	Hostname string          `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Module   CollectorModule `protobuf:"varint,2,opt,name=module,proto3,enum=agent.CollectorModule" json:"module,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterByHostAndModule) Descriptor deprecated

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

Deprecated: Use FilterByHostAndModule.ProtoReflect.Descriptor instead.

func (*FilterByHostAndModule) GetHostname

func (x *FilterByHostAndModule) GetHostname() string

func (*FilterByHostAndModule) GetModule

func (x *FilterByHostAndModule) GetModule() CollectorModule

func (*FilterByHostAndModule) ProtoMessage

func (*FilterByHostAndModule) ProtoMessage()

func (*FilterByHostAndModule) ProtoReflect

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

func (*FilterByHostAndModule) Reset

func (x *FilterByHostAndModule) Reset()

func (*FilterByHostAndModule) String

func (x *FilterByHostAndModule) String() string

type Grpc

func InitGrpc

func InitGrpc() (*Grpc, error)

func (*Grpc) AgentModuleUpdateStream

func (s *Grpc) AgentModuleUpdateStream(stream AgentConfigService_AgentModuleUpdateStreamServer) error

func (*Grpc) AgentStream

func (s *Grpc) AgentStream(stream AgentService_AgentStreamServer) error

func (*Grpc) CollectorStream

func (s *Grpc) CollectorStream(stream CollectorService_CollectorStreamServer) error

func (*Grpc) CreateGroup

func (s *Grpc) CreateGroup(ctx context.Context, req *AgentGroup) (*AgentGroup, error)

func (*Grpc) DeleteAgent

func (s *Grpc) DeleteAgent(ctx context.Context, req *AgentDelete) (*AuthResponse, error)

func (*Grpc) DeleteCollector

func (s *Grpc) DeleteCollector(ctx context.Context, req *CollectorDelete) (*AuthResponse, error)

func (*Grpc) DeleteGroup

func (s *Grpc) DeleteGroup(ctx context.Context, req *Id) (*Id, error)

func (*Grpc) EditGroup

func (s *Grpc) EditGroup(ctx context.Context, req *AgentGroup) (*AgentGroup, error)

func (*Grpc) GetAgentByHostname

func (s *Grpc) GetAgentByHostname(ctx context.Context, req *Hostname) (*Agent, error)

func (*Grpc) GetAgentConfig

func (s *Grpc) GetAgentConfig()

func (*Grpc) GetCollectorConfig

func (s *Grpc) GetCollectorConfig(ctx context.Context, in *ConfigRequest) (*CollectorConfig, error)

func (*Grpc) GetCollectorsByHostnameAndModule

func (s *Grpc) GetCollectorsByHostnameAndModule(ctx context.Context, filter *FilterByHostAndModule) (*ListCollectorResponse, error)

func (*Grpc) GetStreamAuth

func (s *Grpc) GetStreamAuth(stream interface{}) (AuthResponse, error)

func (*Grpc) InitPingSync

func (s *Grpc) InitPingSync()

func (*Grpc) ListAgentCommands

func (s *Grpc) ListAgentCommands(ctx context.Context, req *ListRequest) (*ListAgentsCommandsResponse, error)

func (*Grpc) ListAgents

func (s *Grpc) ListAgents(ctx context.Context, req *ListRequest) (*ListAgentsResponse, error)

func (*Grpc) ListAgentsWithCommands

func (s *Grpc) ListAgentsWithCommands(ctx context.Context, req *ListRequest) (*ListAgentsResponse, error)

func (*Grpc) ListCollector

func (s *Grpc) ListCollector(ctx context.Context, req *ListRequest) (*ListCollectorResponse, error)

func (*Grpc) ListCollectorHostnames

func (s *Grpc) ListCollectorHostnames(ctx context.Context, req *ListRequest) (*CollectorHostnames, error)

func (*Grpc) ListGroups

func (s *Grpc) ListGroups(ctx context.Context, req *ListRequest) (*ListAgentsGroupResponse, error)

func (*Grpc) LoadAgentCacheFromDatabase

func (s *Grpc) LoadAgentCacheFromDatabase() error

func (*Grpc) LoadCollectorsCacheFromDatabase

func (s *Grpc) LoadCollectorsCacheFromDatabase() error

func (*Grpc) Ping

func (s *Grpc) Ping(stream PingService_PingServer) error

func (*Grpc) ProcessCommand

func (s *Grpc) ProcessCommand(stream PanelService_ProcessCommandServer) error

func (*Grpc) ProcessPendingConfigs

func (s *Grpc) ProcessPendingConfigs()

func (*Grpc) RegisterAgent

func (s *Grpc) RegisterAgent(ctx context.Context, req *AgentRequest) (*AuthResponse, error)

func (*Grpc) RegisterCollector

func (s *Grpc) RegisterCollector(ctx context.Context, req *RegisterRequest) (*AuthResponse, error)

func (*Grpc) RegisterCollectorConfig

func (s *Grpc) RegisterCollectorConfig(ctx context.Context, in *CollectorConfig) (*ConfigKnowledge, error)

func (*Grpc) UpdateAgentGroup

func (s *Grpc) UpdateAgentGroup(ctx context.Context, req *AgentGroupUpdate) (*Agent, error)

func (*Grpc) UpdateAgentType

func (s *Grpc) UpdateAgentType(ctx context.Context, req *AgentTypeUpdate) (*Agent, error)

type Hostname

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

func (*Hostname) Descriptor deprecated

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

Deprecated: Use Hostname.ProtoReflect.Descriptor instead.

func (*Hostname) GetHostname

func (x *Hostname) GetHostname() string

func (*Hostname) ProtoMessage

func (*Hostname) ProtoMessage()

func (*Hostname) ProtoReflect

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

func (*Hostname) Reset

func (x *Hostname) Reset()

func (*Hostname) String

func (x *Hostname) String() string

type Id

type Id struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*Id) Descriptor deprecated

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

Deprecated: Use Id.ProtoReflect.Descriptor instead.

func (*Id) GetId

func (x *Id) GetId() int64

func (*Id) ProtoMessage

func (*Id) ProtoMessage()

func (*Id) ProtoReflect

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

func (*Id) Reset

func (x *Id) Reset()

func (*Id) String

func (x *Id) String() string

type ListAgentsCommandsResponse

type ListAgentsCommandsResponse struct {
	Rows  []*AgentCommand `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	Total int32           `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAgentsCommandsResponse) Descriptor deprecated

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

Deprecated: Use ListAgentsCommandsResponse.ProtoReflect.Descriptor instead.

func (*ListAgentsCommandsResponse) GetRows

func (x *ListAgentsCommandsResponse) GetRows() []*AgentCommand

func (*ListAgentsCommandsResponse) GetTotal

func (x *ListAgentsCommandsResponse) GetTotal() int32

func (*ListAgentsCommandsResponse) ProtoMessage

func (*ListAgentsCommandsResponse) ProtoMessage()

func (*ListAgentsCommandsResponse) ProtoReflect

func (*ListAgentsCommandsResponse) Reset

func (x *ListAgentsCommandsResponse) Reset()

func (*ListAgentsCommandsResponse) String

func (x *ListAgentsCommandsResponse) String() string

type ListAgentsGroupResponse

type ListAgentsGroupResponse struct {
	Rows  []*AgentGroup `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	Total int32         `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAgentsGroupResponse) Descriptor deprecated

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

Deprecated: Use ListAgentsGroupResponse.ProtoReflect.Descriptor instead.

func (*ListAgentsGroupResponse) GetRows

func (x *ListAgentsGroupResponse) GetRows() []*AgentGroup

func (*ListAgentsGroupResponse) GetTotal

func (x *ListAgentsGroupResponse) GetTotal() int32

func (*ListAgentsGroupResponse) ProtoMessage

func (*ListAgentsGroupResponse) ProtoMessage()

func (*ListAgentsGroupResponse) ProtoReflect

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

func (*ListAgentsGroupResponse) Reset

func (x *ListAgentsGroupResponse) Reset()

func (*ListAgentsGroupResponse) String

func (x *ListAgentsGroupResponse) String() string

type ListAgentsModulesRequest

type ListAgentsModulesRequest struct {
	AgentKey string `protobuf:"bytes,2,opt,name=agent_key,json=agentKey,proto3" json:"agent_key,omitempty"`
	// contains filtered or unexported fields
}

ListAgentsRequest message definition

func (*ListAgentsModulesRequest) Descriptor deprecated

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

Deprecated: Use ListAgentsModulesRequest.ProtoReflect.Descriptor instead.

func (*ListAgentsModulesRequest) GetAgentKey

func (x *ListAgentsModulesRequest) GetAgentKey() string

func (*ListAgentsModulesRequest) ProtoMessage

func (*ListAgentsModulesRequest) ProtoMessage()

func (*ListAgentsModulesRequest) ProtoReflect

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

func (*ListAgentsModulesRequest) Reset

func (x *ListAgentsModulesRequest) Reset()

func (*ListAgentsModulesRequest) String

func (x *ListAgentsModulesRequest) String() string

type ListAgentsModulesResponse

type ListAgentsModulesResponse struct {
	Modules []*AgentModule `protobuf:"bytes,1,rep,name=modules,proto3" json:"modules,omitempty"`
	// contains filtered or unexported fields
}

ListAgentsResponse message definition

func (*ListAgentsModulesResponse) Descriptor deprecated

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

Deprecated: Use ListAgentsModulesResponse.ProtoReflect.Descriptor instead.

func (*ListAgentsModulesResponse) GetModules

func (x *ListAgentsModulesResponse) GetModules() []*AgentModule

func (*ListAgentsModulesResponse) ProtoMessage

func (*ListAgentsModulesResponse) ProtoMessage()

func (*ListAgentsModulesResponse) ProtoReflect

func (*ListAgentsModulesResponse) Reset

func (x *ListAgentsModulesResponse) Reset()

func (*ListAgentsModulesResponse) String

func (x *ListAgentsModulesResponse) String() string

type ListAgentsResponse

type ListAgentsResponse struct {
	Rows  []*Agent `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	Total int32    `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAgentsResponse) Descriptor deprecated

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

Deprecated: Use ListAgentsResponse.ProtoReflect.Descriptor instead.

func (*ListAgentsResponse) GetRows

func (x *ListAgentsResponse) GetRows() []*Agent

func (*ListAgentsResponse) GetTotal

func (x *ListAgentsResponse) GetTotal() int32

func (*ListAgentsResponse) ProtoMessage

func (*ListAgentsResponse) ProtoMessage()

func (*ListAgentsResponse) ProtoReflect

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

func (*ListAgentsResponse) Reset

func (x *ListAgentsResponse) Reset()

func (*ListAgentsResponse) String

func (x *ListAgentsResponse) String() string

type ListAgentsTypeResponse

type ListAgentsTypeResponse struct {
	Rows  []*AgentType `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	Total int32        `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAgentsTypeResponse) Descriptor deprecated

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

Deprecated: Use ListAgentsTypeResponse.ProtoReflect.Descriptor instead.

func (*ListAgentsTypeResponse) GetRows

func (x *ListAgentsTypeResponse) GetRows() []*AgentType

func (*ListAgentsTypeResponse) GetTotal

func (x *ListAgentsTypeResponse) GetTotal() int32

func (*ListAgentsTypeResponse) ProtoMessage

func (*ListAgentsTypeResponse) ProtoMessage()

func (*ListAgentsTypeResponse) ProtoReflect

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

func (*ListAgentsTypeResponse) Reset

func (x *ListAgentsTypeResponse) Reset()

func (*ListAgentsTypeResponse) String

func (x *ListAgentsTypeResponse) String() string

type ListCollectorResponse

type ListCollectorResponse struct {
	Rows  []*Collector `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	Total int32        `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*ListCollectorResponse) Descriptor deprecated

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

Deprecated: Use ListCollectorResponse.ProtoReflect.Descriptor instead.

func (*ListCollectorResponse) GetRows

func (x *ListCollectorResponse) GetRows() []*Collector

func (*ListCollectorResponse) GetTotal

func (x *ListCollectorResponse) GetTotal() int32

func (*ListCollectorResponse) ProtoMessage

func (*ListCollectorResponse) ProtoMessage()

func (*ListCollectorResponse) ProtoReflect

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

func (*ListCollectorResponse) Reset

func (x *ListCollectorResponse) Reset()

func (*ListCollectorResponse) String

func (x *ListCollectorResponse) String() string

type ListExclusionRequest

type ListExclusionRequest struct {
	AgentId int64 `protobuf:"varint,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListExclusionRequest) Descriptor deprecated

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

Deprecated: Use ListExclusionRequest.ProtoReflect.Descriptor instead.

func (*ListExclusionRequest) GetAgentId

func (x *ListExclusionRequest) GetAgentId() int64

func (*ListExclusionRequest) ProtoMessage

func (*ListExclusionRequest) ProtoMessage()

func (*ListExclusionRequest) ProtoReflect

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

func (*ListExclusionRequest) Reset

func (x *ListExclusionRequest) Reset()

func (*ListExclusionRequest) String

func (x *ListExclusionRequest) String() string

type ListExclusionResponse

type ListExclusionResponse struct {
	Exclusions []*AgentMalwareExclusion `protobuf:"bytes,1,rep,name=exclusions,proto3" json:"exclusions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListExclusionResponse) Descriptor deprecated

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

Deprecated: Use ListExclusionResponse.ProtoReflect.Descriptor instead.

func (*ListExclusionResponse) GetExclusions

func (x *ListExclusionResponse) GetExclusions() []*AgentMalwareExclusion

func (*ListExclusionResponse) ProtoMessage

func (*ListExclusionResponse) ProtoMessage()

func (*ListExclusionResponse) ProtoReflect

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

func (*ListExclusionResponse) Reset

func (x *ListExclusionResponse) Reset()

func (*ListExclusionResponse) String

func (x *ListExclusionResponse) String() string

type ListMalwareHistoryRequest

type ListMalwareHistoryRequest struct {
	PageNumber     int32    `protobuf:"varint,1,opt,name=page_number,json=pageNumber,proto3" json:"page_number,omitempty"`
	PageSize       int32    `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	SearchQuery    string   `protobuf:"bytes,3,opt,name=search_query,json=searchQuery,proto3" json:"search_query,omitempty"`
	SortBy         []string `protobuf:"bytes,4,rep,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	SortDescending bool     `protobuf:"varint,5,opt,name=sort_descending,json=sortDescending,proto3" json:"sort_descending,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMalwareHistoryRequest) Descriptor deprecated

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

Deprecated: Use ListMalwareHistoryRequest.ProtoReflect.Descriptor instead.

func (*ListMalwareHistoryRequest) GetPageNumber

func (x *ListMalwareHistoryRequest) GetPageNumber() int32

func (*ListMalwareHistoryRequest) GetPageSize

func (x *ListMalwareHistoryRequest) GetPageSize() int32

func (*ListMalwareHistoryRequest) GetSearchQuery

func (x *ListMalwareHistoryRequest) GetSearchQuery() string

func (*ListMalwareHistoryRequest) GetSortBy

func (x *ListMalwareHistoryRequest) GetSortBy() []string

func (*ListMalwareHistoryRequest) GetSortDescending

func (x *ListMalwareHistoryRequest) GetSortDescending() bool

func (*ListMalwareHistoryRequest) ProtoMessage

func (*ListMalwareHistoryRequest) ProtoMessage()

func (*ListMalwareHistoryRequest) ProtoReflect

func (*ListMalwareHistoryRequest) Reset

func (x *ListMalwareHistoryRequest) Reset()

func (*ListMalwareHistoryRequest) String

func (x *ListMalwareHistoryRequest) String() string

type ListMalwareHistoryResponse

type ListMalwareHistoryResponse struct {
	Malware      []*AgentMalwareHistory `protobuf:"bytes,1,rep,name=malware,proto3" json:"malware,omitempty"`
	TotalPages   int32                  `protobuf:"varint,2,opt,name=total_pages,json=totalPages,proto3" json:"total_pages,omitempty"`
	TotalResults int32                  `protobuf:"varint,3,opt,name=total_results,json=totalResults,proto3" json:"total_results,omitempty"`
	// contains filtered or unexported fields
}

ListAgentsResponse message definition

func (*ListMalwareHistoryResponse) Descriptor deprecated

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

Deprecated: Use ListMalwareHistoryResponse.ProtoReflect.Descriptor instead.

func (*ListMalwareHistoryResponse) GetMalware

func (*ListMalwareHistoryResponse) GetTotalPages

func (x *ListMalwareHistoryResponse) GetTotalPages() int32

func (*ListMalwareHistoryResponse) GetTotalResults

func (x *ListMalwareHistoryResponse) GetTotalResults() int32

func (*ListMalwareHistoryResponse) ProtoMessage

func (*ListMalwareHistoryResponse) ProtoMessage()

func (*ListMalwareHistoryResponse) ProtoReflect

func (*ListMalwareHistoryResponse) Reset

func (x *ListMalwareHistoryResponse) Reset()

func (*ListMalwareHistoryResponse) String

func (x *ListMalwareHistoryResponse) String() string

type ListMalwareRequest

type ListMalwareRequest struct {
	PageNumber     int32    `protobuf:"varint,1,opt,name=page_number,json=pageNumber,proto3" json:"page_number,omitempty"`
	PageSize       int32    `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	SearchQuery    string   `protobuf:"bytes,3,opt,name=search_query,json=searchQuery,proto3" json:"search_query,omitempty"`
	SortBy         []string `protobuf:"bytes,4,rep,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	SortDescending bool     `protobuf:"varint,5,opt,name=sort_descending,json=sortDescending,proto3" json:"sort_descending,omitempty"`
	// contains filtered or unexported fields
}

ListAgentsRequest message definition

func (*ListMalwareRequest) Descriptor deprecated

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

Deprecated: Use ListMalwareRequest.ProtoReflect.Descriptor instead.

func (*ListMalwareRequest) GetPageNumber

func (x *ListMalwareRequest) GetPageNumber() int32

func (*ListMalwareRequest) GetPageSize

func (x *ListMalwareRequest) GetPageSize() int32

func (*ListMalwareRequest) GetSearchQuery

func (x *ListMalwareRequest) GetSearchQuery() string

func (*ListMalwareRequest) GetSortBy

func (x *ListMalwareRequest) GetSortBy() []string

func (*ListMalwareRequest) GetSortDescending

func (x *ListMalwareRequest) GetSortDescending() bool

func (*ListMalwareRequest) ProtoMessage

func (*ListMalwareRequest) ProtoMessage()

func (*ListMalwareRequest) ProtoReflect

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

func (*ListMalwareRequest) Reset

func (x *ListMalwareRequest) Reset()

func (*ListMalwareRequest) String

func (x *ListMalwareRequest) String() string

type ListMalwareResponse

type ListMalwareResponse struct {
	Malware      []*AgentMalwareDetection `protobuf:"bytes,1,rep,name=malware,proto3" json:"malware,omitempty"`
	TotalPages   int32                    `protobuf:"varint,2,opt,name=total_pages,json=totalPages,proto3" json:"total_pages,omitempty"`
	TotalResults int32                    `protobuf:"varint,3,opt,name=total_results,json=totalResults,proto3" json:"total_results,omitempty"`
	// contains filtered or unexported fields
}

ListAgentsResponse message definition

func (*ListMalwareResponse) Descriptor deprecated

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

Deprecated: Use ListMalwareResponse.ProtoReflect.Descriptor instead.

func (*ListMalwareResponse) GetMalware

func (x *ListMalwareResponse) GetMalware() []*AgentMalwareDetection

func (*ListMalwareResponse) GetTotalPages

func (x *ListMalwareResponse) GetTotalPages() int32

func (*ListMalwareResponse) GetTotalResults

func (x *ListMalwareResponse) GetTotalResults() int32

func (*ListMalwareResponse) ProtoMessage

func (*ListMalwareResponse) ProtoMessage()

func (*ListMalwareResponse) ProtoReflect

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

func (*ListMalwareResponse) Reset

func (x *ListMalwareResponse) Reset()

func (*ListMalwareResponse) String

func (x *ListMalwareResponse) String() string

type ListRequest

type ListRequest struct {
	PageNumber  int32  `protobuf:"varint,1,opt,name=page_number,json=pageNumber,proto3" json:"page_number,omitempty"`
	PageSize    int32  `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	SearchQuery string `protobuf:"bytes,3,opt,name=search_query,json=searchQuery,proto3" json:"search_query,omitempty"`
	SortBy      string `protobuf:"bytes,4,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetPageNumber

func (x *ListRequest) GetPageNumber() int32

func (*ListRequest) GetPageSize

func (x *ListRequest) GetPageSize() int32

func (*ListRequest) GetSearchQuery

func (x *ListRequest) GetSearchQuery() string

func (*ListRequest) GetSortBy

func (x *ListRequest) GetSortBy() string

func (*ListRequest) ProtoMessage

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect

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

func (*ListRequest) Reset

func (x *ListRequest) Reset()

func (*ListRequest) String

func (x *ListRequest) String() string

type MalwareStatus

type MalwareStatus int32
const (
	MalwareStatus_NEW      MalwareStatus = 0
	MalwareStatus_DELETED  MalwareStatus = 1
	MalwareStatus_EXCLUDED MalwareStatus = 2
	MalwareStatus_RESTORED MalwareStatus = 3
)

func (MalwareStatus) Descriptor

func (MalwareStatus) Enum

func (x MalwareStatus) Enum() *MalwareStatus

func (MalwareStatus) EnumDescriptor deprecated

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

Deprecated: Use MalwareStatus.Descriptor instead.

func (MalwareStatus) Number

func (MalwareStatus) String

func (x MalwareStatus) String() string

func (MalwareStatus) Type

type PanelCollectorServiceClient

type PanelCollectorServiceClient interface {
	RegisterCollectorConfig(ctx context.Context, in *CollectorConfig, opts ...grpc.CallOption) (*ConfigKnowledge, error)
}

PanelCollectorServiceClient is the client API for PanelCollectorService 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.

type PanelCollectorServiceServer

type PanelCollectorServiceServer interface {
	RegisterCollectorConfig(context.Context, *CollectorConfig) (*ConfigKnowledge, error)
	// contains filtered or unexported methods
}

PanelCollectorServiceServer is the server API for PanelCollectorService service. All implementations must embed UnimplementedPanelCollectorServiceServer for forward compatibility

type PanelServiceClient

type PanelServiceClient interface {
	ProcessCommand(ctx context.Context, opts ...grpc.CallOption) (PanelService_ProcessCommandClient, error)
}

PanelServiceClient is the client API for PanelService 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.

type PanelServiceServer

type PanelServiceServer interface {
	ProcessCommand(PanelService_ProcessCommandServer) error
	// contains filtered or unexported methods
}

PanelServiceServer is the server API for PanelService service. All implementations must embed UnimplementedPanelServiceServer for forward compatibility

type PanelService_ProcessCommandClient

type PanelService_ProcessCommandClient interface {
	Send(*UtmCommand) error
	Recv() (*CommandResult, error)
	grpc.ClientStream
}

type PanelService_ProcessCommandServer

type PanelService_ProcessCommandServer interface {
	Send(*CommandResult) error
	Recv() (*UtmCommand, error)
	grpc.ServerStream
}

type PingRequest

type PingRequest struct {
	Type ConnectorType `protobuf:"varint,1,opt,name=type,proto3,enum=agent.ConnectorType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*PingRequest) Descriptor deprecated

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) GetType

func (x *PingRequest) GetType() ConnectorType

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect

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

func (*PingRequest) Reset

func (x *PingRequest) Reset()

func (*PingRequest) String

func (x *PingRequest) String() string

type PingResponse

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

func (*PingResponse) Descriptor deprecated

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetReceived

func (x *PingResponse) GetReceived() string

func (*PingResponse) ProtoMessage

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect

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

func (*PingResponse) Reset

func (x *PingResponse) Reset()

func (*PingResponse) String

func (x *PingResponse) String() string

type PingServiceClient

type PingServiceClient interface {
	Ping(ctx context.Context, opts ...grpc.CallOption) (PingService_PingClient, error)
}

PingServiceClient is the client API for PingService 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.

type PingServiceServer

type PingServiceServer interface {
	Ping(PingService_PingServer) error
	// contains filtered or unexported methods
}

PingServiceServer is the server API for PingService service. All implementations must embed UnimplementedPingServiceServer for forward compatibility

type PingService_PingClient

type PingService_PingClient interface {
	Send(*PingRequest) error
	CloseAndRecv() (*PingResponse, error)
	grpc.ClientStream
}

type PingService_PingServer

type PingService_PingServer interface {
	SendAndClose(*PingResponse) error
	Recv() (*PingRequest, error)
	grpc.ServerStream
}

type RegisterRequest

type RegisterRequest struct {
	Ip        string          `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Hostname  string          `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Version   string          `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Collector CollectorModule `protobuf:"varint,4,opt,name=collector,proto3,enum=agent.CollectorModule" json:"collector,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRequest) Descriptor deprecated

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetCollector

func (x *RegisterRequest) GetCollector() CollectorModule

func (*RegisterRequest) GetHostname

func (x *RegisterRequest) GetHostname() string

func (*RegisterRequest) GetIp

func (x *RegisterRequest) GetIp() string

func (*RegisterRequest) GetVersion

func (x *RegisterRequest) GetVersion() string

func (*RegisterRequest) ProtoMessage

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect

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

func (*RegisterRequest) Reset

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String

func (x *RegisterRequest) String() string

type ResultCallback

type ResultCallback func(result *CommandResult)

type Status

type Status int32
const (
	Status_ONLINE  Status = 0
	Status_OFFLINE Status = 1
	Status_UNKNOWN Status = 2
)

func (Status) Descriptor

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated

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

Deprecated: Use Status.Descriptor instead.

func (Status) Number

func (x Status) Number() protoreflect.EnumNumber

func (Status) String

func (x Status) String() string

func (Status) Type

func (Status) Type() protoreflect.EnumType

type UnimplementedAgentConfigServiceServer

type UnimplementedAgentConfigServiceServer struct {
}

UnimplementedAgentConfigServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentConfigServiceServer) AgentModuleUpdateStream

func (UnimplementedAgentConfigServiceServer) GetAgentConfig

type UnimplementedAgentGroupServiceServer

type UnimplementedAgentGroupServiceServer struct {
}

UnimplementedAgentGroupServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentGroupServiceServer) CreateGroup

func (UnimplementedAgentGroupServiceServer) DeleteGroup

func (UnimplementedAgentGroupServiceServer) EditGroup

func (UnimplementedAgentGroupServiceServer) ListGroups

type UnimplementedAgentMalwareServiceServer

type UnimplementedAgentMalwareServiceServer struct {
}

UnimplementedAgentMalwareServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentMalwareServiceServer) ChangeMalwareStatus

func (UnimplementedAgentMalwareServiceServer) CreateNewMalwareEntry

func (UnimplementedAgentMalwareServiceServer) GetAgentExclusions

func (UnimplementedAgentMalwareServiceServer) ListAgentMalware

func (UnimplementedAgentMalwareServiceServer) ListAgentMalwareHistory

type UnimplementedAgentServiceServer

type UnimplementedAgentServiceServer struct {
}

UnimplementedAgentServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentServiceServer) AgentStream

func (UnimplementedAgentServiceServer) DeleteAgent

func (UnimplementedAgentServiceServer) GetAgentByHostname

func (UnimplementedAgentServiceServer) ListAgentCommands

func (UnimplementedAgentServiceServer) ListAgents

func (UnimplementedAgentServiceServer) ListAgentsWithCommands

func (UnimplementedAgentServiceServer) RegisterAgent

func (UnimplementedAgentServiceServer) UpdateAgentGroup

func (UnimplementedAgentServiceServer) UpdateAgentType

type UnimplementedAgentTypeServiceServer

type UnimplementedAgentTypeServiceServer struct {
}

UnimplementedAgentTypeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentTypeServiceServer) ListAgentTypes

type UnimplementedCollectorServiceServer

type UnimplementedCollectorServiceServer struct {
}

UnimplementedCollectorServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCollectorServiceServer) CollectorStream

func (UnimplementedCollectorServiceServer) DeleteCollector

func (UnimplementedCollectorServiceServer) GetCollectorConfig

func (UnimplementedCollectorServiceServer) GetCollectorsByHostnameAndModule

func (UnimplementedCollectorServiceServer) ListCollector

func (UnimplementedCollectorServiceServer) ListCollectorHostnames

func (UnimplementedCollectorServiceServer) RegisterCollector

type UnimplementedPanelCollectorServiceServer

type UnimplementedPanelCollectorServiceServer struct {
}

UnimplementedPanelCollectorServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPanelCollectorServiceServer) RegisterCollectorConfig

type UnimplementedPanelServiceServer

type UnimplementedPanelServiceServer struct {
}

UnimplementedPanelServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPanelServiceServer) ProcessCommand

type UnimplementedPingServiceServer

type UnimplementedPingServiceServer struct {
}

UnimplementedPingServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPingServiceServer) Ping

type UnsafeAgentConfigServiceServer

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

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

type UnsafeAgentGroupServiceServer

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

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

type UnsafeAgentMalwareServiceServer

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

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

type UnsafeAgentServiceServer

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

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

type UnsafeAgentTypeServiceServer

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

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

type UnsafeCollectorServiceServer

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

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

type UnsafePanelCollectorServiceServer

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

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

type UnsafePanelServiceServer

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

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

type UnsafePingServiceServer

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

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

type UpdateAgentModule

type UpdateAgentModule struct {
	AgentModuleShort string `protobuf:"bytes,1,opt,name=agent_module_short,json=agentModuleShort,proto3" json:"agent_module_short,omitempty"`
	ConfKey          string `protobuf:"bytes,4,opt,name=conf_key,json=confKey,proto3" json:"conf_key,omitempty"`
	ConfValue        string `protobuf:"bytes,5,opt,name=conf_value,json=confValue,proto3" json:"conf_value,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateAgentModule) Descriptor deprecated

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

Deprecated: Use UpdateAgentModule.ProtoReflect.Descriptor instead.

func (*UpdateAgentModule) GetAgentModuleShort

func (x *UpdateAgentModule) GetAgentModuleShort() string

func (*UpdateAgentModule) GetConfKey

func (x *UpdateAgentModule) GetConfKey() string

func (*UpdateAgentModule) GetConfValue

func (x *UpdateAgentModule) GetConfValue() string

func (*UpdateAgentModule) ProtoMessage

func (*UpdateAgentModule) ProtoMessage()

func (*UpdateAgentModule) ProtoReflect

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

func (*UpdateAgentModule) Reset

func (x *UpdateAgentModule) Reset()

func (*UpdateAgentModule) String

func (x *UpdateAgentModule) String() string

type UpdateConfigResponse

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

func (*UpdateConfigResponse) Descriptor deprecated

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

Deprecated: Use UpdateConfigResponse.ProtoReflect.Descriptor instead.

func (*UpdateConfigResponse) GetAccepted

func (x *UpdateConfigResponse) GetAccepted() string

func (*UpdateConfigResponse) ProtoMessage

func (*UpdateConfigResponse) ProtoMessage()

func (*UpdateConfigResponse) ProtoReflect

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

func (*UpdateConfigResponse) Reset

func (x *UpdateConfigResponse) Reset()

func (*UpdateConfigResponse) String

func (x *UpdateConfigResponse) String() string

type UtmCommand

type UtmCommand struct {
	AgentKey   string `protobuf:"bytes,1,opt,name=agent_key,json=agentKey,proto3" json:"agent_key,omitempty"`
	Command    string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	ExecutedBy string `protobuf:"bytes,3,opt,name=executed_by,json=executedBy,proto3" json:"executed_by,omitempty"`
	CmdId      string `protobuf:"bytes,4,opt,name=cmd_id,json=cmdId,proto3" json:"cmd_id,omitempty"`
	OriginType string `protobuf:"bytes,5,opt,name=origin_type,json=originType,proto3" json:"origin_type,omitempty"`
	OriginId   string `protobuf:"bytes,6,opt,name=origin_id,json=originId,proto3" json:"origin_id,omitempty"`
	Reason     string `protobuf:"bytes,7,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*UtmCommand) Descriptor deprecated

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

Deprecated: Use UtmCommand.ProtoReflect.Descriptor instead.

func (*UtmCommand) GetAgentKey

func (x *UtmCommand) GetAgentKey() string

func (*UtmCommand) GetCmdId

func (x *UtmCommand) GetCmdId() string

func (*UtmCommand) GetCommand

func (x *UtmCommand) GetCommand() string

func (*UtmCommand) GetExecutedBy

func (x *UtmCommand) GetExecutedBy() string

func (*UtmCommand) GetOriginId

func (x *UtmCommand) GetOriginId() string

func (*UtmCommand) GetOriginType

func (x *UtmCommand) GetOriginType() string

func (*UtmCommand) GetReason

func (x *UtmCommand) GetReason() string

func (*UtmCommand) ProtoMessage

func (*UtmCommand) ProtoMessage()

func (*UtmCommand) ProtoReflect

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

func (*UtmCommand) Reset

func (x *UtmCommand) Reset()

func (*UtmCommand) String

func (x *UtmCommand) String() string

Jump to

Keyboard shortcuts

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