apiv1

type Connector struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to State:
	//
	//	*Connector_DestinationState_
	//	*Connector_SourceState_
	State        isConnector_State      `protobuf_oneof:"state"`
	Config       *Connector_Config      `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	Type         Connector_Type         `protobuf:"varint,5,opt,name=type,proto3,enum=api.v1.Connector_Type" json:"type,omitempty"`
	Plugin       string                 `protobuf:"bytes,6,opt,name=plugin,proto3" json:"plugin,omitempty"`
	PipelineId   string                 `protobuf:"bytes,7,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	ProcessorIds []string               `protobuf:"bytes,8,rep,name=processor_ids,json=processorIds,proto3" json:"processor_ids,omitempty"`
	CreatedAt    *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt    *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

type ConnectorPluginSpecifications struct {

	// Name is the name of the plugin.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Summary is a brief description of the plugin and what it does,
	// ideally not longer than one sentence.
	Summary string `protobuf:"bytes,2,opt,name=summary,proto3" json:"summary,omitempty"`
	// Description is a longer form field, appropriate for README-like
	// text that the author can provide for documentation about the
	// usage of the plugin.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Version string. Should follow semantic versioning and use the "v"
	// prefix (e.g. v1.23.4).
	Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	// Author declares the entity that created or maintains this plugin.
	Author string `protobuf:"bytes,5,opt,name=author,proto3" json:"author,omitempty"`
	// A map that describes parameters available for configuring the
	// destination plugin.
	DestinationParams map[string]*v1.Parameter `` /* 200-byte string literal not displayed */
	// A map that describes parameters available for configuring the
	// source plugin.
	SourceParams map[string]*v1.Parameter `` /* 185-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ConnectorServiceClient interface {
	ListConnectors(ctx context.Context, in *ListConnectorsRequest, opts ...grpc.CallOption) (*ListConnectorsResponse, error)
	InspectConnector(ctx context.Context, in *InspectConnectorRequest, opts ...grpc.CallOption) (ConnectorService_InspectConnectorClient, error)
	GetConnector(ctx context.Context, in *GetConnectorRequest, opts ...grpc.CallOption) (*GetConnectorResponse, error)
	CreateConnector(ctx context.Context, in *CreateConnectorRequest, opts ...grpc.CallOption) (*CreateConnectorResponse, error)
	ValidateConnector(ctx context.Context, in *ValidateConnectorRequest, opts ...grpc.CallOption) (*ValidateConnectorResponse, error)
	UpdateConnector(ctx context.Context, in *UpdateConnectorRequest, opts ...grpc.CallOption) (*UpdateConnectorResponse, error)
	DeleteConnector(ctx context.Context, in *DeleteConnectorRequest, opts ...grpc.CallOption) (*DeleteConnectorResponse, error)
	ListConnectorPlugins(ctx context.Context, in *ListConnectorPluginsRequest, opts ...grpc.CallOption) (*ListConnectorPluginsResponse, error)
}

type ConnectorServiceServer interface {
	ListConnectors(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)
	InspectConnector(*InspectConnectorRequest, ConnectorService_InspectConnectorServer) error
	GetConnector(context.Context, *GetConnectorRequest) (*GetConnectorResponse, error)
	CreateConnector(context.Context, *CreateConnectorRequest) (*CreateConnectorResponse, error)
	ValidateConnector(context.Context, *ValidateConnectorRequest) (*ValidateConnectorResponse, error)
	UpdateConnector(context.Context, *UpdateConnectorRequest) (*UpdateConnectorResponse, error)
	DeleteConnector(context.Context, *DeleteConnectorRequest) (*DeleteConnectorResponse, error)
	ListConnectorPlugins(context.Context, *ListConnectorPluginsRequest) (*ListConnectorPluginsResponse, error)
	// contains filtered or unexported methods
}

type ConnectorService_InspectConnectorClient interface {
	Recv() (*InspectConnectorResponse, error)
	grpc.ClientStream
}

type ConnectorService_InspectConnectorServer interface {
	Send(*InspectConnectorResponse) error
	grpc.ServerStream
}

type Connector_Config struct {
	Name     string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Settings map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Connector_DestinationState struct {
	Positions map[string][]byte `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Connector_DestinationState_ struct {
	DestinationState *Connector_DestinationState `protobuf:"bytes,2,opt,name=destination_state,json=destinationState,proto3,oneof"`
}

type Connector_SourceState struct {
	Position []byte `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

type Connector_SourceState_ struct {
	SourceState *Connector_SourceState `protobuf:"bytes,3,opt,name=source_state,json=sourceState,proto3,oneof"`
}

type Connector_Type int32

type CreateConnectorRequest struct {
	Type Connector_Type `protobuf:"varint,1,opt,name=type,proto3,enum=api.v1.Connector_Type" json:"type,omitempty"`
	// Used to reference a plugin. Its format is as follows:
	// [PLUGIN-TYPE:]PLUGIN-NAME[@VERSION]
	// PLUGIN-TYPE: One of: builtin, standalone or any (default).
	// PLUGIN-NAME: The name of the plugin as specified in the plugin specifications.
	// VERSION: The plugin version as specified in the plugin specifications or latest (default).
	// For more information, see: https://conduit.io/docs/connectors/referencing/
	Plugin string `protobuf:"bytes,2,opt,name=plugin,proto3" json:"plugin,omitempty"`
	// ID of the pipeline to which the connector will get attached.
	PipelineId string            `protobuf:"bytes,3,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	Config     *Connector_Config `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type CreateConnectorResponse struct {
	Connector *Connector `protobuf:"bytes,1,opt,name=connector,proto3" json:"connector,omitempty"`
	// contains filtered or unexported fields
}

type CreatePipelineRequest struct {
	Config *Pipeline_Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type CreatePipelineResponse struct {
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

type CreateProcessorRequest struct {

	// Deprecated: Marked as deprecated in api/v1/api.proto.
	Type      string            `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Parent    *Processor_Parent `protobuf:"bytes,3,opt,name=parent,proto3" json:"parent,omitempty"`
	Config    *Processor_Config `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	Condition string            `protobuf:"bytes,5,opt,name=condition,proto3" json:"condition,omitempty"`
	Plugin    string            `protobuf:"bytes,6,opt,name=plugin,proto3" json:"plugin,omitempty"`
	// contains filtered or unexported fields
}

type CreateProcessorResponse struct {
	Processor *Processor `protobuf:"bytes,1,opt,name=processor,proto3" json:"processor,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

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

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

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

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

type ExportPipelineResponse struct {
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

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

type GetConnectorResponse struct {
	Connector *Connector `protobuf:"bytes,1,opt,name=connector,proto3" json:"connector,omitempty"`
	// contains filtered or unexported fields
}

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

type GetDLQResponse struct {
	Dlq *Pipeline_DLQ `protobuf:"bytes,1,opt,name=dlq,proto3" json:"dlq,omitempty"`
	// contains filtered or unexported fields
}

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

type GetInfoResponse struct {
	Info *Info `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

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

type GetPipelineResponse struct {
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

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

type GetProcessorResponse struct {
	Processor *Processor `protobuf:"bytes,1,opt,name=processor,proto3" json:"processor,omitempty"`
	// contains filtered or unexported fields
}

type ImportPipelineRequest struct {
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

type ImportPipelineResponse struct {
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

type Info struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Os      string `protobuf:"bytes,2,opt,name=os,proto3" json:"os,omitempty"`
	Arch    string `protobuf:"bytes,3,opt,name=arch,proto3" json:"arch,omitempty"`
	// contains filtered or unexported fields
}

type InformationServiceClient interface {
	GetInfo(ctx context.Context, in *GetInfoRequest, opts ...grpc.CallOption) (*GetInfoResponse, error)
}

type InformationServiceServer interface {
	GetInfo(context.Context, *GetInfoRequest) (*GetInfoResponse, error)
	// contains filtered or unexported methods
}

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

type InspectConnectorResponse struct {
	Record *v11.Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

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

type InspectProcessorInResponse struct {
	Record *v11.Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

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

type InspectProcessorOutResponse struct {
	Record *v11.Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

type ListConnectorPluginsRequest struct {

	// Regex to filter plugins by name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type ListConnectorPluginsResponse struct {
	Plugins []*ConnectorPluginSpecifications `protobuf:"bytes,1,rep,name=plugins,proto3" json:"plugins,omitempty"`
	// contains filtered or unexported fields
}

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

type ListConnectorsResponse struct {
	Connectors []*Connector `protobuf:"bytes,1,rep,name=connectors,proto3" json:"connectors,omitempty"`
	// contains filtered or unexported fields
}

type ListPipelinesRequest struct {

	// Regex to filter pipelines by name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type ListPipelinesResponse struct {
	Pipelines []*Pipeline `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"`
	// contains filtered or unexported fields
}

type ListProcessorPluginsRequest struct {

	// Regex to filter plugins by name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type ListProcessorPluginsResponse struct {
	Plugins []*ProcessorPluginSpecifications `protobuf:"bytes,1,rep,name=plugins,proto3" json:"plugins,omitempty"`
	// contains filtered or unexported fields
}

type ListProcessorsRequest struct {
	ParentIds []string `protobuf:"bytes,1,rep,name=parent_ids,json=parentIds,proto3" json:"parent_ids,omitempty"`
	// contains filtered or unexported fields
}

type ListProcessorsResponse struct {
	Processors []*Processor `protobuf:"bytes,1,rep,name=processors,proto3" json:"processors,omitempty"`
	// contains filtered or unexported fields
}

type Pipeline struct {
	Id           string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State        *Pipeline_State        `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	Config       *Pipeline_Config       `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	ConnectorIds []string               `protobuf:"bytes,5,rep,name=connector_ids,json=connectorIds,proto3" json:"connector_ids,omitempty"`
	ProcessorIds []string               `protobuf:"bytes,6,rep,name=processor_ids,json=processorIds,proto3" json:"processor_ids,omitempty"`
	CreatedAt    *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt    *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

type PipelineServiceClient interface {
	ListPipelines(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (*ListPipelinesResponse, error)
	CreatePipeline(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*CreatePipelineResponse, error)
	GetPipeline(ctx context.Context, in *GetPipelineRequest, opts ...grpc.CallOption) (*GetPipelineResponse, error)
	UpdatePipeline(ctx context.Context, in *UpdatePipelineRequest, opts ...grpc.CallOption) (*UpdatePipelineResponse, error)
	DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*DeletePipelineResponse, error)
	StartPipeline(ctx context.Context, in *StartPipelineRequest, opts ...grpc.CallOption) (*StartPipelineResponse, error)
	StopPipeline(ctx context.Context, in *StopPipelineRequest, opts ...grpc.CallOption) (*StopPipelineResponse, error)
	GetDLQ(ctx context.Context, in *GetDLQRequest, opts ...grpc.CallOption) (*GetDLQResponse, error)
	UpdateDLQ(ctx context.Context, in *UpdateDLQRequest, opts ...grpc.CallOption) (*UpdateDLQResponse, error)
	ExportPipeline(ctx context.Context, in *ExportPipelineRequest, opts ...grpc.CallOption) (*ExportPipelineResponse, error)
	ImportPipeline(ctx context.Context, in *ImportPipelineRequest, opts ...grpc.CallOption) (*ImportPipelineResponse, error)
}

type PipelineServiceServer interface {
	ListPipelines(context.Context, *ListPipelinesRequest) (*ListPipelinesResponse, error)
	CreatePipeline(context.Context, *CreatePipelineRequest) (*CreatePipelineResponse, error)
	GetPipeline(context.Context, *GetPipelineRequest) (*GetPipelineResponse, error)
	UpdatePipeline(context.Context, *UpdatePipelineRequest) (*UpdatePipelineResponse, error)
	DeletePipeline(context.Context, *DeletePipelineRequest) (*DeletePipelineResponse, error)
	StartPipeline(context.Context, *StartPipelineRequest) (*StartPipelineResponse, error)
	StopPipeline(context.Context, *StopPipelineRequest) (*StopPipelineResponse, error)
	GetDLQ(context.Context, *GetDLQRequest) (*GetDLQResponse, error)
	UpdateDLQ(context.Context, *UpdateDLQRequest) (*UpdateDLQResponse, error)
	ExportPipeline(context.Context, *ExportPipelineRequest) (*ExportPipelineResponse, error)
	ImportPipeline(context.Context, *ImportPipelineRequest) (*ImportPipelineResponse, error)
	// contains filtered or unexported methods
}

type Pipeline_Config 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"`
	// contains filtered or unexported fields
}

type Pipeline_DLQ struct {

	// plugin is the connector plugin used for storing DLQ records
	// default = builtin:log, configured to log with level WARN
	Plugin string `protobuf:"bytes,1,opt,name=plugin,proto3" json:"plugin,omitempty"`
	// settings are the plugin settings
	Settings map[string]string `` /* 157-byte string literal not displayed */
	// window_size defines how many last acks/nacks are monitored in the window
	// that controls if the pipeline should stop (0 disables the window)
	// default = 1
	WindowSize uint64 `protobuf:"varint,3,opt,name=window_size,json=windowSize,proto3" json:"window_size,omitempty"`
	// window_nack_threshold defines the number of nacks in the window that are
	// tolerated. Crossing the threshold stops the pipeline.
	// default = 0
	WindowNackThreshold uint64 `protobuf:"varint,4,opt,name=window_nack_threshold,json=windowNackThreshold,proto3" json:"window_nack_threshold,omitempty"`
	// contains filtered or unexported fields
}

type Pipeline_State struct {
	Status Pipeline_Status `protobuf:"varint,1,opt,name=status,proto3,enum=api.v1.Pipeline_Status" json:"status,omitempty"`
	// Error message when pipeline status is STATUS_DEGRADED.
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type Pipeline_Status int32

type PluginServiceClient interface {
	// Deprecated: Do not use.
	// Deprecated: use ConnectorService.ListConnectorPlugins instead.
	ListPlugins(ctx context.Context, in *ListPluginsRequest, opts ...grpc.CallOption) (*ListPluginsResponse, error)
}

type PluginServiceServer interface {
	// Deprecated: Do not use.
	// Deprecated: use ConnectorService.ListConnectorPlugins instead.
	ListPlugins(context.Context, *ListPluginsRequest) (*ListPluginsResponse, error)
	// contains filtered or unexported methods
}