rpc

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

type CleanupScanRequest struct {

	// DryRun computes and returns the plan without writing anything.
	DryRun bool `protobuf:"varint,1,opt,name=DryRun,proto3" json:"DryRun,omitempty"`
	// Prune additionally hard-deletes the byte-identical (same RawXML) subset instead of
	// tombstoning it — safe because those rows carry no unique information.
	Prune bool `protobuf:"varint,2,opt,name=Prune,proto3" json:"Prune,omitempty"`
	// contains filtered or unexported fields
}

type CleanupScanResponse struct {

	// Tombstoned is the number of runs marked SupersededBy a head.
	Tombstoned int32 `protobuf:"varint,1,opt,name=Tombstoned,proto3" json:"Tombstoned,omitempty"`
	// Pruned is the number of byte-identical runs hard-deleted (only when Prune).
	Pruned int32 `protobuf:"varint,2,opt,name=Pruned,proto3" json:"Pruned,omitempty"`
	// Heads are the surviving series heads, each with its recomputed FormerRuns.
	Heads []*pb.Run `protobuf:"bytes,3,rep,name=Heads,proto3" json:"Heads,omitempty"`
	// contains filtered or unexported fields
}

type CreateScanRequest struct {
	Filters *RunFilters `protobuf:"bytes,1,opt,name=Filters,proto3" json:"Filters,omitempty"`
	Scans   []*pb.Run   `protobuf:"bytes,2,rep,name=Scans,proto3" json:"Scans,omitempty"`
	// contains filtered or unexported fields
}

type CreateScanResponse struct {
	Scans []*pb.Run `protobuf:"bytes,1,rep,name=Scans,proto3" json:"Scans,omitempty"`
	// contains filtered or unexported fields
}

type DeleteScanRequest struct {
	Scans []*pb.Run `protobuf:"bytes,1,rep,name=Scans,proto3" json:"Scans,omitempty"`
	// contains filtered or unexported fields
}

type DeleteScanResponse struct {
	Scans []*pb.Run `protobuf:"bytes,1,rep,name=Scans,proto3" json:"Scans,omitempty"`
	// contains filtered or unexported fields
}

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

type JobsResponse struct {
	Jobs []*ScanJob `protobuf:"bytes,1,rep,name=Jobs,proto3" json:"Jobs,omitempty"`
	// contains filtered or unexported fields
}

type ReadScanManyRequest struct {
	Filters *RunFilters `protobuf:"bytes,1,opt,name=Filters,proto3" json:"Filters,omitempty"`
	Scan    *pb.Run     `protobuf:"bytes,2,opt,name=Scan,proto3" json:"Scan,omitempty"`
	// contains filtered or unexported fields
}

type ReadScanManyResponse struct {
	Scans []*pb.Run `protobuf:"bytes,1,rep,name=Scans,proto3" json:"Scans,omitempty"`
	// contains filtered or unexported fields
}

type ReadScanRequest struct {
	Filters *RunFilters `protobuf:"bytes,1,opt,name=Filters,proto3" json:"Filters,omitempty"`
	Scan    *pb.Run     `protobuf:"bytes,2,opt,name=Scan,proto3" json:"Scan,omitempty"`
	// contains filtered or unexported fields
}

type ReadScanResponse struct {
	Scans []*pb.Run `protobuf:"bytes,1,rep,name=Scans,proto3" json:"Scans,omitempty"`
	// contains filtered or unexported fields
}

type ResumeScanRequest struct {

	// Id is the interrupted run to resume. The server re-scans only its uncompleted targets.
	Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	// Background detaches the resumed job, like RunScanRequest.Background.
	Background bool `protobuf:"varint,2,opt,name=Background,proto3" json:"Background,omitempty"`
	// contains filtered or unexported fields
}

type RunFilters struct {
	MaxResults int64 `protobuf:"varint,1,opt,name=MaxResults,proto3" json:"MaxResults,omitempty"`
	Hosts      bool  `protobuf:"varint,2,opt,name=Hosts,proto3" json:"Hosts,omitempty"`
	Ports      bool  `protobuf:"varint,3,opt,name=Ports,proto3" json:"Ports,omitempty"`
	// Source: if set, scope the read to only the runs of this tool (matched against the
	// run's Scanner, which is the producing tool). Empty means all runs.
	Source string `protobuf:"bytes,4,opt,name=Source,proto3" json:"Source,omitempty"`
	// IncludeSuperseded: by default a read returns only surviving series heads (tombstoned runs are
	// hidden — see Run.SupersededBy). Set true to return every run, superseded ones included (used
	// by `scan list --all`, and by id-addressed reads like `show`/`rm`/`diff` that must reach a
	// tombstoned run).
	IncludeSuperseded bool `protobuf:"varint,5,opt,name=IncludeSuperseded,proto3" json:"IncludeSuperseded,omitempty"`
	// SupersededBy: if set, return exactly the runs tombstoned under this head Id — the server-side
	// query behind `scan history <head>`, so a series is fetched directly instead of read-all-and-filter.
	SupersededBy string `protobuf:"bytes,6,opt,name=SupersededBy,proto3" json:"SupersededBy,omitempty"`
	// contains filtered or unexported fields
}

type RunScanRequest struct {

	// Scanner is the tool to drive (e.g. "nmap"); it names a server-side Scanner adapter.
	Scanner string `protobuf:"bytes,1,opt,name=Scanner,proto3" json:"Scanner,omitempty"`
	// Args are extra tool arguments (raw passthrough), placed before the target specs.
	Args []string `protobuf:"bytes,2,rep,name=Args,proto3" json:"Args,omitempty"`
	// Targets are the scan targets (typically derived from stored hosts).
	Targets []*pb.Target `protobuf:"bytes,3,rep,name=Targets,proto3" json:"Targets,omitempty"`
	// Background detaches the job: the server returns the JobId frame and keeps running.
	Background bool `protobuf:"varint,4,opt,name=Background,proto3" json:"Background,omitempty"`
	// contains filtered or unexported fields
}

type RunUpdate struct {

	// Types that are assignable to Update:
	//
	//	*RunUpdate_JobId
	//	*RunUpdate_Progress
	//	*RunUpdate_Host
	//	*RunUpdate_Final
	//	*RunUpdate_Error
	//	*RunUpdate_Warning
	Update isRunUpdate_Update `protobuf_oneof:"update"`
	// contains filtered or unexported fields
}

type RunUpdate_Error struct {
	// Error carries a fatal scan error (the stream ends after it).
	Error string `protobuf:"bytes,5,opt,name=Error,proto3,oneof"`
}

type RunUpdate_Final struct {
	// Final is the completed, stored run; sent as the last frame of a foreground stream.
	Final *pb.Run `protobuf:"bytes,4,opt,name=Final,proto3,oneof"`
}

type RunUpdate_Host struct {
	// Host is a host the scan has finished, streamed as it is found.
	Host *pb1.Host `protobuf:"bytes,3,opt,name=Host,proto3,oneof"`
}

type RunUpdate_JobId struct {
	// JobId identifies the server-side job; sent as the first frame.
	JobId string `protobuf:"bytes,1,opt,name=JobId,proto3,oneof"`
}

type RunUpdate_Progress struct {
	// Progress is a taskprogress frame from the scanner.
	Progress *pb.TaskProgress `protobuf:"bytes,2,opt,name=Progress,proto3,oneof"`
}

type RunUpdate_Warning struct {
	// Warning is a live, non-fatal scanner notice (a raw nmap/masscan stderr line) streamed as
	// it is emitted, so a long scan that is plainly busy is not shown as silent. The client
	// classifies/colours it; the stream continues after it.
	Warning string `protobuf:"bytes,6,opt,name=Warning,proto3,oneof"`
}

type ScanJob struct {
	Id        string       `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Scanner   string       `protobuf:"bytes,2,opt,name=Scanner,proto3" json:"Scanner,omitempty"`
	Args      []string     `protobuf:"bytes,3,rep,name=Args,proto3" json:"Args,omitempty"`
	StartedAt int64        `protobuf:"varint,4,opt,name=StartedAt,proto3" json:"StartedAt,omitempty"`
	Targets   []*pb.Target `protobuf:"bytes,5,rep,name=Targets,proto3" json:"Targets,omitempty"`
	// contains filtered or unexported fields
}

type ScansClient interface {
	Create(ctx context.Context, in *CreateScanRequest, opts ...grpc.CallOption) (*CreateScanResponse, error)
	Read(ctx context.Context, in *ReadScanRequest, opts ...grpc.CallOption) (*ReadScanResponse, error)
	List(ctx context.Context, in *ReadScanRequest, opts ...grpc.CallOption) (*ReadScanResponse, error)
	Upsert(ctx context.Context, in *UpsertScanRequest, opts ...grpc.CallOption) (*UpsertScanResponse, error)
	Delete(ctx context.Context, in *DeleteScanRequest, opts ...grpc.CallOption) (*DeleteScanResponse, error)
	// Cleanup collapses repeated runs of the same scan definition (same scanner + args + targets)
	// into a single visible head per series, tombstoning the older siblings (SupersededBy) rather
	// than deleting them so drift history (`scan diff`) and cross-run host sharing survive. DryRun
	// returns the plan without writing; Prune additionally hard-deletes the byte-identical subset.
	Cleanup(ctx context.Context, in *CleanupScanRequest, opts ...grpc.CallOption) (*CleanupScanResponse, error)
	// Run executes a scanner server-side against the given targets and streams progress,
	// hosts, and the final stored run back as RunUpdate frames. Foreground clients consume the
	// stream to completion; background clients (Background=true) get the JobId frame and may
	// disconnect while the server-side job keeps running.
	Run(ctx context.Context, in *RunScanRequest, opts ...grpc.CallOption) (Scans_RunClient, error)
	// Jobs lists the scans currently running server-side.
	Jobs(ctx context.Context, in *JobsRequest, opts ...grpc.CallOption) (*JobsResponse, error)
	// Attach re-subscribes to a running job's stream, yielding the same RunUpdate frames as Run.
	Attach(ctx context.Context, in *AttachRequest, opts ...grpc.CallOption) (Scans_AttachClient, error)
	// Stop cancels a running job, killing its scanner process.
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
	// Resume continues an interrupted run: it re-invokes the scanner over only the targets that
	// run never completed (its per-target completion record), folding the results into a new run
	// that links back to the interrupted one (ResumedFrom) and tombstones it. Streams the same
	// RunUpdate frames as Run.
	Resume(ctx context.Context, in *ResumeScanRequest, opts ...grpc.CallOption) (Scans_ResumeClient, error)
}

type ScansServer interface {
	Create(context.Context, *CreateScanRequest) (*CreateScanResponse, error)
	Read(context.Context, *ReadScanRequest) (*ReadScanResponse, error)
	List(context.Context, *ReadScanRequest) (*ReadScanResponse, error)
	Upsert(context.Context, *UpsertScanRequest) (*UpsertScanResponse, error)
	Delete(context.Context, *DeleteScanRequest) (*DeleteScanResponse, error)
	// Cleanup collapses repeated runs of the same scan definition (same scanner + args + targets)
	// into a single visible head per series, tombstoning the older siblings (SupersededBy) rather
	// than deleting them so drift history (`scan diff`) and cross-run host sharing survive. DryRun
	// returns the plan without writing; Prune additionally hard-deletes the byte-identical subset.
	Cleanup(context.Context, *CleanupScanRequest) (*CleanupScanResponse, error)
	// Run executes a scanner server-side against the given targets and streams progress,
	// hosts, and the final stored run back as RunUpdate frames. Foreground clients consume the
	// stream to completion; background clients (Background=true) get the JobId frame and may
	// disconnect while the server-side job keeps running.
	Run(*RunScanRequest, Scans_RunServer) error
	// Jobs lists the scans currently running server-side.
	Jobs(context.Context, *JobsRequest) (*JobsResponse, error)
	// Attach re-subscribes to a running job's stream, yielding the same RunUpdate frames as Run.
	Attach(*AttachRequest, Scans_AttachServer) error
	// Stop cancels a running job, killing its scanner process.
	Stop(context.Context, *StopRequest) (*StopResponse, error)
	// Resume continues an interrupted run: it re-invokes the scanner over only the targets that
	// run never completed (its per-target completion record), folding the results into a new run
	// that links back to the interrupted one (ResumedFrom) and tombstones it. Streams the same
	// RunUpdate frames as Run.
	Resume(*ResumeScanRequest, Scans_ResumeServer) error
	// contains filtered or unexported methods
}

type Scans_AttachClient interface {
	Recv() (*RunUpdate, error)
	grpc.ClientStream
}

type Scans_AttachServer interface {
	Send(*RunUpdate) error
	grpc.ServerStream
}

type Scans_ResumeClient interface {
	Recv() (*RunUpdate, error)
	grpc.ClientStream
}

type Scans_ResumeServer interface {
	Send(*RunUpdate) error
	grpc.ServerStream
}

type Scans_RunClient interface {
	Recv() (*RunUpdate, error)
	grpc.ClientStream
}

type Scans_RunServer interface {
	Send(*RunUpdate) error
	grpc.ServerStream
}

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

type StopResponse struct {
	JobId   string `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	Stopped bool   `protobuf:"varint,2,opt,name=Stopped,proto3" json:"Stopped,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedScansServer struct {
}

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

type UpsertScanRequest struct {
	Scans []*pb.Run `protobuf:"bytes,1,rep,name=Scans,proto3" json:"Scans,omitempty"`
	// contains filtered or unexported fields
}

type UpsertScanResponse struct {
	Scans []*pb.Run `protobuf:"bytes,1,rep,name=Scans,proto3" json:"Scans,omitempty"`
	// contains filtered or unexported fields
}