proto

type AgentServiceClient interface {
	// ReceiveKeyRequests provides a persistent stream of key generation requests from server to agent
	ReceiveKeyRequests(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[KeyGenerationRequest], error)
	// SubmitPublicKeys allows agents to submit public keys for certificate generation
	SubmitPublicKeys(ctx context.Context, in *PublicKeysRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// SubmitHealthReport allows agents to send periodic health reports via persistent stream
	SubmitHealthReport(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[HealthReportRequest, emptypb.Empty], error)
	// ReceiveFiles provides a persistent stream of files from server to agent (certificates, secrets, config updates)
	ReceiveFiles(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[FileTransfer], error)
}

type AgentServiceServer interface {
	// ReceiveKeyRequests provides a persistent stream of key generation requests from server to agent
	ReceiveKeyRequests(*emptypb.Empty, grpc.ServerStreamingServer[KeyGenerationRequest]) error
	// SubmitPublicKeys allows agents to submit public keys for certificate generation
	SubmitPublicKeys(context.Context, *PublicKeysRequest) (*emptypb.Empty, error)
	// SubmitHealthReport allows agents to send periodic health reports via persistent stream
	SubmitHealthReport(grpc.ClientStreamingServer[HealthReportRequest, emptypb.Empty]) error
	// ReceiveFiles provides a persistent stream of files from server to agent (certificates, secrets, config updates)
	ReceiveFiles(*emptypb.Empty, grpc.ServerStreamingServer[FileTransfer]) error
	// contains filtered or unexported methods
}

type AgentService_ReceiveFilesClient = grpc.ServerStreamingClient[FileTransfer]

type AgentService_ReceiveFilesServer = grpc.ServerStreamingServer[FileTransfer]

type AgentService_ReceiveKeyRequestsClient = grpc.ServerStreamingClient[KeyGenerationRequest]

type AgentService_ReceiveKeyRequestsServer = grpc.ServerStreamingServer[KeyGenerationRequest]

type AgentService_SubmitHealthReportClient = grpc.ClientStreamingClient[HealthReportRequest, emptypb.Empty]

type AgentService_SubmitHealthReportServer = grpc.ClientStreamingServer[HealthReportRequest, emptypb.Empty]

type ConfigStatusResponse struct {
	Etag         string                 `protobuf:"bytes,1,opt,name=etag,proto3" json:"etag,omitempty"`
	LastModified *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"`
	Size         int64                  `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

type CreateInstanceRequest struct {
	InstanceId string          `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // If empty, server generates one
	Config     *InstanceConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type CreateInstanceResponse struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // Generated or confirmed instance ID
	Status     string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`                           // Current instance status
	// contains filtered or unexported fields
}

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

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

type DeleteInstanceResponse struct {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` // "deleting", "deleted", "unknown"
	// contains filtered or unexported fields
}

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

type ErrorEvent struct {
	Group      string                 `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`                             // Affected group (optional)
	InstanceId string                 `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // Affected instance (optional)
	Error      string                 `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`                             // Error message
	Timestamp  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                     // When the error occurred
	// contains filtered or unexported fields
}

type FileStatus struct {

	// Types that are valid to be assigned to Status:
	//
	//	*FileStatus_LastModified
	//	*FileStatus_Error
	Status isFileStatus_Status `protobuf_oneof:"status"`
	// contains filtered or unexported fields
}

type FileStatus_Error struct {
	Error string `protobuf:"bytes,2,opt,name=error,proto3,oneof"` // Error accessing file
}

type FileStatus_LastModified struct {
	LastModified *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=last_modified,json=lastModified,proto3,oneof"` // File exists and last modified time
}

type FileTransfer struct {
	Filename     string                 `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	Content      []byte                 `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	LastModified *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"`
	ConfigHash   string                 `protobuf:"bytes,4,opt,name=config_hash,json=configHash,proto3" json:"config_hash,omitempty"` // Optional: updated runtime config hash to write to identity/config.hash
	// contains filtered or unexported fields
}

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

type GroupConfig struct {
	Template     string            `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	Size         int32             `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	InstanceType string            `protobuf:"bytes,3,opt,name=instance_type,json=instanceType,proto3" json:"instance_type,omitempty"`
	SubnetPool   string            `protobuf:"bytes,4,opt,name=subnet_pool,json=subnetPool,proto3" json:"subnet_pool,omitempty"` // Logical subnet pool ID (references server.subnet_pools map key)
	Vars         map[string]string ``                                                                                            /* 135-byte string literal not displayed */
	Args         map[string]string ``                                                                                            // Group-level overrides
	/* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

type GroupEvent struct {
	Type  GroupEvent_Type `protobuf:"varint,1,opt,name=type,proto3,enum=nstance.v1.GroupEvent_Type" json:"type,omitempty"`
	Group *GroupStatus    `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"` // For UPSERT: full group status. For DELETE: only key is set.
	// contains filtered or unexported fields
}

type GroupEvent_Type int32

type GroupStatus struct {
	Key          string            `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`                                       // Group name/key
	Tenant       string            `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"`                                 // Tenant identifier
	Template     string            `protobuf:"bytes,3,opt,name=template,proto3" json:"template,omitempty"`                             // Instance template used
	Size         int32             `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`                                    // Desired size
	InstanceType string            `protobuf:"bytes,5,opt,name=instance_type,json=instanceType,proto3" json:"instance_type,omitempty"` // Instance type (from template or override)
	SubnetPool   string            `protobuf:"bytes,6,opt,name=subnet_pool,json=subnetPool,proto3" json:"subnet_pool,omitempty"`       // Logical subnet pool ID for this group
	Vars         map[string]string ``                                                                                                  // Merged vars
	/* 135-byte string literal not displayed */
	IsStatic    bool     `protobuf:"varint,8,opt,name=is_static,json=isStatic,proto3" json:"is_static,omitempty"`          // Whether group is defined in static config
	Etag        string   `protobuf:"bytes,9,opt,name=etag,proto3" json:"etag,omitempty"`                                   // Hash of this group's merged config for change detection
	ActualSize  int32    `protobuf:"varint,10,opt,name=actual_size,json=actualSize,proto3" json:"actual_size,omitempty"`   // Number of currently running instances
	ProviderIds []string `protobuf:"bytes,11,rep,name=provider_ids,json=providerIds,proto3" json:"provider_ids,omitempty"` // Provider IDs of running instances (sorted)
	// contains filtered or unexported fields
}

type HealthReportRequest struct {
	Version        string                 `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // Agent version
	InstanceId     string                 `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Timestamp      *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Count          int64                  `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`                                         // Health report sequence number
	Started        *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=started,proto3" json:"started,omitempty"`                                      // When metrics collection started
	WindowStart    *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=window_start,json=windowStart,proto3" json:"window_start,omitempty"`           // Current metrics window start
	WindowEnd      *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=window_end,json=windowEnd,proto3" json:"window_end,omitempty"`                 // Current metrics window end
	Uptime         string                 `protobuf:"bytes,8,opt,name=uptime,proto3" json:"uptime,omitempty"`                                        // Uptime duration string
	OneMinute      *Metrics               `protobuf:"bytes,9,opt,name=one_minute,json=oneMinute,proto3" json:"one_minute,omitempty"`                 // 1-minute averages
	FiveMinutes    *Metrics               `protobuf:"bytes,10,opt,name=five_minutes,json=fiveMinutes,proto3" json:"five_minutes,omitempty"`          // 5-minute averages
	FifteenMinutes *Metrics               `protobuf:"bytes,11,opt,name=fifteen_minutes,json=fifteenMinutes,proto3" json:"fifteen_minutes,omitempty"` // 15-minute averages
	Files          map[string]*FileStatus ``                                                                                                         // File status map
	/* 138-byte string literal not displayed */
	TerminationNotice *TerminationNotice `protobuf:"bytes,13,opt,name=termination_notice,json=terminationNotice,proto3" json:"termination_notice,omitempty"` // Optional termination notice for spot instances
	ConfigHash        string             `protobuf:"bytes,14,opt,name=config_hash,json=configHash,proto3" json:"config_hash,omitempty"`                      // Runtime config hash from /opt/nstance-agent/identity/config.hash
	// contains filtered or unexported fields
}

type InstanceConfig struct {
	Group        string            `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`                                   // Required group reference
	Template     string            `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`                             // Optional template override
	InstanceType string            `protobuf:"bytes,3,opt,name=instance_type,json=instanceType,proto3" json:"instance_type,omitempty"` // Optional instance type override
	SubnetPool   string            `protobuf:"bytes,4,opt,name=subnet_pool,json=subnetPool,proto3" json:"subnet_pool,omitempty"`       // Optional subnet pool override
	Vars         map[string]string ``                                                                                                  // Additional vars
	/* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

type InstanceEvent struct {
	InstanceId         string                 `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Tenant             string                 `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"`                                                     // Tenant identifier
	ProviderInstanceId string                 `protobuf:"bytes,3,opt,name=provider_instance_id,json=providerInstanceId,proto3" json:"provider_instance_id,omitempty"` // Provider's instance ID (e.g., i-1234567890abcdef0) for node mapping
	Group              string                 `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"`
	Status             string                 `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`                              // "pending_deletion", "deleting", "deleted"
	Reason             string                 `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`                              // Why instance is being deleted (e.g., "unhealthy")
	UnhealthyAt        *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=unhealthy_at,json=unhealthyAt,proto3" json:"unhealthy_at,omitempty"` // When instance was determined unhealthy
	DeleteAt           *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=delete_at,json=deleteAt,proto3" json:"delete_at,omitempty"`          // When instance will be deleted (drain_timeout from unhealthy_at)
	// contains filtered or unexported fields
}

type InstanceStatusResponse struct {
	InstanceId         string                 `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Tenant             string                 `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"` // Tenant identifier
	Status             string                 `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"` // "pending", "running", "terminating", "terminated", etc.
	CreatedAt          *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	LastSeen           *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	ProviderInstanceId string                 `protobuf:"bytes,6,opt,name=provider_instance_id,json=providerInstanceId,proto3" json:"provider_instance_id,omitempty"` // e.g., EC2 instance ID
	// contains filtered or unexported fields
}

type KeyGenerationRequest struct {
	KeyNames []string `protobuf:"bytes,1,rep,name=key_names,json=keyNames,proto3" json:"key_names,omitempty"`
	// contains filtered or unexported fields
}

type ListGroupsResponse struct {
	Groups []*GroupStatus `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

type Metrics struct {
	CpuUsage             float64   `protobuf:"fixed64,1,opt,name=cpu_usage,json=cpuUsage,proto3" json:"cpu_usage,omitempty"`                                       // CPU usage percentage
	CpuCoreUsage         []float64 `protobuf:"fixed64,2,rep,packed,name=cpu_core_usage,json=cpuCoreUsage,proto3" json:"cpu_core_usage,omitempty"`                  // Per-core CPU usage percentages
	MemoryUsage          float64   `protobuf:"fixed64,3,opt,name=memory_usage,json=memoryUsage,proto3" json:"memory_usage,omitempty"`                              // Memory usage percentage
	NetworkBytesSent     float64   `protobuf:"fixed64,4,opt,name=network_bytes_sent,json=networkBytesSent,proto3" json:"network_bytes_sent,omitempty"`             // Network bytes sent
	NetworkBytesReceived float64   `protobuf:"fixed64,5,opt,name=network_bytes_received,json=networkBytesReceived,proto3" json:"network_bytes_received,omitempty"` // Network bytes received
	DiskUsed             float64   `protobuf:"fixed64,6,opt,name=disk_used,json=diskUsed,proto3" json:"disk_used,omitempty"`                                       // Disk usage percentage
	DiskInodesUsed       float64   `protobuf:"fixed64,7,opt,name=disk_inodes_used,json=diskInodesUsed,proto3" json:"disk_inodes_used,omitempty"`                   // Disk inode usage percentage
	DiskBytesRead        float64   `protobuf:"fixed64,8,opt,name=disk_bytes_read,json=diskBytesRead,proto3" json:"disk_bytes_read,omitempty"`                      // Disk bytes read
	DiskBytesWritten     float64   `protobuf:"fixed64,9,opt,name=disk_bytes_written,json=diskBytesWritten,proto3" json:"disk_bytes_written,omitempty"`             // Disk bytes written
	// contains filtered or unexported fields
}

type OperatorServiceClient interface {
	// Certificate renewal
	RenewCertificate(ctx context.Context, in *RenewCertificateRequest, opts ...grpc.CallOption) (*RenewCertificateResponse, error)
	// GetConfigStatus returns current configuration metadata for per-shard config
	GetConfigStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ConfigStatusResponse, error)
	// RefreshConfig triggers server to reload configuration from S3
	RefreshConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RefreshConfigResponse, error)
	// Group management operations
	ListGroups(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListGroupsResponse, error)
	UpsertGroup(ctx context.Context, in *UpsertGroupRequest, opts ...grpc.CallOption) (*GroupStatus, error)
	DeleteGroup(ctx context.Context, in *DeleteGroupRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Instance management operations
	CreateInstance(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)
	DeleteInstance(ctx context.Context, in *DeleteInstanceRequest, opts ...grpc.CallOption) (*DeleteInstanceResponse, error)
	GetInstanceStatus(ctx context.Context, in *GetInstanceStatusRequest, opts ...grpc.CallOption) (*InstanceStatusResponse, error)
	AcknowledgeDrained(ctx context.Context, in *DrainAckRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Watch streams for operator sync
	WatchGroups(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GroupEvent], error)
	WatchInstances(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[InstanceEvent], error)
	WatchErrors(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ErrorEvent], error)
}

type OperatorServiceServer interface {
	// Certificate renewal
	RenewCertificate(context.Context, *RenewCertificateRequest) (*RenewCertificateResponse, error)
	// GetConfigStatus returns current configuration metadata for per-shard config
	GetConfigStatus(context.Context, *emptypb.Empty) (*ConfigStatusResponse, error)
	// RefreshConfig triggers server to reload configuration from S3
	RefreshConfig(context.Context, *emptypb.Empty) (*RefreshConfigResponse, error)
	// Group management operations
	ListGroups(context.Context, *emptypb.Empty) (*ListGroupsResponse, error)
	UpsertGroup(context.Context, *UpsertGroupRequest) (*GroupStatus, error)
	DeleteGroup(context.Context, *DeleteGroupRequest) (*emptypb.Empty, error)
	// Instance management operations
	CreateInstance(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)
	DeleteInstance(context.Context, *DeleteInstanceRequest) (*DeleteInstanceResponse, error)
	GetInstanceStatus(context.Context, *GetInstanceStatusRequest) (*InstanceStatusResponse, error)
	AcknowledgeDrained(context.Context, *DrainAckRequest) (*emptypb.Empty, error)
	// Watch streams for operator sync
	WatchGroups(*emptypb.Empty, grpc.ServerStreamingServer[GroupEvent]) error
	WatchInstances(*emptypb.Empty, grpc.ServerStreamingServer[InstanceEvent]) error
	WatchErrors(*emptypb.Empty, grpc.ServerStreamingServer[ErrorEvent]) error
	// contains filtered or unexported methods
}

type OperatorService_WatchErrorsClient = grpc.ServerStreamingClient[ErrorEvent]

type OperatorService_WatchErrorsServer = grpc.ServerStreamingServer[ErrorEvent]

type OperatorService_WatchGroupsClient = grpc.ServerStreamingClient[GroupEvent]

type OperatorService_WatchGroupsServer = grpc.ServerStreamingServer[GroupEvent]

type OperatorService_WatchInstancesClient = grpc.ServerStreamingClient[InstanceEvent]

type OperatorService_WatchInstancesServer = grpc.ServerStreamingServer[InstanceEvent]

type PublicKeySubmission struct {
	Filename     string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`                               // e.g., "kubelet.server"
	PublicKeyPem []byte `protobuf:"bytes,2,opt,name=public_key_pem,json=publicKeyPem,proto3" json:"public_key_pem,omitempty"` // PEM-encoded public key
	// contains filtered or unexported fields
}

type PublicKeysRequest struct {
	InstanceId string                 `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Keys       []*PublicKeySubmission `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

type RefreshConfigResponse struct {
	Updated  bool   `protobuf:"varint,1,opt,name=updated,proto3" json:"updated,omitempty"`                  // true if config was updated, false if unchanged
	PrevEtag string `protobuf:"bytes,2,opt,name=prev_etag,json=prevEtag,proto3" json:"prev_etag,omitempty"` // Config etag before refresh
	Etag     string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`                         // Config etag after refresh
	// contains filtered or unexported fields
}

type RegisterClientRequest struct {
	RegistrationNonceJwt string `protobuf:"bytes,1,opt,name=registration_nonce_jwt,json=registrationNonceJwt,proto3" json:"registration_nonce_jwt,omitempty"`
	PublicKeyPem         []byte `protobuf:"bytes,2,opt,name=public_key_pem,json=publicKeyPem,proto3" json:"public_key_pem,omitempty"` // PEM-encoded public key
	PrivateIpv4          string `protobuf:"bytes,3,opt,name=private_ipv4,json=privateIpv4,proto3" json:"private_ipv4,omitempty"`      // Agent-reported private IPv4
	PrivateIpv6          string `protobuf:"bytes,4,opt,name=private_ipv6,json=privateIpv6,proto3" json:"private_ipv6,omitempty"`      // Agent-reported private IPv6
	Hostname             string `protobuf:"bytes,5,opt,name=hostname,proto3" json:"hostname,omitempty"`                               // Agent-reported hostname
	// contains filtered or unexported fields
}

type RegisterClientResponse struct {
	ClientCertificatePem []byte                 `protobuf:"bytes,1,opt,name=client_certificate_pem,json=clientCertificatePem,proto3" json:"client_certificate_pem,omitempty"` // PEM-encoded client certificate
	ExpiresAt            *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

type RegistrationServiceClient interface {
	// RegisterAgent registers a new agent using a registration nonce JWT
	RegisterAgent(ctx context.Context, in *RegisterClientRequest, opts ...grpc.CallOption) (*RegisterClientResponse, error)
	// RegisterOperator registers a new operator using a registration nonce JWT
	RegisterOperator(ctx context.Context, in *RegisterClientRequest, opts ...grpc.CallOption) (*RegisterClientResponse, error)
}

type RegistrationServiceServer interface {
	// RegisterAgent registers a new agent using a registration nonce JWT
	RegisterAgent(context.Context, *RegisterClientRequest) (*RegisterClientResponse, error)
	// RegisterOperator registers a new operator using a registration nonce JWT
	RegisterOperator(context.Context, *RegisterClientRequest) (*RegisterClientResponse, error)
	// contains filtered or unexported methods
}

type RenewCertificateRequest struct {
	PublicKeyPem []byte `protobuf:"bytes,1,opt,name=public_key_pem,json=publicKeyPem,proto3" json:"public_key_pem,omitempty"` // Same or new public key
	// contains filtered or unexported fields
}

type RenewCertificateResponse struct {
	ClientCertificatePem []byte                 `protobuf:"bytes,1,opt,name=client_certificate_pem,json=clientCertificatePem,proto3" json:"client_certificate_pem,omitempty"`
	ExpiresAt            *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

type TerminationNotice struct {
	Action   string                 `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`     // Action to take, e.g., "terminate"
	Deadline *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=deadline,proto3" json:"deadline,omitempty"` // Optional termination deadline
	// contains filtered or unexported fields
}

type UnimplementedAgentServiceServer struct{}

type UnimplementedOperatorServiceServer struct{}

type UnimplementedRegistrationServiceServer struct{}

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

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

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

type UpsertGroupRequest struct {
	Key    string       `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Config *GroupConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}