proto

type AccountLimits struct {
	MaxConnections       int64 `protobuf:"varint,1,opt,name=max_connections,json=maxConnections,proto3" json:"max_connections,omitempty"`                     // Maximum concurrent connections (0 = unlimited)
	MaxSubscriptions     int64 `protobuf:"varint,2,opt,name=max_subscriptions,json=maxSubscriptions,proto3" json:"max_subscriptions,omitempty"`               // Maximum subscriptions per connection (0 = unlimited)
	MaxPayloadBytes      int64 `protobuf:"varint,3,opt,name=max_payload_bytes,json=maxPayloadBytes,proto3" json:"max_payload_bytes,omitempty"`                // Maximum message payload size in bytes (0 = default 1MB)
	MaxDataBytes         int64 `protobuf:"varint,4,opt,name=max_data_bytes,json=maxDataBytes,proto3" json:"max_data_bytes,omitempty"`                         // Maximum data throughput in bytes/sec (0 = unlimited)
	MaxExports           int64 `protobuf:"varint,5,opt,name=max_exports,json=maxExports,proto3" json:"max_exports,omitempty"`                                 // Maximum number of exports (0 = unlimited)
	MaxImports           int64 `protobuf:"varint,6,opt,name=max_imports,json=maxImports,proto3" json:"max_imports,omitempty"`                                 // Maximum number of imports (0 = unlimited)
	AllowWildcardExports bool  `protobuf:"varint,7,opt,name=allow_wildcard_exports,json=allowWildcardExports,proto3" json:"allow_wildcard_exports,omitempty"` // Whether wildcard exports are allowed
	// contains filtered or unexported fields
}

type AgentCheckConfig struct {
	CheckId     string `protobuf:"bytes,1,opt,name=check_id,json=checkId,proto3" json:"check_id,omitempty"`              // Unique check identifier
	CheckType   string `protobuf:"bytes,2,opt,name=check_type,json=checkType,proto3" json:"check_type,omitempty"`        // Type: "icmp", "tcp", "http", "grpc", "process", "sweep"
	Name        string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`                                   // Human-readable name
	Enabled     bool   `protobuf:"varint,4,opt,name=enabled,proto3" json:"enabled,omitempty"`                            // Whether check is active
	IntervalSec int32  `protobuf:"varint,5,opt,name=interval_sec,json=intervalSec,proto3" json:"interval_sec,omitempty"` // Check interval in seconds
	TimeoutSec  int32  `protobuf:"varint,6,opt,name=timeout_sec,json=timeoutSec,proto3" json:"timeout_sec,omitempty"`    // Check timeout in seconds
	// Target configuration (interpretation depends on check_type)
	Target string `protobuf:"bytes,7,opt,name=target,proto3" json:"target,omitempty"`  // Target host/IP/URL
	Port   int32  `protobuf:"varint,8,opt,name=port,proto3" json:"port,omitempty"`     // Target port (for tcp, http, grpc)
	Path   string `protobuf:"bytes,9,opt,name=path,proto3" json:"path,omitempty"`      // Path (for http checks)
	Method string `protobuf:"bytes,10,opt,name=method,proto3" json:"method,omitempty"` // HTTP method (for http checks)
	// Additional settings as key-value pairs
	Settings map[string]string `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

type AgentConfigRequest struct {
	AgentId       string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`                   // Agent requesting config
	ConfigVersion string `protobuf:"bytes,2,opt,name=config_version,json=configVersion,proto3" json:"config_version,omitempty"` // Current config version hash (for cache validation)
	// contains filtered or unexported fields
}

type AgentConfigResponse struct {
	NotModified     bool   `protobuf:"varint,1,opt,name=not_modified,json=notModified,proto3" json:"not_modified,omitempty"`             // True if config_version matches current; config fields empty
	ConfigVersion   string `protobuf:"bytes,2,opt,name=config_version,json=configVersion,proto3" json:"config_version,omitempty"`        // New config version hash
	ConfigTimestamp int64  `protobuf:"varint,3,opt,name=config_timestamp,json=configTimestamp,proto3" json:"config_timestamp,omitempty"` // When config was last updated (unix timestamp)
	// Agent settings
	HeartbeatIntervalSec  int32 `protobuf:"varint,4,opt,name=heartbeat_interval_sec,json=heartbeatIntervalSec,proto3" json:"heartbeat_interval_sec,omitempty"` // How often to push status (seconds)
	ConfigPollIntervalSec int32 ``                                                                                                                             // How often to check for config updates (seconds)
	/* 129-byte string literal not displayed */
	// Checks to perform
	Checks []*AgentCheckConfig `protobuf:"bytes,6,rep,name=checks,proto3" json:"checks,omitempty"`
	// Optional: raw JSON config for extensibility
	ConfigJson []byte `protobuf:"bytes,7,opt,name=config_json,json=configJson,proto3" json:"config_json,omitempty"`
	// Sysmon configuration for embedded system monitoring
	SysmonConfig *SysmonConfig `protobuf:"bytes,8,opt,name=sysmon_config,json=sysmonConfig,proto3" json:"sysmon_config,omitempty"`
	// SNMP configuration for embedded SNMP monitoring
	SnmpConfig *SNMPConfig `protobuf:"bytes,9,opt,name=snmp_config,json=snmpConfig,proto3" json:"snmp_config,omitempty"`
	// Wasm plugin configuration assignments
	PluginConfig *PluginConfig `protobuf:"bytes,11,opt,name=plugin_config,json=pluginConfig,proto3" json:"plugin_config,omitempty"`
	// contains filtered or unexported fields
}

type AgentGatewayServiceClient interface {
	// Hello is called by the agent on startup to announce itself and enroll.
	// The gateway validates the mTLS certificate and registers the agent.
	Hello(ctx context.Context, in *AgentHelloRequest, opts ...grpc.CallOption) (*AgentHelloResponse, error)
	// GetConfig is called by the agent to fetch its configuration.
	// Supports versioning - returns not_modified if config hasn't changed.
	GetConfig(ctx context.Context, in *AgentConfigRequest, opts ...grpc.CallOption) (*AgentConfigResponse, error)
	// PushStatus sends a batch of service statuses from the agent to the gateway.
	PushStatus(ctx context.Context, in *GatewayStatusRequest, opts ...grpc.CallOption) (*GatewayStatusResponse, error)
	// StreamStatus streams service status chunks for large payloads.
	StreamStatus(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[GatewayStatusChunk, GatewayStatusResponse], error)
	// ControlStream establishes a bidirectional control channel for commands and push-config.
	ControlStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ControlStreamRequest, ControlStreamResponse], error)
}

type AgentGatewayServiceServer interface {
	// Hello is called by the agent on startup to announce itself and enroll.
	// The gateway validates the mTLS certificate and registers the agent.
	Hello(context.Context, *AgentHelloRequest) (*AgentHelloResponse, error)
	// GetConfig is called by the agent to fetch its configuration.
	// Supports versioning - returns not_modified if config hasn't changed.
	GetConfig(context.Context, *AgentConfigRequest) (*AgentConfigResponse, error)
	// PushStatus sends a batch of service statuses from the agent to the gateway.
	PushStatus(context.Context, *GatewayStatusRequest) (*GatewayStatusResponse, error)
	// StreamStatus streams service status chunks for large payloads.
	StreamStatus(grpc.ClientStreamingServer[GatewayStatusChunk, GatewayStatusResponse]) error
	// ControlStream establishes a bidirectional control channel for commands and push-config.
	ControlStream(grpc.BidiStreamingServer[ControlStreamRequest, ControlStreamResponse]) error
	// contains filtered or unexported methods
}

type AgentGatewayService_ControlStreamClient = grpc.BidiStreamingClient[ControlStreamRequest, ControlStreamResponse]

type AgentGatewayService_ControlStreamServer = grpc.BidiStreamingServer[ControlStreamRequest, ControlStreamResponse]

type AgentGatewayService_StreamStatusClient = grpc.ClientStreamingClient[GatewayStatusChunk, GatewayStatusResponse]

type AgentGatewayService_StreamStatusServer = grpc.ClientStreamingServer[GatewayStatusChunk, GatewayStatusResponse]

type AgentHelloRequest struct {
	AgentId       string            `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`                   // Unique agent identifier (from bootstrap config)
	Version       string            `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`                                  // Agent software version (e.g., "1.2.3")
	Capabilities  []string          `protobuf:"bytes,3,rep,name=capabilities,proto3" json:"capabilities,omitempty"`                        // Agent capabilities (e.g., ["icmp", "tcp", "http", "sweep"])
	Hostname      string            `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"`                                // Host machine name
	Os            string            `protobuf:"bytes,5,opt,name=os,proto3" json:"os,omitempty"`                                            // Operating system (e.g., "linux", "darwin", "windows")
	Arch          string            `protobuf:"bytes,6,opt,name=arch,proto3" json:"arch,omitempty"`                                        // Architecture (e.g., "amd64", "arm64")
	Partition     string            `protobuf:"bytes,7,opt,name=partition,proto3" json:"partition,omitempty"`                              // Partition/site identifier
	ConfigVersion string            `protobuf:"bytes,8,opt,name=config_version,json=configVersion,proto3" json:"config_version,omitempty"` // Current config version hash (for config sync)
	Labels        map[string]string ``                                                                                                     // Optional labels/tags for grouping
	/* 139-byte string literal not displayed */
	ConfigSource string `protobuf:"bytes,10,opt,name=config_source,json=configSource,proto3" json:"config_source,omitempty"` // Source of sysmon config: "remote", "local", "cached", "default"
	// contains filtered or unexported fields
}

type AgentHelloResponse struct {
	Accepted             bool   `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`                                                       // Whether the agent was accepted
	AgentId              string `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`                                           // Confirmed agent ID (may be assigned if not provided)
	Message              string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`                                                          // Human-readable status message
	GatewayId            string `protobuf:"bytes,4,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"`                                     // Gateway that accepted the connection
	ServerTime           int64  `protobuf:"varint,5,opt,name=server_time,json=serverTime,proto3" json:"server_time,omitempty"`                                 // Server timestamp (for clock sync)
	HeartbeatIntervalSec int32  `protobuf:"varint,6,opt,name=heartbeat_interval_sec,json=heartbeatIntervalSec,proto3" json:"heartbeat_interval_sec,omitempty"` // Recommended status push interval in seconds
	ConfigOutdated       bool   `protobuf:"varint,7,opt,name=config_outdated,json=configOutdated,proto3" json:"config_outdated,omitempty"`                     // True if agent should fetch new config
	// contains filtered or unexported fields
}

type AgentServiceClient interface {
	GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	GetResults(ctx context.Context, in *ResultsRequest, opts ...grpc.CallOption) (*ResultsResponse, error)
	StreamResults(ctx context.Context, in *ResultsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ResultsChunk], error)
}

type AgentServiceServer interface {
	GetStatus(context.Context, *StatusRequest) (*StatusResponse, error)
	GetResults(context.Context, *ResultsRequest) (*ResultsResponse, error)
	StreamResults(*ResultsRequest, grpc.ServerStreamingServer[ResultsChunk]) error
	// contains filtered or unexported methods
}

type AgentService_StreamResultsClient = grpc.ServerStreamingClient[ResultsChunk]

type AgentService_StreamResultsServer = grpc.ServerStreamingServer[ResultsChunk]

type BatchGetEntry struct {
	Key      string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value    []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Found    bool   `protobuf:"varint,3,opt,name=found,proto3" json:"found,omitempty"`
	Revision uint64 `protobuf:"varint,4,opt,name=revision,proto3" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

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

type BatchGetResponse struct {
	Results []*BatchGetEntry `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

type BootstrapOperatorRequest struct {
	OperatorName          string `protobuf:"bytes,1,opt,name=operator_name,json=operatorName,proto3" json:"operator_name,omitempty"`                           // Name for the operator (e.g., "serviceradar")
	ExistingOperatorSeed  string `protobuf:"bytes,2,opt,name=existing_operator_seed,json=existingOperatorSeed,proto3" json:"existing_operator_seed,omitempty"` // Optional: import existing seed instead of generating
	GenerateSystemAccount bool   ``                                                                                                                            // Whether to generate the system account
	/* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

type BootstrapOperatorResponse struct {
	OperatorPublicKey      string `protobuf:"bytes,1,opt,name=operator_public_key,json=operatorPublicKey,proto3" json:"operator_public_key,omitempty"` // The operator's public NKey (starts with 'O')
	OperatorSeed           string `protobuf:"bytes,2,opt,name=operator_seed,json=operatorSeed,proto3" json:"operator_seed,omitempty"`                  // The operator's private seed - only if newly generated
	OperatorJwt            string `protobuf:"bytes,3,opt,name=operator_jwt,json=operatorJwt,proto3" json:"operator_jwt,omitempty"`                     // The signed operator JWT
	SystemAccountPublicKey string ``                                                                                                                   // System account public key (if generated)
	/* 131-byte string literal not displayed */
	SystemAccountSeed string `protobuf:"bytes,5,opt,name=system_account_seed,json=systemAccountSeed,proto3" json:"system_account_seed,omitempty"` // System account seed - only if newly generated
	SystemAccountJwt  string `protobuf:"bytes,6,opt,name=system_account_jwt,json=systemAccountJwt,proto3" json:"system_account_jwt,omitempty"`    // Signed system account JWT (if generated)
	// contains filtered or unexported fields
}

type CommandAck struct {
	CommandId   string `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`       // Command identifier
	CommandType string `protobuf:"bytes,2,opt,name=command_type,json=commandType,proto3" json:"command_type,omitempty"` // Command type
	Timestamp   int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                       // Ack time (unix seconds)
	Message     string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`                            // Optional message
	// contains filtered or unexported fields
}

type CommandProgress struct {
	CommandId       string `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`                    // Command identifier
	CommandType     string `protobuf:"bytes,2,opt,name=command_type,json=commandType,proto3" json:"command_type,omitempty"`              // Command type
	ProgressPercent int32  `protobuf:"varint,3,opt,name=progress_percent,json=progressPercent,proto3" json:"progress_percent,omitempty"` // Progress percentage (0-100)
	Message         string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`                                         // Optional progress message
	Timestamp       int64  `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                                    // Progress time (unix seconds)
	// contains filtered or unexported fields
}

type CommandRequest struct {
	CommandId   string `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`       // Unique command identifier (UUID)
	CommandType string `protobuf:"bytes,2,opt,name=command_type,json=commandType,proto3" json:"command_type,omitempty"` // Command type (e.g., "mapper.run_job")
	PayloadJson []byte `protobuf:"bytes,3,opt,name=payload_json,json=payloadJson,proto3" json:"payload_json,omitempty"` // Command payload as JSON
	TtlSeconds  int64  `protobuf:"varint,4,opt,name=ttl_seconds,json=ttlSeconds,proto3" json:"ttl_seconds,omitempty"`   // Time-to-live in seconds
	CreatedAt   int64  `protobuf:"varint,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`      // Command creation time (unix seconds)
	// contains filtered or unexported fields
}

type CommandResult struct {
	CommandId   string `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`       // Command identifier
	CommandType string `protobuf:"bytes,2,opt,name=command_type,json=commandType,proto3" json:"command_type,omitempty"` // Command type
	Success     bool   `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"`                           // Whether the command succeeded
	Message     string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`                            // Result message or error
	PayloadJson []byte `protobuf:"bytes,5,opt,name=payload_json,json=payloadJson,proto3" json:"payload_json,omitempty"` // Optional result payload as JSON
	Timestamp   int64  `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                       // Completion time (unix seconds)
	// contains filtered or unexported fields
}

type ConfigAck struct {
	ConfigVersion string `protobuf:"bytes,1,opt,name=config_version,json=configVersion,proto3" json:"config_version,omitempty"` // Applied config version
	Timestamp     int64  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                             // Ack time (unix seconds)
	// contains filtered or unexported fields
}

type ControlStreamHello struct {
	AgentId       string   `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`                   // Unique agent identifier
	Partition     string   `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`                              // Partition/site identifier
	Capabilities  []string `protobuf:"bytes,3,rep,name=capabilities,proto3" json:"capabilities,omitempty"`                        // Agent capabilities (e.g., ["mapper", "sweep"])
	ConfigVersion string   `protobuf:"bytes,4,opt,name=config_version,json=configVersion,proto3" json:"config_version,omitempty"` // Current config version hash
	// contains filtered or unexported fields
}

type ControlStreamRequest struct {

	// Types that are valid to be assigned to Payload:
	//
	//	*ControlStreamRequest_Hello
	//	*ControlStreamRequest_CommandAck
	//	*ControlStreamRequest_CommandProgress
	//	*ControlStreamRequest_CommandResult
	//	*ControlStreamRequest_ConfigAck
	Payload isControlStreamRequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

type ControlStreamRequest_CommandAck struct {
	CommandAck *CommandAck `protobuf:"bytes,2,opt,name=command_ack,json=commandAck,proto3,oneof"`
}

type ControlStreamRequest_CommandProgress struct {
	CommandProgress *CommandProgress `protobuf:"bytes,3,opt,name=command_progress,json=commandProgress,proto3,oneof"`
}

type ControlStreamRequest_CommandResult struct {
	CommandResult *CommandResult `protobuf:"bytes,4,opt,name=command_result,json=commandResult,proto3,oneof"`
}

type ControlStreamRequest_ConfigAck struct {
	ConfigAck *ConfigAck `protobuf:"bytes,5,opt,name=config_ack,json=configAck,proto3,oneof"`
}

type ControlStreamRequest_Hello struct {
	Hello *ControlStreamHello `protobuf:"bytes,1,opt,name=hello,proto3,oneof"`
}

type ControlStreamResponse struct {

	// Types that are valid to be assigned to Payload:
	//
	//	*ControlStreamResponse_Command
	//	*ControlStreamResponse_Config
	Payload isControlStreamResponse_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

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

type ControlStreamResponse_Config struct {
	Config *AgentConfigResponse `protobuf:"bytes,2,opt,name=config,proto3,oneof"`
}

type CoreServiceClient interface {
	// GetCanonicalDevice resolves identities to canonical device records backed by the shared identity map.
	GetCanonicalDevice(ctx context.Context, in *GetCanonicalDeviceRequest, opts ...grpc.CallOption) (*GetCanonicalDeviceResponse, error)
	// RegisterTemplate allows services to register their default config templates on startup.
	RegisterTemplate(ctx context.Context, in *RegisterTemplateRequest, opts ...grpc.CallOption) (*RegisterTemplateResponse, error)
	// GetTemplate retrieves a registered template for admin seeding operations.
	GetTemplate(ctx context.Context, in *GetTemplateRequest, opts ...grpc.CallOption) (*GetTemplateResponse, error)
	// ListTemplates returns metadata about all registered templates.
	ListTemplates(ctx context.Context, in *ListTemplatesRequest, opts ...grpc.CallOption) (*ListTemplatesResponse, error)
}

type CoreServiceServer interface {
	// GetCanonicalDevice resolves identities to canonical device records backed by the shared identity map.
	GetCanonicalDevice(context.Context, *GetCanonicalDeviceRequest) (*GetCanonicalDeviceResponse, error)
	// RegisterTemplate allows services to register their default config templates on startup.
	RegisterTemplate(context.Context, *RegisterTemplateRequest) (*RegisterTemplateResponse, error)
	// GetTemplate retrieves a registered template for admin seeding operations.
	GetTemplate(context.Context, *GetTemplateRequest) (*GetTemplateResponse, error)
	// ListTemplates returns metadata about all registered templates.
	ListTemplates(context.Context, *ListTemplatesRequest) (*ListTemplatesResponse, error)
	// contains filtered or unexported methods
}

type CreateAccountRequest struct {
	AccountName     string            `protobuf:"bytes,1,opt,name=account_name,json=accountName,proto3" json:"account_name,omitempty"`             // Unique account identifier (e.g., "acme-corp")
	Limits          *AccountLimits    `protobuf:"bytes,2,opt,name=limits,proto3" json:"limits,omitempty"`                                          // Optional resource limits
	SubjectMappings []*SubjectMapping `protobuf:"bytes,3,rep,name=subject_mappings,json=subjectMappings,proto3" json:"subject_mappings,omitempty"` // Optional custom subject mappings
	Exports         []*StreamExport   `protobuf:"bytes,4,rep,name=exports,proto3" json:"exports,omitempty"`                                        // Optional stream exports (defaults applied server-side)
	// contains filtered or unexported fields
}

type CreateAccountResponse struct {
	AccountPublicKey string `protobuf:"bytes,1,opt,name=account_public_key,json=accountPublicKey,proto3" json:"account_public_key,omitempty"` // The account's public NKey (starts with 'A')
	AccountSeed      string `protobuf:"bytes,2,opt,name=account_seed,json=accountSeed,proto3" json:"account_seed,omitempty"`                  // The account's private seed (starts with 'SA') - STORE ENCRYPTED
	AccountJwt       string `protobuf:"bytes,3,opt,name=account_jwt,json=accountJwt,proto3" json:"account_jwt,omitempty"`                     // The signed account JWT
	// contains filtered or unexported fields
}

type DataServiceClient interface {
	// UploadObject streams an object payload into the JetStream object store.
	UploadObject(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[ObjectUploadChunk, UploadObjectResponse], error)
	// DownloadObject streams the contents of an object from the JetStream object store.
	DownloadObject(ctx context.Context, in *DownloadObjectRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ObjectDownloadChunk], error)
	// DeleteObject removes an object from the JetStream object store.
	DeleteObject(ctx context.Context, in *DeleteObjectRequest, opts ...grpc.CallOption) (*DeleteObjectResponse, error)
	// GetObjectInfo retrieves metadata for an object without returning its payload.
	GetObjectInfo(ctx context.Context, in *GetObjectInfoRequest, opts ...grpc.CallOption) (*GetObjectInfoResponse, error)
}

type DataServiceServer interface {
	// UploadObject streams an object payload into the JetStream object store.
	UploadObject(grpc.ClientStreamingServer[ObjectUploadChunk, UploadObjectResponse]) error
	// DownloadObject streams the contents of an object from the JetStream object store.
	DownloadObject(*DownloadObjectRequest, grpc.ServerStreamingServer[ObjectDownloadChunk]) error
	// DeleteObject removes an object from the JetStream object store.
	DeleteObject(context.Context, *DeleteObjectRequest) (*DeleteObjectResponse, error)
	// GetObjectInfo retrieves metadata for an object without returning its payload.
	GetObjectInfo(context.Context, *GetObjectInfoRequest) (*GetObjectInfoResponse, error)
	// contains filtered or unexported methods
}

type DataService_DownloadObjectClient = grpc.ServerStreamingClient[ObjectDownloadChunk]

type DataService_DownloadObjectServer = grpc.ServerStreamingServer[ObjectDownloadChunk]

type DataService_UploadObjectClient = grpc.ClientStreamingClient[ObjectUploadChunk, UploadObjectResponse]

type DataService_UploadObjectServer = grpc.ClientStreamingServer[ObjectUploadChunk, UploadObjectResponse]

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

type DeleteObjectResponse struct {
	Deleted bool `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

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

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

type DeviceStatusRequest struct {
	AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"` // Unique identifier for the agent
	// contains filtered or unexported fields
}

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

type GatewayServiceStatus struct {
	ServiceName  string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	Available    bool   `protobuf:"varint,2,opt,name=available,proto3" json:"available,omitempty"`
	Message      []byte `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	ServiceType  string `protobuf:"bytes,4,opt,name=service_type,json=serviceType,proto3" json:"service_type,omitempty"`
	ResponseTime int64  `protobuf:"varint,5,opt,name=response_time,json=responseTime,proto3" json:"response_time,omitempty"`
	AgentId      string `protobuf:"bytes,6,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`          // Agent ID for traceability
	GatewayId    string `protobuf:"bytes,7,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"`    // Gateway ID for traceability
	Partition    string `protobuf:"bytes,8,opt,name=partition,proto3" json:"partition,omitempty"`                     // Partition identifier
	Source       string `protobuf:"bytes,9,opt,name=source,proto3" json:"source,omitempty"`                           // Source of the message: "status" or "results"
	KvStoreId    string `protobuf:"bytes,10,opt,name=kv_store_id,json=kvStoreId,proto3" json:"kv_store_id,omitempty"` // KV store identifier this service is using
	// contains filtered or unexported fields
}

type GatewayStatusChunk struct {
	Services     []*GatewayServiceStatus `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	GatewayId    string                  `protobuf:"bytes,2,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"`
	AgentId      string                  `protobuf:"bytes,3,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Timestamp    int64                   `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Partition    string                  `protobuf:"bytes,5,opt,name=partition,proto3" json:"partition,omitempty"`
	SourceIp     string                  `protobuf:"bytes,6,opt,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`
	IsFinal      bool                    `protobuf:"varint,7,opt,name=is_final,json=isFinal,proto3" json:"is_final,omitempty"`                // Whether this is the last chunk
	ChunkIndex   int32                   `protobuf:"varint,8,opt,name=chunk_index,json=chunkIndex,proto3" json:"chunk_index,omitempty"`       // Order of this chunk
	TotalChunks  int32                   `protobuf:"varint,9,opt,name=total_chunks,json=totalChunks,proto3" json:"total_chunks,omitempty"`    // Total number of chunks
	KvStoreId    string                  `protobuf:"bytes,10,opt,name=kv_store_id,json=kvStoreId,proto3" json:"kv_store_id,omitempty"`        // KV store identifier this agent is using
	ConfigSource string                  `protobuf:"bytes,13,opt,name=config_source,json=configSource,proto3" json:"config_source,omitempty"` // Source of sysmon config: "remote", "local", "cached", "default"
	// contains filtered or unexported fields
}

type GatewayStatusRequest struct {
	Services     []*GatewayServiceStatus `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	GatewayId    string                  `protobuf:"bytes,2,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"` // Gateway receiving this status
	AgentId      string                  `protobuf:"bytes,3,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`       // Agent sending this status
	Timestamp    int64                   `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Partition    string                  `protobuf:"bytes,5,opt,name=partition,proto3" json:"partition,omitempty"`                            // Partition identifier
	SourceIp     string                  `protobuf:"bytes,6,opt,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`              // Host IP where agent is running
	KvStoreId    string                  `protobuf:"bytes,7,opt,name=kv_store_id,json=kvStoreId,proto3" json:"kv_store_id,omitempty"`         // KV store identifier this agent is using
	ConfigSource string                  `protobuf:"bytes,10,opt,name=config_source,json=configSource,proto3" json:"config_source,omitempty"` // Source of sysmon config: "remote", "local", "cached", "default"
	// contains filtered or unexported fields
}

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