proto

type ArtifactInfo struct {

	// The local path of the downloaded artifact.
	LocalName string `protobuf:"bytes,1,opt,name=local_name,json=localName,proto3" json:"local_name,omitempty"`
	// The original path of the artifact.
	OriginalName string `protobuf:"bytes,2,opt,name=original_name,json=originalName,proto3" json:"original_name,omitempty"`
	// Any enrichment fields provided by the source.
	SourceEnrichment *SourceEnrichment `protobuf:"bytes,3,opt,name=source_enrichment,json=sourceEnrichment,proto3" json:"source_enrichment,omitempty"`
	// contains filtered or unexported fields
}

type ArtifactSourceConfig struct {

	// File layout grok string defining the file layout and allowing metadata extraction.
	FileLayout string `protobuf:"bytes,1,opt,name=file_layout,json=fileLayout,proto3" json:"file_layout,omitempty"`
	// Grok patterns to add to the grok parser used to parse the layout.
	Patterns map[string]string `` /* 143-byte string literal not displayed */
	// List of filters to apply to the path segments.
	// Note: each filter must refer to a single property only.
	Filters []string `protobuf:"bytes,3,rep,name=filters,proto3" json:"filters,omitempty"`
	// contains filtered or unexported fields
}

type CollectRequest struct {
	TableName     string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	PartitionName string `protobuf:"bytes,2,opt,name=partition_name,json=partitionName,proto3" json:"partition_name,omitempty"`
	// unique identifier for collection execution this will be used as base for the filename for the resulting JSONL files
	ExecutionId string `protobuf:"bytes,3,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	// the temporary directory to use for the collection
	CollectionTempDir string `protobuf:"bytes,4,opt,name=collection_temp_dir,json=collectionTempDir,proto3" json:"collection_temp_dir,omitempty"`
	// the path to the collection state file
	CollectionStatePath string `protobuf:"bytes,5,opt,name=collection_state_path,json=collectionStatePath,proto3" json:"collection_state_path,omitempty"`
	// the source to use (with raw config)
	SourceData *ConfigData `protobuf:"bytes,6,opt,name=source_data,json=sourceData,proto3" json:"source_data,omitempty"`
	// the raw hcl of the connection
	ConnectionData *ConfigData `protobuf:"bytes,7,opt,name=connection_data,json=connectionData,proto3" json:"connection_data,omitempty"`
	// if this is custom table, schema contains the source format and table schema
	CustomTableSchema *Schema `protobuf:"bytes,8,opt,name=custom_table_schema,json=customTableSchema,proto3" json:"custom_table_schema,omitempty"`
	// optional: the source format
	SourceFormat *FormatData `protobuf:"bytes,9,opt,name=source_format,json=sourceFormat,proto3" json:"source_format,omitempty"`
	// optional: the reattach config to connect to the plugin providing the source
	SourcePlugin *SourcePluginReattach `protobuf:"bytes,10,opt,name=source_plugin,json=sourcePlugin,proto3" json:"source_plugin,omitempty"`
	// optional: the collection start time
	FromTime *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=from_time,json=fromTime,proto3" json:"from_time,omitempty"`
	// the max space to take with temp files
	TempDirMaxMb int64 `protobuf:"varint,12,opt,name=temp_dir_max_mb,json=tempDirMaxMb,proto3" json:"temp_dir_max_mb,omitempty"`
	// the collection end time
	ToTime *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=to_time,json=toTime,proto3" json:"to_time,omitempty"`
	// recollect all data for the specified time range even if it has been collected already
	Recollect *bool `protobuf:"varint,14,opt,name=recollect,proto3,oneof" json:"recollect,omitempty"`
	// contains filtered or unexported fields
}

type CollectResponse struct {
	ExecutionId string `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	// partition schema
	Schema *Schema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// resolved from time
	FromTime *ResolvedFromTime `protobuf:"bytes,3,opt,name=from_time,json=fromTime,proto3" json:"from_time,omitempty"`
	// contains filtered or unexported fields
}

type ColumnSchema struct {

	// The type of the column - must be a valid DuckDB type
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// The name of the source field
	SourceName string `protobuf:"bytes,2,opt,name=source_name,json=sourceName,proto3" json:"source_name,omitempty"`
	// The name of the column
	ColumnName string `protobuf:"bytes,3,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	// child fields (for a struct)
	ChildFields []*ColumnSchema `protobuf:"bytes,4,rep,name=child_fields,json=childFields,proto3" json:"child_fields,omitempty"`
	// column description
	Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// is the column required
	Required bool `protobuf:"varint,6,opt,name=required,proto3" json:"required,omitempty"`
	// the null value to use for the column
	NullValue string `protobuf:"bytes,7,opt,name=null_value,json=nullValue,proto3" json:"null_value,omitempty"`
	// the duckdb function to use to map the column
	Transform string `protobuf:"bytes,8,opt,name=transform,proto3" json:"transform,omitempty"`
	// contains filtered or unexported fields
}

type ConfigData struct {

	// the name of the config target
	Target string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	// raw hcl for collection specific config
	Hcl   []byte `protobuf:"bytes,2,opt,name=hcl,proto3" json:"hcl,omitempty"`
	Range *Range `protobuf:"bytes,3,opt,name=range,proto3" json:"range,omitempty"`
	// contains filtered or unexported fields
}

type DescribeRequest struct {
	CustomFormats []*FormatData `protobuf:"bytes,1,rep,name=custom_formats,json=customFormats,proto3" json:"custom_formats,omitempty"`
	// only include the specified format types - no other descriptions will be returned
	CustomFormatsOnly bool `protobuf:"varint,2,opt,name=custom_formats_only,json=customFormatsOnly,proto3" json:"custom_formats_only,omitempty"`
	// contains filtered or unexported fields
}

type DescribeResponse struct {

	// Map of schemas keyed by collection name
	Schemas        map[string]*Schema            `` /* 141-byte string literal not displayed */
	Sources        map[string]*SourceMetadata    `` /* 141-byte string literal not displayed */
	FormatsPresets map[string]*FormatDescription `` /* 177-byte string literal not displayed */
	// map string to array of custom format descriptions
	CustomFormats map[string]*FormatDescription `` /* 174-byte string literal not displayed */
	// list of all format types provided by the plugin
	FormatTypes []string `protobuf:"bytes,5,rep,name=format_types,json=formatTypes,proto3" json:"format_types,omitempty"`
	// contains filtered or unexported fields
}

type DownloadedArtifactInfo struct {

	// The local path of the downloaded artifact.
	LocalName string `protobuf:"bytes,1,opt,name=local_name,json=localName,proto3" json:"local_name,omitempty"`
	// The original path of the artifact.
	OriginalName string `protobuf:"bytes,2,opt,name=original_name,json=originalName,proto3" json:"original_name,omitempty"`
	// Any enrichment fields provided by the source.
	SourceEnrichment *SourceEnrichment `protobuf:"bytes,3,opt,name=source_enrichment,json=sourceEnrichment,proto3" json:"source_enrichment,omitempty"`
	Size             int64             `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

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

type Event struct {

	// Types that are valid to be assigned to Event:
	//
	//	*Event_StartedEvent
	//	*Event_ChunkWrittenEvent
	//	*Event_CompleteEvent
	//	*Event_ErrorEvent
	//	*Event_StatusEvent
	//	*Event_ArtifactDiscoveredEvent
	//	*Event_ArtifactDownloadedEvent
	//	*Event_ArtifactExtractedEvent
	//	*Event_SourceCompleteEvent
	//	*Event_HeaderEvent
	Event isEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

type EventArtifactDiscovered struct {
	ExecutionId  string        `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	ArtifactInfo *ArtifactInfo `protobuf:"bytes,2,opt,name=artifact_info,json=artifactInfo,proto3" json:"artifact_info,omitempty"`
	// contains filtered or unexported fields
}

type EventArtifactDownloaded struct {
	ExecutionId  string                  `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	ArtifactInfo *DownloadedArtifactInfo `protobuf:"bytes,2,opt,name=artifact_info,json=artifactInfo,proto3" json:"artifact_info,omitempty"`
	Size         int64                   `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

type EventArtifactExtracted struct {
	ExecutionId  string                  `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	ArtifactInfo *DownloadedArtifactInfo `protobuf:"bytes,2,opt,name=artifact_info,json=artifactInfo,proto3" json:"artifact_info,omitempty"`
	// contains filtered or unexported fields
}

type EventChunkWritten struct {
	ExecutionId string `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	ChunkNumber int32  `protobuf:"varint,2,opt,name=chunk_number,json=chunkNumber,proto3" json:"chunk_number,omitempty"`
	// contains filtered or unexported fields
}

type EventComplete struct {
	ExecutionId string            `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	RowCount    int64             `protobuf:"varint,2,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	ChunkCount  int32             `protobuf:"varint,3,opt,name=chunk_count,json=chunkCount,proto3" json:"chunk_count,omitempty"`
	Metadata    map[string]string `` /* 143-byte string literal not displayed */
	Error       string            `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type EventError struct {
	ExecutionId string `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	Error       string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type EventHeader struct {
	ExecutionId  string        `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	ArtifactInfo *ArtifactInfo `protobuf:"bytes,2,opt,name=artifact_info,json=artifactInfo,proto3" json:"artifact_info,omitempty"`
	Header       []string      `protobuf:"bytes,3,rep,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

type EventSourceComplete struct {
	ExecutionId string `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	Error       string `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

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

type EventStatus struct {
	LatestArtifactPath       string     `protobuf:"bytes,1,opt,name=latest_artifact_path,json=latestArtifactPath,proto3" json:"latest_artifact_path,omitempty"`
	ArtifactsDiscovered      int64      `protobuf:"varint,2,opt,name=artifacts_discovered,json=artifactsDiscovered,proto3" json:"artifacts_discovered,omitempty"`
	ArtifactsDownloaded      int64      `protobuf:"varint,3,opt,name=artifacts_downloaded,json=artifactsDownloaded,proto3" json:"artifacts_downloaded,omitempty"`
	ArtifactsDownloadedBytes int64      `` /* 136-byte string literal not displayed */
	ArtifactsExtracted       int64      `protobuf:"varint,5,opt,name=artifacts_extracted,json=artifactsExtracted,proto3" json:"artifacts_extracted,omitempty"`
	ArtifactErrors           int64      `protobuf:"varint,6,opt,name=artifact_errors,json=artifactErrors,proto3" json:"artifact_errors,omitempty"`
	RowsReceived             int64      `protobuf:"varint,7,opt,name=rows_received,json=rowsReceived,proto3" json:"rows_received,omitempty"`
	RowsEnriched             int64      `protobuf:"varint,8,opt,name=rows_enriched,json=rowsEnriched,proto3" json:"rows_enriched,omitempty"`
	Errors                   int64      `protobuf:"varint,9,opt,name=errors,proto3" json:"errors,omitempty"`
	RowErrors                *RowErrors `protobuf:"bytes,10,opt,name=row_errors,json=rowErrors,proto3" json:"row_errors,omitempty"`
	SourceErrors             []string   `protobuf:"bytes,11,rep,name=source_errors,json=sourceErrors,proto3" json:"source_errors,omitempty"`
	// contains filtered or unexported fields
}

type Event_ArtifactDiscoveredEvent struct {
	ArtifactDiscoveredEvent *EventArtifactDiscovered `protobuf:"bytes,6,opt,name=artifact_discovered_event,json=artifactDiscoveredEvent,proto3,oneof"`
}

type Event_ArtifactDownloadedEvent struct {
	ArtifactDownloadedEvent *EventArtifactDownloaded `protobuf:"bytes,7,opt,name=artifact_downloaded_event,json=artifactDownloadedEvent,proto3,oneof"`
}

type Event_ArtifactExtractedEvent struct {
	ArtifactExtractedEvent *EventArtifactExtracted `protobuf:"bytes,8,opt,name=artifact_extracted_event,json=artifactExtractedEvent,proto3,oneof"`
}

type Event_ChunkWrittenEvent struct {
	ChunkWrittenEvent *EventChunkWritten `protobuf:"bytes,2,opt,name=chunk_written_event,json=chunkWrittenEvent,proto3,oneof"`
}

type Event_CompleteEvent struct {
	CompleteEvent *EventComplete `protobuf:"bytes,3,opt,name=complete_event,json=completeEvent,proto3,oneof"`
}

type Event_ErrorEvent struct {
	ErrorEvent *EventError `protobuf:"bytes,4,opt,name=error_event,json=errorEvent,proto3,oneof"`
}

type Event_HeaderEvent struct {
	HeaderEvent *EventHeader `protobuf:"bytes,10,opt,name=header_event,json=headerEvent,proto3,oneof"`
}

type Event_SourceCompleteEvent struct {
	SourceCompleteEvent *EventSourceComplete `protobuf:"bytes,9,opt,name=source_complete_event,json=sourceCompleteEvent,proto3,oneof"`
}

type Event_StartedEvent struct {
	StartedEvent *EventStarted `protobuf:"bytes,1,opt,name=started_event,json=startedEvent,proto3,oneof"`
}

type Event_StatusEvent struct {
	StatusEvent *EventStatus `protobuf:"bytes,5,opt,name=status_event,json=statusEvent,proto3,oneof"`
}

type FormatData struct {
	Config     *ConfigData `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Name       string      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	PresetName string      `protobuf:"bytes,3,opt,name=preset_name,json=presetName,proto3" json:"preset_name,omitempty"`
	Regex      string      `protobuf:"bytes,4,opt,name=regex,proto3" json:"regex,omitempty"`
	// contains filtered or unexported fields
}

type FormatDescription struct {

	// format type
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// format instance name
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// format description
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// format properties
	Properties map[string]string `` /* 147-byte string literal not displayed */
	// regex
	Regex string `protobuf:"bytes,5,opt,name=regex,proto3" json:"regex,omitempty"`
	// contains filtered or unexported fields
}

type GetSupportedOperationsResponse struct {
	TimeRanges bool `protobuf:"varint,1,opt,name=time_ranges,json=timeRanges,proto3" json:"time_ranges,omitempty"`
	// contains filtered or unexported fields
}

type InitSourceRequest struct {

	// the default config for the source
	DefaultConfig *ArtifactSourceConfig `protobuf:"bytes,1,opt,name=default_config,json=defaultConfig,proto3" json:"default_config,omitempty"`
	// params to use for the source
	SourceParams *RowSourceParams `protobuf:"bytes,2,opt,name=source_params,json=sourceParams,proto3" json:"source_params,omitempty"`
	// contains filtered or unexported fields
}

type InitSourceResponse struct {

	// resolved from time
	FromTime *ResolvedFromTime `protobuf:"bytes,1,opt,name=from_time,json=fromTime,proto3" json:"from_time,omitempty"`
	// contains filtered or unexported fields
}

type NetAddr struct {
	Network string `protobuf:"bytes,1,opt,name=Network,proto3" json:"Network,omitempty"` // name of the network (for example, "tcp", "udp")
	Address string `protobuf:"bytes,2,opt,name=Address,proto3" json:"Address,omitempty"` // string form of address (for example, "192.0.2.1:25", "[2001:db8::1]:80")
	// contains filtered or unexported fields
}

type OperationErrorAggregate struct {
	MissingFields []string `protobuf:"bytes,1,rep,name=missing_fields,json=missingFields,proto3" json:"missing_fields,omitempty"`
	InvalidFields []string `protobuf:"bytes,2,rep,name=invalid_fields,json=invalidFields,proto3" json:"invalid_fields,omitempty"`
	Messages      []string `protobuf:"bytes,3,rep,name=messages,proto3" json:"messages,omitempty"`
	Count         int64    `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

type Pos struct {
	Line   int64 `protobuf:"varint,1,opt,name=line,proto3" json:"line,omitempty"`
	Column int64 `protobuf:"varint,2,opt,name=column,proto3" json:"column,omitempty"`
	Byte   int64 `protobuf:"varint,3,opt,name=byte,proto3" json:"byte,omitempty"`
	// contains filtered or unexported fields
}

type PropertyMetadata struct {
	Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	Type        string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Required    bool   `protobuf:"varint,3,opt,name=required,proto3" json:"required,omitempty"`
	Default     string `protobuf:"bytes,4,opt,name=default,proto3" json:"default,omitempty"`
	// contains filtered or unexported fields
}

type Range struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	Start    *Pos   `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	End      *Pos   `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

type ReattachConfig struct {
	Protocol        string   `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
	ProtocolVersion int64    `protobuf:"varint,2,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	Addr            *NetAddr `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
	Pid             int64    `protobuf:"varint,4,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

type ResolvedFromTime struct {
	FromTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=from_time,json=fromTime,proto3" json:"from_time,omitempty"`
	Source   string                 `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

type RowErrors struct {
	Total int64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	// source -> operation
	Errors map[string]*RowErrorsByOperation `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type RowErrorsByOperation struct {

	// operation -> error aggregate
	OperationErrors map[string]*OperationErrorAggregate `` /* 180-byte string literal not displayed */
	// contains filtered or unexported fields
}

type RowSourceParams struct {

	// the source to use (with raw config)
	SourceData *ConfigData `protobuf:"bytes,1,opt,name=source_data,json=sourceData,proto3" json:"source_data,omitempty"`
	// the raw hcl of the connection
	ConnectionData *ConfigData `protobuf:"bytes,2,opt,name=connection_data,json=connectionData,proto3" json:"connection_data,omitempty"`
	// the collection start time
	FromTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=from_time,json=fromTime,proto3" json:"from_time,omitempty"`
	// the collection temporary directory
	CollectionTempDir string `protobuf:"bytes,4,opt,name=collection_temp_dir,json=collectionTempDir,proto3" json:"collection_temp_dir,omitempty"`
	// the path to the collection state file
	CollectionStatePath string `protobuf:"bytes,5,opt,name=collection_state_path,json=collectionStatePath,proto3" json:"collection_state_path,omitempty"`
	// the collection end time
	ToTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=to_time,json=toTime,proto3" json:"to_time,omitempty"`
	// recollect all data for the specified time range even if it has been collected already
	Overwrite bool `protobuf:"varint,14,opt,name=overwrite,proto3" json:"overwrite,omitempty"`
	// contains filtered or unexported fields
}

type Schema struct {

	// Map of source field name to column name and type
	Columns []*ColumnSchema `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	// deprecated: use source_columns
	//
	// Deprecated: Marked as deprecated in plugin.proto.
	AutomapSourceFields bool `protobuf:"varint,2,opt,name=automap_source_fields,json=automapSourceFields,proto3" json:"automap_source_fields,omitempty"`
	// deprecated: use source_columns
	//
	// Deprecated: Marked as deprecated in plugin.proto.
	ExcludeSourceFields []string `protobuf:"bytes,3,rep,name=exclude_source_fields,json=excludeSourceFields,proto3" json:"exclude_source_fields,omitempty"`
	// table description
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// the default null value to use for the table
	NullValue string `protobuf:"bytes,5,opt,name=null_value,json=nullValue,proto3" json:"null_value,omitempty"`
	// the table name
	Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	// a pattern to select which source columns to auto map
	MapFields []string `protobuf:"bytes,7,rep,name=map_fields,json=mapFields,proto3" json:"map_fields,omitempty"`
	// contains filtered or unexported fields
}

type SimpleAddr struct {
	NetworkString string `json:"network"`
	AddressString string `json:"string"`
}

type SourceCollectRequest struct {

	// unique identifier for collection execution
	ExecutionId string `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	// contains filtered or unexported fields
}

type SourceEnrichment struct {
	CommonFields map[string]string `` /* 171-byte string literal not displayed */
	Metadata     map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type SourceMetadata struct {
	Name        string                       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string                       `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Properties  map[string]*PropertyMetadata `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

type SourcePluginReattach struct {
	ReattachConfig *ReattachConfig `protobuf:"bytes,1,opt,name=reattach_config,json=reattachConfig,proto3" json:"reattach_config,omitempty"`
	SourceType     string          `protobuf:"bytes,2,opt,name=source_type,json=sourceType,proto3" json:"source_type,omitempty"`
	Plugin         string          `protobuf:"bytes,3,opt,name=plugin,proto3" json:"plugin,omitempty"`
	// contains filtered or unexported fields
}

type TailpipePluginClient interface {
	Describe(ctx context.Context, in *DescribeRequest, opts ...grpc.CallOption) (*DescribeResponse, error)
	AddObserver(ctx context.Context, in *Empty, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Event], error)
	Collect(ctx context.Context, in *CollectRequest, opts ...grpc.CallOption) (*CollectResponse, error)
	InitSource(ctx context.Context, in *InitSourceRequest, opts ...grpc.CallOption) (*InitSourceResponse, error)
	UpdateCollectionState(ctx context.Context, in *UpdateCollectionStateRequest, opts ...grpc.CallOption) (*Empty, error)
	CloseSource(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	SaveCollectionState(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	SourceCollect(ctx context.Context, in *SourceCollectRequest, opts ...grpc.CallOption) (*Empty, error)
	SourcePause(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	SourceResume(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	SourceCollectionComplete(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	GetSupportedOperations(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetSupportedOperationsResponse, error)
}

type TailpipePluginServer interface {
	Describe(context.Context, *DescribeRequest) (*DescribeResponse, error)
	AddObserver(*Empty, grpc.ServerStreamingServer[Event]) error
	Collect(context.Context, *CollectRequest) (*CollectResponse, error)
	InitSource(context.Context, *InitSourceRequest) (*InitSourceResponse, error)
	UpdateCollectionState(context.Context, *UpdateCollectionStateRequest) (*Empty, error)
	CloseSource(context.Context, *Empty) (*Empty, error)
	SaveCollectionState(context.Context, *Empty) (*Empty, error)
	SourceCollect(context.Context, *SourceCollectRequest) (*Empty, error)
	SourcePause(context.Context, *Empty) (*Empty, error)
	SourceResume(context.Context, *Empty) (*Empty, error)
	SourceCollectionComplete(context.Context, *Empty) (*Empty, error)
	GetSupportedOperations(context.Context, *Empty) (*GetSupportedOperationsResponse, error)
	// contains filtered or unexported methods
}

type TailpipePlugin_AddObserverClient = grpc.ServerStreamingClient[Event]

type TailpipePlugin_AddObserverServer = grpc.ServerStreamingServer[Event]

type UnimplementedTailpipePluginServer struct{}

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

type UpdateCollectionStateRequest struct {

	// the path to the collection state file
	CollectionStatePath string `protobuf:"bytes,1,opt,name=collection_state_path,json=collectionStatePath,proto3" json:"collection_state_path,omitempty"`
	// the source to use (with raw config)
	SourceData *ConfigData `protobuf:"bytes,2,opt,name=source_data,json=sourceData,proto3" json:"source_data,omitempty"`
	// the collection start time
	FromTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=from_time,json=fromTime,proto3" json:"from_time,omitempty"`
	// contains filtered or unexported fields
}