apiv1

package
v0.11.0-nightly.20240712 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 11, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Overview

Package apiv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	PipelineService_ListPipelines_FullMethodName  = "/api.v1.PipelineService/ListPipelines"
	PipelineService_CreatePipeline_FullMethodName = "/api.v1.PipelineService/CreatePipeline"
	PipelineService_GetPipeline_FullMethodName    = "/api.v1.PipelineService/GetPipeline"
	PipelineService_UpdatePipeline_FullMethodName = "/api.v1.PipelineService/UpdatePipeline"
	PipelineService_DeletePipeline_FullMethodName = "/api.v1.PipelineService/DeletePipeline"
	PipelineService_StartPipeline_FullMethodName  = "/api.v1.PipelineService/StartPipeline"
	PipelineService_StopPipeline_FullMethodName   = "/api.v1.PipelineService/StopPipeline"
	PipelineService_GetDLQ_FullMethodName         = "/api.v1.PipelineService/GetDLQ"
	PipelineService_UpdateDLQ_FullMethodName      = "/api.v1.PipelineService/UpdateDLQ"
	PipelineService_ExportPipeline_FullMethodName = "/api.v1.PipelineService/ExportPipeline"
	PipelineService_ImportPipeline_FullMethodName = "/api.v1.PipelineService/ImportPipeline"
)
View Source 
const (
	ConnectorService_ListConnectors_FullMethodName       = "/api.v1.ConnectorService/ListConnectors"
	ConnectorService_InspectConnector_FullMethodName     = "/api.v1.ConnectorService/InspectConnector"
	ConnectorService_GetConnector_FullMethodName         = "/api.v1.ConnectorService/GetConnector"
	ConnectorService_CreateConnector_FullMethodName      = "/api.v1.ConnectorService/CreateConnector"
	ConnectorService_ValidateConnector_FullMethodName    = "/api.v1.ConnectorService/ValidateConnector"
	ConnectorService_UpdateConnector_FullMethodName      = "/api.v1.ConnectorService/UpdateConnector"
	ConnectorService_DeleteConnector_FullMethodName      = "/api.v1.ConnectorService/DeleteConnector"
	ConnectorService_ListConnectorPlugins_FullMethodName = "/api.v1.ConnectorService/ListConnectorPlugins"
)
View Source 
const (
	ProcessorService_ListProcessors_FullMethodName       = "/api.v1.ProcessorService/ListProcessors"
	ProcessorService_InspectProcessorIn_FullMethodName   = "/api.v1.ProcessorService/InspectProcessorIn"
	ProcessorService_InspectProcessorOut_FullMethodName  = "/api.v1.ProcessorService/InspectProcessorOut"
	ProcessorService_GetProcessor_FullMethodName         = "/api.v1.ProcessorService/GetProcessor"
	ProcessorService_CreateProcessor_FullMethodName      = "/api.v1.ProcessorService/CreateProcessor"
	ProcessorService_UpdateProcessor_FullMethodName      = "/api.v1.ProcessorService/UpdateProcessor"
	ProcessorService_DeleteProcessor_FullMethodName      = "/api.v1.ProcessorService/DeleteProcessor"
	ProcessorService_ListProcessorPlugins_FullMethodName = "/api.v1.ProcessorService/ListProcessorPlugins"
)
View Source 
const (
	InformationService_GetInfo_FullMethodName = "/api.v1.InformationService/GetInfo"
)
View Source 
const (
	PluginService_ListPlugins_FullMethodName = "/api.v1.PluginService/ListPlugins"
)

Variables

View Source 
var (
	Pipeline_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "STATUS_RUNNING",
		2: "STATUS_STOPPED",
		3: "STATUS_DEGRADED",
	}
	Pipeline_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"STATUS_RUNNING":     1,
		"STATUS_STOPPED":     2,
		"STATUS_DEGRADED":    3,
	}
)

Enum value maps for Pipeline_Status.

View Source 
var (
	Connector_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_SOURCE",
		2: "TYPE_DESTINATION",
	}
	Connector_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"TYPE_SOURCE":      1,
		"TYPE_DESTINATION": 2,
	}
)

Enum value maps for Connector_Type.

View Source 
var (
	Processor_Parent_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_CONNECTOR",
		2: "TYPE_PIPELINE",
	}
	Processor_Parent_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"TYPE_CONNECTOR":   1,
		"TYPE_PIPELINE":    2,
	}
)

Enum value maps for Processor_Parent_Type.

View Source 
var (
	PluginSpecifications_Parameter_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_STRING",
		2: "TYPE_INT",
		3: "TYPE_FLOAT",
		4: "TYPE_BOOL",
		5: "TYPE_FILE",
		6: "TYPE_DURATION",
	}
	PluginSpecifications_Parameter_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"TYPE_STRING":      1,
		"TYPE_INT":         2,
		"TYPE_FLOAT":       3,
		"TYPE_BOOL":        4,
		"TYPE_FILE":        5,
		"TYPE_DURATION":    6,
	}
)

Enum value maps for PluginSpecifications_Parameter_Type.

View Source 
var (
	PluginSpecifications_Parameter_Validation_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_REQUIRED",
		2: "TYPE_GREATER_THAN",
		3: "TYPE_LESS_THAN",
		4: "TYPE_INCLUSION",
		5: "TYPE_EXCLUSION",
		6: "TYPE_REGEX",
	}
	PluginSpecifications_Parameter_Validation_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED":  0,
		"TYPE_REQUIRED":     1,
		"TYPE_GREATER_THAN": 2,
		"TYPE_LESS_THAN":    3,
		"TYPE_INCLUSION":    4,
		"TYPE_EXCLUSION":    5,
		"TYPE_REGEX":        6,
	}
)

Enum value maps for PluginSpecifications_Parameter_Validation_Type.

View Source 
var ConnectorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.v1.ConnectorService",
	HandlerType: (*ConnectorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListConnectors",
			Handler:    _ConnectorService_ListConnectors_Handler,
		},
		{
			MethodName: "GetConnector",
			Handler:    _ConnectorService_GetConnector_Handler,
		},
		{
			MethodName: "CreateConnector",
			Handler:    _ConnectorService_CreateConnector_Handler,
		},
		{
			MethodName: "ValidateConnector",
			Handler:    _ConnectorService_ValidateConnector_Handler,
		},
		{
			MethodName: "UpdateConnector",
			Handler:    _ConnectorService_UpdateConnector_Handler,
		},
		{
			MethodName: "DeleteConnector",
			Handler:    _ConnectorService_DeleteConnector_Handler,
		},
		{
			MethodName: "ListConnectorPlugins",
			Handler:    _ConnectorService_ListConnectorPlugins_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "InspectConnector",
			Handler:       _ConnectorService_InspectConnector_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/v1/api.proto",
}

ConnectorService_ServiceDesc is the grpc.ServiceDesc for ConnectorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_api_v1_api_proto protoreflect.FileDescriptor
View Source 
var InformationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.v1.InformationService",
	HandlerType: (*InformationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetInfo",
			Handler:    _InformationService_GetInfo_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/api.proto",
}

InformationService_ServiceDesc is the grpc.ServiceDesc for InformationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var PipelineService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.v1.PipelineService",
	HandlerType: (*PipelineServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListPipelines",
			Handler:    _PipelineService_ListPipelines_Handler,
		},
		{
			MethodName: "CreatePipeline",
			Handler:    _PipelineService_CreatePipeline_Handler,
		},
		{
			MethodName: "GetPipeline",
			Handler:    _PipelineService_GetPipeline_Handler,
		},
		{
			MethodName: "UpdatePipeline",
			Handler:    _PipelineService_UpdatePipeline_Handler,
		},
		{
			MethodName: "DeletePipeline",
			Handler:    _PipelineService_DeletePipeline_Handler,
		},
		{
			MethodName: "StartPipeline",
			Handler:    _PipelineService_StartPipeline_Handler,
		},
		{
			MethodName: "StopPipeline",
			Handler:    _PipelineService_StopPipeline_Handler,
		},
		{
			MethodName: "GetDLQ",
			Handler:    _PipelineService_GetDLQ_Handler,
		},
		{
			MethodName: "UpdateDLQ",
			Handler:    _PipelineService_UpdateDLQ_Handler,
		},
		{
			MethodName: "ExportPipeline",
			Handler:    _PipelineService_ExportPipeline_Handler,
		},
		{
			MethodName: "ImportPipeline",
			Handler:    _PipelineService_ImportPipeline_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/api.proto",
}

PipelineService_ServiceDesc is the grpc.ServiceDesc for PipelineService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var PluginService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.v1.PluginService",
	HandlerType: (*PluginServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListPlugins",
			Handler:    _PluginService_ListPlugins_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/api.proto",
}

PluginService_ServiceDesc is the grpc.ServiceDesc for PluginService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var ProcessorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.v1.ProcessorService",
	HandlerType: (*ProcessorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListProcessors",
			Handler:    _ProcessorService_ListProcessors_Handler,
		},
		{
			MethodName: "GetProcessor",
			Handler:    _ProcessorService_GetProcessor_Handler,
		},
		{
			MethodName: "CreateProcessor",
			Handler:    _ProcessorService_CreateProcessor_Handler,
		},
		{
			MethodName: "UpdateProcessor",
			Handler:    _ProcessorService_UpdateProcessor_Handler,
		},
		{
			MethodName: "DeleteProcessor",
			Handler:    _ProcessorService_DeleteProcessor_Handler,
		},
		{
			MethodName: "ListProcessorPlugins",
			Handler:    _ProcessorService_ListProcessorPlugins_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "InspectProcessorIn",
			Handler:       _ProcessorService_InspectProcessorIn_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "InspectProcessorOut",
			Handler:       _ProcessorService_InspectProcessorOut_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/v1/api.proto",
}

ProcessorService_ServiceDesc is the grpc.ServiceDesc for ProcessorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterConnectorServiceHandler 

func RegisterConnectorServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterConnectorServiceHandler registers the http handlers for service ConnectorService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterConnectorServiceHandlerClient 

func RegisterConnectorServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ConnectorServiceClient) error

RegisterConnectorServiceHandlerClient registers the http handlers for service ConnectorService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ConnectorServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ConnectorServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ConnectorServiceClient" to call the correct interceptors.

func RegisterConnectorServiceHandlerFromEndpoint 

func RegisterConnectorServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterConnectorServiceHandlerFromEndpoint is same as RegisterConnectorServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterConnectorServiceHandlerServer 

func RegisterConnectorServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ConnectorServiceServer) error

RegisterConnectorServiceHandlerServer registers the http handlers for service ConnectorService to "mux". UnaryRPC :call ConnectorServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterConnectorServiceHandlerFromEndpoint instead.

func RegisterConnectorServiceServer 

func RegisterConnectorServiceServer(s grpc.ServiceRegistrar, srv ConnectorServiceServer)

func RegisterInformationServiceHandler 

func RegisterInformationServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterInformationServiceHandler registers the http handlers for service InformationService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterInformationServiceHandlerClient 

func RegisterInformationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client InformationServiceClient) error

RegisterInformationServiceHandlerClient registers the http handlers for service InformationService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "InformationServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "InformationServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "InformationServiceClient" to call the correct interceptors.

func RegisterInformationServiceHandlerFromEndpoint 

func RegisterInformationServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterInformationServiceHandlerFromEndpoint is same as RegisterInformationServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterInformationServiceHandlerServer 

func RegisterInformationServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server InformationServiceServer) error

RegisterInformationServiceHandlerServer registers the http handlers for service InformationService to "mux". UnaryRPC :call InformationServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterInformationServiceHandlerFromEndpoint instead.

func RegisterInformationServiceServer 

func RegisterInformationServiceServer(s grpc.ServiceRegistrar, srv InformationServiceServer)

func RegisterPipelineServiceHandler 

func RegisterPipelineServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterPipelineServiceHandler registers the http handlers for service PipelineService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterPipelineServiceHandlerClient 

func RegisterPipelineServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PipelineServiceClient) error

RegisterPipelineServiceHandlerClient registers the http handlers for service PipelineService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "PipelineServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "PipelineServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "PipelineServiceClient" to call the correct interceptors.

func RegisterPipelineServiceHandlerFromEndpoint 

func RegisterPipelineServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterPipelineServiceHandlerFromEndpoint is same as RegisterPipelineServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterPipelineServiceHandlerServer 

func RegisterPipelineServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PipelineServiceServer) error

RegisterPipelineServiceHandlerServer registers the http handlers for service PipelineService to "mux". UnaryRPC :call PipelineServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterPipelineServiceHandlerFromEndpoint instead.

func RegisterPipelineServiceServer 

func RegisterPipelineServiceServer(s grpc.ServiceRegistrar, srv PipelineServiceServer)

func RegisterPluginServiceHandler added in v0.2.0 

func RegisterPluginServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterPluginServiceHandler registers the http handlers for service PluginService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterPluginServiceHandlerClient added in v0.2.0 

func RegisterPluginServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PluginServiceClient) error

RegisterPluginServiceHandlerClient registers the http handlers for service PluginService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "PluginServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "PluginServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "PluginServiceClient" to call the correct interceptors.

func RegisterPluginServiceHandlerFromEndpoint added in v0.2.0 

func RegisterPluginServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterPluginServiceHandlerFromEndpoint is same as RegisterPluginServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterPluginServiceHandlerServer added in v0.2.0 

func RegisterPluginServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PluginServiceServer) error

RegisterPluginServiceHandlerServer registers the http handlers for service PluginService to "mux". UnaryRPC :call PluginServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterPluginServiceHandlerFromEndpoint instead.

func RegisterPluginServiceServer added in v0.2.0 

func RegisterPluginServiceServer(s grpc.ServiceRegistrar, srv PluginServiceServer)

func RegisterProcessorServiceHandler 

func RegisterProcessorServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterProcessorServiceHandler registers the http handlers for service ProcessorService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterProcessorServiceHandlerClient 

func RegisterProcessorServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ProcessorServiceClient) error

RegisterProcessorServiceHandlerClient registers the http handlers for service ProcessorService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ProcessorServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ProcessorServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ProcessorServiceClient" to call the correct interceptors.

func RegisterProcessorServiceHandlerFromEndpoint 

func RegisterProcessorServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterProcessorServiceHandlerFromEndpoint is same as RegisterProcessorServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterProcessorServiceHandlerServer 

func RegisterProcessorServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ProcessorServiceServer) error

RegisterProcessorServiceHandlerServer registers the http handlers for service ProcessorService to "mux". UnaryRPC :call ProcessorServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterProcessorServiceHandlerFromEndpoint instead.

func RegisterProcessorServiceServer 

func RegisterProcessorServiceServer(s grpc.ServiceRegistrar, srv ProcessorServiceServer)

Types

type Connector 

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
}

func (*Connector) Descriptor deprecated 

func (*Connector) Descriptor() ([]byte, []int)

Deprecated: Use Connector.ProtoReflect.Descriptor instead.

func (*Connector) GetConfig 

func (x *Connector) GetConfig() *Connector_Config

func (*Connector) GetCreatedAt added in v0.2.1 

func (x *Connector) GetCreatedAt() *timestamppb.Timestamp

func (*Connector) GetDestinationState 

func (x *Connector) GetDestinationState() *Connector_DestinationState

func (*Connector) GetId 

func (x *Connector) GetId() string

func (*Connector) GetPipelineId 

func (x *Connector) GetPipelineId() string

func (*Connector) GetPlugin 

func (x *Connector) GetPlugin() string

func (*Connector) GetProcessorIds 

func (x *Connector) GetProcessorIds() []string

func (*Connector) GetSourceState 

func (x *Connector) GetSourceState() *Connector_SourceState

func (*Connector) GetState 

func (m *Connector) GetState() isConnector_State

func (*Connector) GetType 

func (x *Connector) GetType() Connector_Type

func (*Connector) GetUpdatedAt added in v0.2.1 

func (x *Connector) GetUpdatedAt() *timestamppb.Timestamp

func (*Connector) ProtoMessage 

func (*Connector) ProtoMessage()

func (*Connector) ProtoReflect 

func (x *Connector) ProtoReflect() protoreflect.Message

func (*Connector) Reset 

func (x *Connector) Reset()

func (*Connector) String 

func (x *Connector) String() string

type ConnectorPluginSpecifications added in v0.9.0 

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
}

ConnectorPluginSpecifications describes the specifications of a connector plugin.

func (*ConnectorPluginSpecifications) Descriptor deprecated added in v0.9.0 

func (*ConnectorPluginSpecifications) Descriptor() ([]byte, []int)

Deprecated: Use ConnectorPluginSpecifications.ProtoReflect.Descriptor instead.

func (*ConnectorPluginSpecifications) GetAuthor added in v0.9.0 

func (x *ConnectorPluginSpecifications) GetAuthor() string

func (*ConnectorPluginSpecifications) GetDescription added in v0.9.0 

func (x *ConnectorPluginSpecifications) GetDescription() string

func (*ConnectorPluginSpecifications) GetDestinationParams added in v0.9.0 

func (x *ConnectorPluginSpecifications) GetDestinationParams() map[string]*v1.Parameter

func (*ConnectorPluginSpecifications) GetName added in v0.9.0 

func (x *ConnectorPluginSpecifications) GetName() string

func (*ConnectorPluginSpecifications) GetSourceParams added in v0.9.0 

func (x *ConnectorPluginSpecifications) GetSourceParams() map[string]*v1.Parameter

func (*ConnectorPluginSpecifications) GetSummary added in v0.9.0 

func (x *ConnectorPluginSpecifications) GetSummary() string

func (*ConnectorPluginSpecifications) GetVersion added in v0.9.0 

func (x *ConnectorPluginSpecifications) GetVersion() string

func (*ConnectorPluginSpecifications) ProtoMessage added in v0.9.0 

func (*ConnectorPluginSpecifications) ProtoMessage()

func (*ConnectorPluginSpecifications) ProtoReflect added in v0.9.0 

func (x *ConnectorPluginSpecifications) ProtoReflect() protoreflect.Message

func (*ConnectorPluginSpecifications) Reset added in v0.9.0 

func (x *ConnectorPluginSpecifications) Reset()

func (*ConnectorPluginSpecifications) String added in v0.9.0 

func (x *ConnectorPluginSpecifications) String() string

type ConnectorServiceClient 

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)
}

ConnectorServiceClient is the client API for ConnectorService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

ConnectorService exposes CRUD functionality for managing connectors.

func NewConnectorServiceClient 

func NewConnectorServiceClient(cc grpc.ClientConnInterface) ConnectorServiceClient

type ConnectorServiceServer 

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
}

ConnectorServiceServer is the server API for ConnectorService service. All implementations must embed UnimplementedConnectorServiceServer for forward compatibility

ConnectorService exposes CRUD functionality for managing connectors.

type ConnectorService_InspectConnectorClient added in v0.6.0 

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

type ConnectorService_InspectConnectorServer added in v0.6.0 

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

type Connector_Config 

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
}

func (*Connector_Config) Descriptor deprecated 

func (*Connector_Config) Descriptor() ([]byte, []int)

Deprecated: Use Connector_Config.ProtoReflect.Descriptor instead.

func (*Connector_Config) GetName 

func (x *Connector_Config) GetName() string

func (*Connector_Config) GetSettings 

func (x *Connector_Config) GetSettings() map[string]string

func (*Connector_Config) ProtoMessage 

func (*Connector_Config) ProtoMessage()

func (*Connector_Config) ProtoReflect 

func (x *Connector_Config) ProtoReflect() protoreflect.Message

func (*Connector_Config) Reset 

func (x *Connector_Config) Reset()

func (*Connector_Config) String 

func (x *Connector_Config) String() string

type Connector_DestinationState 

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

func (*Connector_DestinationState) Descriptor deprecated 

func (*Connector_DestinationState) Descriptor() ([]byte, []int)

Deprecated: Use Connector_DestinationState.ProtoReflect.Descriptor instead.

func (*Connector_DestinationState) GetPositions 

func (x *Connector_DestinationState) GetPositions() map[string][]byte

func (*Connector_DestinationState) ProtoMessage 

func (*Connector_DestinationState) ProtoMessage()

func (*Connector_DestinationState) ProtoReflect 

func (x *Connector_DestinationState) ProtoReflect() protoreflect.Message

func (*Connector_DestinationState) Reset 

func (x *Connector_DestinationState) Reset()

func (*Connector_DestinationState) String 

func (x *Connector_DestinationState) String() string

type Connector_DestinationState_ 

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

type Connector_SourceState 

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

func (*Connector_SourceState) Descriptor deprecated 

func (*Connector_SourceState) Descriptor() ([]byte, []int)

Deprecated: Use Connector_SourceState.ProtoReflect.Descriptor instead.

func (*Connector_SourceState) GetPosition 

func (x *Connector_SourceState) GetPosition() []byte

func (*Connector_SourceState) ProtoMessage 

func (*Connector_SourceState) ProtoMessage()

func (*Connector_SourceState) ProtoReflect 

func (x *Connector_SourceState) ProtoReflect() protoreflect.Message

func (*Connector_SourceState) Reset 

func (x *Connector_SourceState) Reset()

func (*Connector_SourceState) String 

func (x *Connector_SourceState) String() string

type Connector_SourceState_ 

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

type Connector_Type 

type Connector_Type int32

Type shows the connector type. 

const (
	Connector_TYPE_UNSPECIFIED Connector_Type = 0
	// Connector is a source.
	Connector_TYPE_SOURCE Connector_Type = 1
	// Connector is a destination.
	Connector_TYPE_DESTINATION Connector_Type = 2
)

func (Connector_Type) Descriptor 

func (Connector_Type) Descriptor() protoreflect.EnumDescriptor

func (Connector_Type) Enum 

func (x Connector_Type) Enum() *Connector_Type

func (Connector_Type) EnumDescriptor deprecated 

func (Connector_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Connector_Type.Descriptor instead.

func (Connector_Type) Number 

func (x Connector_Type) Number() protoreflect.EnumNumber

func (Connector_Type) String 

func (x Connector_Type) String() string

func (Connector_Type) Type 

func (Connector_Type) Type() protoreflect.EnumType

type CreateConnectorRequest 

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
}

func (*CreateConnectorRequest) Descriptor deprecated 

func (*CreateConnectorRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateConnectorRequest.ProtoReflect.Descriptor instead.

func (*CreateConnectorRequest) GetConfig 

func (x *CreateConnectorRequest) GetConfig() *Connector_Config

func (*CreateConnectorRequest) GetPipelineId 

func (x *CreateConnectorRequest) GetPipelineId() string

func (*CreateConnectorRequest) GetPlugin 

func (x *CreateConnectorRequest) GetPlugin() string

func (*CreateConnectorRequest) GetType 

func (x *CreateConnectorRequest) GetType() Connector_Type

func (*CreateConnectorRequest) ProtoMessage 

func (*CreateConnectorRequest) ProtoMessage()

func (*CreateConnectorRequest) ProtoReflect 

func (x *CreateConnectorRequest) ProtoReflect() protoreflect.Message

func (*CreateConnectorRequest) Reset 

func (x *CreateConnectorRequest) Reset()

func (*CreateConnectorRequest) String 

func (x *CreateConnectorRequest) String() string

type CreateConnectorResponse 

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

func (*CreateConnectorResponse) Descriptor deprecated 

func (*CreateConnectorResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateConnectorResponse.ProtoReflect.Descriptor instead.

func (*CreateConnectorResponse) GetConnector 

func (x *CreateConnectorResponse) GetConnector() *Connector

func (*CreateConnectorResponse) ProtoMessage 

func (*CreateConnectorResponse) ProtoMessage()

func (*CreateConnectorResponse) ProtoReflect 

func (x *CreateConnectorResponse) ProtoReflect() protoreflect.Message

func (*CreateConnectorResponse) Reset 

func (x *CreateConnectorResponse) Reset()

func (*CreateConnectorResponse) String 

func (x *CreateConnectorResponse) String() string

type CreatePipelineRequest 

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

func (*CreatePipelineRequest) Descriptor deprecated 

func (*CreatePipelineRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreatePipelineRequest.ProtoReflect.Descriptor instead.

func (*CreatePipelineRequest) GetConfig 

func (x *CreatePipelineRequest) GetConfig() *Pipeline_Config

func (*CreatePipelineRequest) ProtoMessage 

func (*CreatePipelineRequest) ProtoMessage()

func (*CreatePipelineRequest) ProtoReflect 

func (x *CreatePipelineRequest) ProtoReflect() protoreflect.Message

func (*CreatePipelineRequest) Reset 

func (x *CreatePipelineRequest) Reset()

func (*CreatePipelineRequest) String 

func (x *CreatePipelineRequest) String() string

type CreatePipelineResponse 

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

func (*CreatePipelineResponse) Descriptor deprecated 

func (*CreatePipelineResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreatePipelineResponse.ProtoReflect.Descriptor instead.

func (*CreatePipelineResponse) GetPipeline 

func (x *CreatePipelineResponse) GetPipeline() *Pipeline

func (*CreatePipelineResponse) ProtoMessage 

func (*CreatePipelineResponse) ProtoMessage()

func (*CreatePipelineResponse) ProtoReflect 

func (x *CreatePipelineResponse) ProtoReflect() protoreflect.Message

func (*CreatePipelineResponse) Reset 

func (x *CreatePipelineResponse) Reset()

func (*CreatePipelineResponse) String 

func (x *CreatePipelineResponse) String() string

type CreateProcessorRequest 

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
}

func (*CreateProcessorRequest) Descriptor deprecated 

func (*CreateProcessorRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateProcessorRequest.ProtoReflect.Descriptor instead.

func (*CreateProcessorRequest) GetCondition added in v0.8.1 

func (x *CreateProcessorRequest) GetCondition() string

func (*CreateProcessorRequest) GetConfig 

func (x *CreateProcessorRequest) GetConfig() *Processor_Config

func (*CreateProcessorRequest) GetParent 

func (x *CreateProcessorRequest) GetParent() *Processor_Parent

func (*CreateProcessorRequest) GetPlugin added in v0.9.0 

func (x *CreateProcessorRequest) GetPlugin() string

func (*CreateProcessorRequest) GetType deprecated 

func (x *CreateProcessorRequest) GetType() string

Deprecated: Marked as deprecated in api/v1/api.proto.

func (*CreateProcessorRequest) ProtoMessage 

func (*CreateProcessorRequest) ProtoMessage()

func (*CreateProcessorRequest) ProtoReflect 

func (x *CreateProcessorRequest) ProtoReflect() protoreflect.Message

func (*CreateProcessorRequest) Reset 

func (x *CreateProcessorRequest) Reset()

func (*CreateProcessorRequest) String 

func (x *CreateProcessorRequest) String() string

type CreateProcessorResponse 

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

func (*CreateProcessorResponse) Descriptor deprecated 

func (*CreateProcessorResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateProcessorResponse.ProtoReflect.Descriptor instead.

func (*CreateProcessorResponse) GetProcessor 

func (x *CreateProcessorResponse) GetProcessor() *Processor

func (*CreateProcessorResponse) ProtoMessage 

func (*CreateProcessorResponse) ProtoMessage()

func (*CreateProcessorResponse) ProtoReflect 

func (x *CreateProcessorResponse) ProtoReflect() protoreflect.Message

func (*CreateProcessorResponse) Reset 

func (x *CreateProcessorResponse) Reset()

func (*CreateProcessorResponse) String 

func (x *CreateProcessorResponse) String() string

type DeleteConnectorRequest 

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

func (*DeleteConnectorRequest) Descriptor deprecated 

func (*DeleteConnectorRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteConnectorRequest.ProtoReflect.Descriptor instead.

func (*DeleteConnectorRequest) GetId 

func (x *DeleteConnectorRequest) GetId() string

func (*DeleteConnectorRequest) ProtoMessage 

func (*DeleteConnectorRequest) ProtoMessage()

func (*DeleteConnectorRequest) ProtoReflect 

func (x *DeleteConnectorRequest) ProtoReflect() protoreflect.Message

func (*DeleteConnectorRequest) Reset 

func (x *DeleteConnectorRequest) Reset()

func (*DeleteConnectorRequest) String 

func (x *DeleteConnectorRequest) String() string

type DeleteConnectorResponse 

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

func (*DeleteConnectorResponse) Descriptor deprecated 

func (*DeleteConnectorResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteConnectorResponse.ProtoReflect.Descriptor instead.

func (*DeleteConnectorResponse) ProtoMessage 

func (*DeleteConnectorResponse) ProtoMessage()

func (*DeleteConnectorResponse) ProtoReflect 

func (x *DeleteConnectorResponse) ProtoReflect() protoreflect.Message

func (*DeleteConnectorResponse) Reset 

func (x *DeleteConnectorResponse) Reset()

func (*DeleteConnectorResponse) String 

func (x *DeleteConnectorResponse) String() string

type DeletePipelineRequest 

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

func (*DeletePipelineRequest) Descriptor deprecated 

func (*DeletePipelineRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeletePipelineRequest.ProtoReflect.Descriptor instead.

func (*DeletePipelineRequest) GetId 

func (x *DeletePipelineRequest) GetId() string

func (*DeletePipelineRequest) ProtoMessage 

func (*DeletePipelineRequest) ProtoMessage()

func (*DeletePipelineRequest) ProtoReflect 

func (x *DeletePipelineRequest) ProtoReflect() protoreflect.Message

func (*DeletePipelineRequest) Reset 

func (x *DeletePipelineRequest) Reset()

func (*DeletePipelineRequest) String 

func (x *DeletePipelineRequest) String() string

type DeletePipelineResponse 

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

func (*DeletePipelineResponse) Descriptor deprecated 

func (*DeletePipelineResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeletePipelineResponse.ProtoReflect.Descriptor instead.

func (*DeletePipelineResponse) ProtoMessage 

func (*DeletePipelineResponse) ProtoMessage()

func (*DeletePipelineResponse) ProtoReflect 

func (x *DeletePipelineResponse) ProtoReflect() protoreflect.Message

func (*DeletePipelineResponse) Reset 

func (x *DeletePipelineResponse) Reset()

func (*DeletePipelineResponse) String 

func (x *DeletePipelineResponse) String() string

type DeleteProcessorRequest 

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

func (*DeleteProcessorRequest) Descriptor deprecated 

func (*DeleteProcessorRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteProcessorRequest.ProtoReflect.Descriptor instead.

func (*DeleteProcessorRequest) GetId 

func (x *DeleteProcessorRequest) GetId() string

func (*DeleteProcessorRequest) ProtoMessage 

func (*DeleteProcessorRequest) ProtoMessage()

func (*DeleteProcessorRequest) ProtoReflect 

func (x *DeleteProcessorRequest) ProtoReflect() protoreflect.Message

func (*DeleteProcessorRequest) Reset 

func (x *DeleteProcessorRequest) Reset()

func (*DeleteProcessorRequest) String 

func (x *DeleteProcessorRequest) String() string

type DeleteProcessorResponse 

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

func (*DeleteProcessorResponse) Descriptor deprecated 

func (*DeleteProcessorResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteProcessorResponse.ProtoReflect.Descriptor instead.

func (*DeleteProcessorResponse) ProtoMessage 

func (*DeleteProcessorResponse) ProtoMessage()

func (*DeleteProcessorResponse) ProtoReflect 

func (x *DeleteProcessorResponse) ProtoReflect() protoreflect.Message

func (*DeleteProcessorResponse) Reset 

func (x *DeleteProcessorResponse) Reset()

func (*DeleteProcessorResponse) String 

func (x *DeleteProcessorResponse) String() string

type ExportPipelineRequest 

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

func (*ExportPipelineRequest) Descriptor deprecated 

func (*ExportPipelineRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExportPipelineRequest.ProtoReflect.Descriptor instead.

func (*ExportPipelineRequest) GetId 

func (x *ExportPipelineRequest) GetId() string

func (*ExportPipelineRequest) ProtoMessage 

func (*ExportPipelineRequest) ProtoMessage()

func (*ExportPipelineRequest) ProtoReflect 

func (x *ExportPipelineRequest) ProtoReflect() protoreflect.Message

func (*ExportPipelineRequest) Reset 

func (x *ExportPipelineRequest) Reset()

func (*ExportPipelineRequest) String 

func (x *ExportPipelineRequest) String() string

type ExportPipelineResponse 

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

func (*ExportPipelineResponse) Descriptor deprecated 

func (*ExportPipelineResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExportPipelineResponse.ProtoReflect.Descriptor instead.

func (*ExportPipelineResponse) GetPipeline 

func (x *ExportPipelineResponse) GetPipeline() *Pipeline

func (*ExportPipelineResponse) ProtoMessage 

func (*ExportPipelineResponse) ProtoMessage()

func (*ExportPipelineResponse) ProtoReflect 

func (x *ExportPipelineResponse) ProtoReflect() protoreflect.Message

func (*ExportPipelineResponse) Reset 

func (x *ExportPipelineResponse) Reset()

func (*ExportPipelineResponse) String 

func (x *ExportPipelineResponse) String() string

type GetConnectorRequest 

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

func (*GetConnectorRequest) Descriptor deprecated 

func (*GetConnectorRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetConnectorRequest.ProtoReflect.Descriptor instead.

func (*GetConnectorRequest) GetId 

func (x *GetConnectorRequest) GetId() string

func (*GetConnectorRequest) ProtoMessage 

func (*GetConnectorRequest) ProtoMessage()

func (*GetConnectorRequest) ProtoReflect 

func (x *GetConnectorRequest) ProtoReflect() protoreflect.Message

func (*GetConnectorRequest) Reset 

func (x *GetConnectorRequest) Reset()

func (*GetConnectorRequest) String 

func (x *GetConnectorRequest) String() string

type GetConnectorResponse 

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

func (*GetConnectorResponse) Descriptor deprecated 

func (*GetConnectorResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetConnectorResponse.ProtoReflect.Descriptor instead.

func (*GetConnectorResponse) GetConnector 

func (x *GetConnectorResponse) GetConnector() *Connector

func (*GetConnectorResponse) ProtoMessage 

func (*GetConnectorResponse) ProtoMessage()

func (*GetConnectorResponse) ProtoReflect 

func (x *GetConnectorResponse) ProtoReflect() protoreflect.Message

func (*GetConnectorResponse) Reset 

func (x *GetConnectorResponse) Reset()

func (*GetConnectorResponse) String 

func (x *GetConnectorResponse) String() string

type GetDLQRequest added in v0.6.0 

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

func (*GetDLQRequest) Descriptor deprecated added in v0.6.0 

func (*GetDLQRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetDLQRequest.ProtoReflect.Descriptor instead.

func (*GetDLQRequest) GetId added in v0.6.0 

func (x *GetDLQRequest) GetId() string

func (*GetDLQRequest) ProtoMessage added in v0.6.0 

func (*GetDLQRequest) ProtoMessage()

func (*GetDLQRequest) ProtoReflect added in v0.6.0 

func (x *GetDLQRequest) ProtoReflect() protoreflect.Message

func (*GetDLQRequest) Reset added in v0.6.0 

func (x *GetDLQRequest) Reset()

func (*GetDLQRequest) String added in v0.6.0 

func (x *GetDLQRequest) String() string

type GetDLQResponse added in v0.6.0 

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

func (*GetDLQResponse) Descriptor deprecated added in v0.6.0 

func (*GetDLQResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetDLQResponse.ProtoReflect.Descriptor instead.

func (*GetDLQResponse) GetDlq added in v0.6.0 

func (x *GetDLQResponse) GetDlq() *Pipeline_DLQ

func (*GetDLQResponse) ProtoMessage added in v0.6.0 

func (*GetDLQResponse) ProtoMessage()

func (*GetDLQResponse) ProtoReflect added in v0.6.0 

func (x *GetDLQResponse) ProtoReflect() protoreflect.Message

func (*GetDLQResponse) Reset added in v0.6.0 

func (x *GetDLQResponse) Reset()

func (*GetDLQResponse) String added in v0.6.0 

func (x *GetDLQResponse) String() string

type GetInfoRequest 

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

func (*GetInfoRequest) Descriptor deprecated 

func (*GetInfoRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetInfoRequest.ProtoReflect.Descriptor instead.

func (*GetInfoRequest) ProtoMessage 

func (*GetInfoRequest) ProtoMessage()

func (*GetInfoRequest) ProtoReflect 

func (x *GetInfoRequest) ProtoReflect() protoreflect.Message

func (*GetInfoRequest) Reset 

func (x *GetInfoRequest) Reset()

func (*GetInfoRequest) String 

func (x *GetInfoRequest) String() string

type GetInfoResponse 

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

func (*GetInfoResponse) Descriptor deprecated 

func (*GetInfoResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetInfoResponse.ProtoReflect.Descriptor instead.

func (*GetInfoResponse) GetInfo 

func (x *GetInfoResponse) GetInfo() *Info

func (*GetInfoResponse) ProtoMessage 

func (*GetInfoResponse) ProtoMessage()

func (*GetInfoResponse) ProtoReflect 

func (x *GetInfoResponse) ProtoReflect() protoreflect.Message

func (*GetInfoResponse) Reset 

func (x *GetInfoResponse) Reset()

func (*GetInfoResponse) String 

func (x *GetInfoResponse) String() string

type GetPipelineRequest 

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

func (*GetPipelineRequest) Descriptor deprecated 

func (*GetPipelineRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetPipelineRequest.ProtoReflect.Descriptor instead.

func (*GetPipelineRequest) GetId 

func (x *GetPipelineRequest) GetId() string

func (*GetPipelineRequest) ProtoMessage 

func (*GetPipelineRequest) ProtoMessage()

func (*GetPipelineRequest) ProtoReflect 

func (x *GetPipelineRequest) ProtoReflect() protoreflect.Message

func (*GetPipelineRequest) Reset 

func (x *GetPipelineRequest) Reset()

func (*GetPipelineRequest) String 

func (x *GetPipelineRequest) String() string

type GetPipelineResponse 

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

func (*GetPipelineResponse) Descriptor deprecated 

func (*GetPipelineResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetPipelineResponse.ProtoReflect.Descriptor instead.

func (*GetPipelineResponse) GetPipeline 

func (x *GetPipelineResponse) GetPipeline() *Pipeline

func (*GetPipelineResponse) ProtoMessage 

func (*GetPipelineResponse) ProtoMessage()

func (*GetPipelineResponse) ProtoReflect 

func (x *GetPipelineResponse) ProtoReflect() protoreflect.Message

func (*GetPipelineResponse) Reset 

func (x *GetPipelineResponse) Reset()

func (*GetPipelineResponse) String 

func (x *GetPipelineResponse) String() string

type GetProcessorRequest 

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

func (*GetProcessorRequest) Descriptor deprecated 

func (*GetProcessorRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetProcessorRequest.ProtoReflect.Descriptor instead.

func (*GetProcessorRequest) GetId 

func (x *GetProcessorRequest) GetId() string

func (*GetProcessorRequest) ProtoMessage 

func (*GetProcessorRequest) ProtoMessage()

func (*GetProcessorRequest) ProtoReflect 

func (x *GetProcessorRequest) ProtoReflect() protoreflect.Message

func (*GetProcessorRequest) Reset 

func (x *GetProcessorRequest) Reset()

func (*GetProcessorRequest) String 

func (x *GetProcessorRequest) String() string

type GetProcessorResponse 

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

func (*GetProcessorResponse) Descriptor deprecated 

func (*GetProcessorResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetProcessorResponse.ProtoReflect.Descriptor instead.

func (*GetProcessorResponse) GetProcessor 

func (x *GetProcessorResponse) GetProcessor() *Processor

func (*GetProcessorResponse) ProtoMessage 

func (*GetProcessorResponse) ProtoMessage()

func (*GetProcessorResponse) ProtoReflect 

func (x *GetProcessorResponse) ProtoReflect() protoreflect.Message

func (*GetProcessorResponse) Reset 

func (x *GetProcessorResponse) Reset()

func (*GetProcessorResponse) String 

func (x *GetProcessorResponse) String() string

type ImportPipelineRequest 

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

func (*ImportPipelineRequest) Descriptor deprecated 

func (*ImportPipelineRequest) Descriptor() ([]byte, []int)

Deprecated: Use ImportPipelineRequest.ProtoReflect.Descriptor instead.

func (*ImportPipelineRequest) GetPipeline 

func (x *ImportPipelineRequest) GetPipeline() *Pipeline

func (*ImportPipelineRequest) ProtoMessage 

func (*ImportPipelineRequest) ProtoMessage()

func (*ImportPipelineRequest) ProtoReflect 

func (x *ImportPipelineRequest) ProtoReflect() protoreflect.Message

func (*ImportPipelineRequest) Reset 

func (x *ImportPipelineRequest) Reset()

func (*ImportPipelineRequest) String 

func (x *ImportPipelineRequest) String() string

type ImportPipelineResponse 

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

func (*ImportPipelineResponse) Descriptor deprecated 

func (*ImportPipelineResponse) Descriptor() ([]byte, []int)

Deprecated: Use ImportPipelineResponse.ProtoReflect.Descriptor instead.

func (*ImportPipelineResponse) GetPipeline 

func (x *ImportPipelineResponse) GetPipeline() *Pipeline

func (*ImportPipelineResponse) ProtoMessage 

func (*ImportPipelineResponse) ProtoMessage()

func (*ImportPipelineResponse) ProtoReflect 

func (x *ImportPipelineResponse) ProtoReflect() protoreflect.Message

func (*ImportPipelineResponse) Reset 

func (x *ImportPipelineResponse) Reset()

func (*ImportPipelineResponse) String 

func (x *ImportPipelineResponse) String() string

type Info 

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
}

func (*Info) Descriptor deprecated 

func (*Info) Descriptor() ([]byte, []int)

Deprecated: Use Info.ProtoReflect.Descriptor instead.

func (*Info) GetArch 

func (x *Info) GetArch() string

func (*Info) GetOs 

func (x *Info) GetOs() string

func (*Info) GetVersion 

func (x *Info) GetVersion() string

func (*Info) ProtoMessage 

func (*Info) ProtoMessage()

func (*Info) ProtoReflect 

func (x *Info) ProtoReflect() protoreflect.Message

func (*Info) Reset 

func (x *Info) Reset()

func (*Info) String 

func (x *Info) String() string

type InformationServiceClient 

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

InformationServiceClient is the client API for InformationService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewInformationServiceClient 

func NewInformationServiceClient(cc grpc.ClientConnInterface) InformationServiceClient

type InformationServiceServer 

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

InformationServiceServer is the server API for InformationService service. All implementations must embed UnimplementedInformationServiceServer for forward compatibility

type InspectConnectorRequest added in v0.6.0 

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

func (*InspectConnectorRequest) Descriptor deprecated added in v0.6.0 

func (*InspectConnectorRequest) Descriptor() ([]byte, []int)

Deprecated: Use InspectConnectorRequest.ProtoReflect.Descriptor instead.

func (*InspectConnectorRequest) GetId added in v0.6.0 

func (x *InspectConnectorRequest) GetId() string

func (*InspectConnectorRequest) ProtoMessage added in v0.6.0 

func (*InspectConnectorRequest) ProtoMessage()

func (*InspectConnectorRequest) ProtoReflect added in v0.6.0 

func (x *InspectConnectorRequest) ProtoReflect() protoreflect.Message

func (*InspectConnectorRequest) Reset added in v0.6.0 

func (x *InspectConnectorRequest) Reset()

func (*InspectConnectorRequest) String added in v0.6.0 

func (x *InspectConnectorRequest) String() string

type InspectConnectorResponse added in v0.6.0 

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

func (*InspectConnectorResponse) Descriptor deprecated added in v0.6.0 

func (*InspectConnectorResponse) Descriptor() ([]byte, []int)

Deprecated: Use InspectConnectorResponse.ProtoReflect.Descriptor instead.

func (*InspectConnectorResponse) GetRecord added in v0.6.0 

func (x *InspectConnectorResponse) GetRecord() *v11.Record

func (*InspectConnectorResponse) ProtoMessage added in v0.6.0 

func (*InspectConnectorResponse) ProtoMessage()

func (*InspectConnectorResponse) ProtoReflect added in v0.6.0 

func (x *InspectConnectorResponse) ProtoReflect() protoreflect.Message

func (*InspectConnectorResponse) Reset added in v0.6.0 

func (x *InspectConnectorResponse) Reset()

func (*InspectConnectorResponse) String added in v0.6.0 

func (x *InspectConnectorResponse) String() string

type InspectProcessorInRequest added in v0.6.0 

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

func (*InspectProcessorInRequest) Descriptor deprecated added in v0.6.0 

func (*InspectProcessorInRequest) Descriptor() ([]byte, []int)

Deprecated: Use InspectProcessorInRequest.ProtoReflect.Descriptor instead.

func (*InspectProcessorInRequest) GetId added in v0.6.0 

func (x *InspectProcessorInRequest) GetId() string

func (*InspectProcessorInRequest) ProtoMessage added in v0.6.0 

func (*InspectProcessorInRequest) ProtoMessage()

func (*InspectProcessorInRequest) ProtoReflect added in v0.6.0 

func (x *InspectProcessorInRequest) ProtoReflect() protoreflect.Message

func (*InspectProcessorInRequest) Reset added in v0.6.0 

func (x *InspectProcessorInRequest) Reset()

func (*InspectProcessorInRequest) String added in v0.6.0 

func (x *InspectProcessorInRequest) String() string

type InspectProcessorInResponse added in v0.6.0 

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

func (*InspectProcessorInResponse) Descriptor deprecated added in v0.6.0 

func (*InspectProcessorInResponse) Descriptor() ([]byte, []int)

Deprecated: Use InspectProcessorInResponse.ProtoReflect.Descriptor instead.

func (*InspectProcessorInResponse) GetRecord added in v0.6.0 

func (x *InspectProcessorInResponse) GetRecord() *v11.Record

func (*InspectProcessorInResponse) ProtoMessage added in v0.6.0 

func (*InspectProcessorInResponse) ProtoMessage()

func (*InspectProcessorInResponse) ProtoReflect added in v0.6.0 

func (x *InspectProcessorInResponse) ProtoReflect() protoreflect.Message

func (*InspectProcessorInResponse) Reset added in v0.6.0 

func (x *InspectProcessorInResponse) Reset()

func (*InspectProcessorInResponse) String added in v0.6.0 

func (x *InspectProcessorInResponse) String() string

type InspectProcessorOutRequest added in v0.6.0 

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

func (*InspectProcessorOutRequest) Descriptor deprecated added in v0.6.0 

func (*InspectProcessorOutRequest) Descriptor() ([]byte, []int)

Deprecated: Use InspectProcessorOutRequest.ProtoReflect.Descriptor instead.

func (*InspectProcessorOutRequest) GetId added in v0.6.0 

func (x *InspectProcessorOutRequest) GetId() string

func (*InspectProcessorOutRequest) ProtoMessage added in v0.6.0 

func (*InspectProcessorOutRequest) ProtoMessage()

func (*InspectProcessorOutRequest) ProtoReflect added in v0.6.0 

func (x *InspectProcessorOutRequest) ProtoReflect() protoreflect.Message

func (*InspectProcessorOutRequest) Reset added in v0.6.0 

func (x *InspectProcessorOutRequest) Reset()

func (*InspectProcessorOutRequest) String added in v0.6.0 

func (x *InspectProcessorOutRequest) String() string

type InspectProcessorOutResponse added in v0.6.0 

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

func (*InspectProcessorOutResponse) Descriptor deprecated added in v0.6.0 

func (*InspectProcessorOutResponse) Descriptor() ([]byte, []int)

Deprecated: Use InspectProcessorOutResponse.ProtoReflect.Descriptor instead.

func (*InspectProcessorOutResponse) GetRecord added in v0.6.0 

func (x *InspectProcessorOutResponse) GetRecord() *v11.Record

func (*InspectProcessorOutResponse) ProtoMessage added in v0.6.0 

func (*InspectProcessorOutResponse) ProtoMessage()

func (*InspectProcessorOutResponse) ProtoReflect added in v0.6.0 

func (x *InspectProcessorOutResponse) ProtoReflect() protoreflect.Message

func (*InspectProcessorOutResponse) Reset added in v0.6.0 

func (x *InspectProcessorOutResponse) Reset()

func (*InspectProcessorOutResponse) String added in v0.6.0 

func (x *InspectProcessorOutResponse) String() string

type ListConnectorPluginsRequest added in v0.9.0 

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
}

func (*ListConnectorPluginsRequest) Descriptor deprecated added in v0.9.0 

func (*ListConnectorPluginsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListConnectorPluginsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectorPluginsRequest) GetName added in v0.9.0 

func (x *ListConnectorPluginsRequest) GetName() string

func (*ListConnectorPluginsRequest) ProtoMessage added in v0.9.0 

func (*ListConnectorPluginsRequest) ProtoMessage()

func (*ListConnectorPluginsRequest) ProtoReflect added in v0.9.0 

func (x *ListConnectorPluginsRequest) ProtoReflect() protoreflect.Message

func (*ListConnectorPluginsRequest) Reset added in v0.9.0 

func (x *ListConnectorPluginsRequest) Reset()

func (*ListConnectorPluginsRequest) String added in v0.9.0 

func (x *ListConnectorPluginsRequest) String() string

type ListConnectorPluginsResponse added in v0.9.0 

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

func (*ListConnectorPluginsResponse) Descriptor deprecated added in v0.9.0 

func (*ListConnectorPluginsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListConnectorPluginsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectorPluginsResponse) GetPlugins added in v0.9.0 

func (x *ListConnectorPluginsResponse) GetPlugins() []*ConnectorPluginSpecifications

func (*ListConnectorPluginsResponse) ProtoMessage added in v0.9.0 

func (*ListConnectorPluginsResponse) ProtoMessage()

func (*ListConnectorPluginsResponse) ProtoReflect added in v0.9.0 

func (x *ListConnectorPluginsResponse) ProtoReflect() protoreflect.Message

func (*ListConnectorPluginsResponse) Reset added in v0.9.0 

func (x *ListConnectorPluginsResponse) Reset()

func (*ListConnectorPluginsResponse) String added in v0.9.0 

func (x *ListConnectorPluginsResponse) String() string

type ListConnectorsRequest 

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

func (*ListConnectorsRequest) Descriptor deprecated 

func (*ListConnectorsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListConnectorsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectorsRequest) GetPipelineId 

func (x *ListConnectorsRequest) GetPipelineId() string

func (*ListConnectorsRequest) ProtoMessage 

func (*ListConnectorsRequest) ProtoMessage()

func (*ListConnectorsRequest) ProtoReflect 

func (x *ListConnectorsRequest) ProtoReflect() protoreflect.Message

func (*ListConnectorsRequest) Reset 

func (x *ListConnectorsRequest) Reset()

func (*ListConnectorsRequest) String 

func (x *ListConnectorsRequest) String() string

type ListConnectorsResponse 

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

func (*ListConnectorsResponse) Descriptor deprecated 

func (*ListConnectorsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListConnectorsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectorsResponse) GetConnectors 

func (x *ListConnectorsResponse) GetConnectors() []*Connector

func (*ListConnectorsResponse) ProtoMessage 

func (*ListConnectorsResponse) ProtoMessage()

func (*ListConnectorsResponse) ProtoReflect 

func (x *ListConnectorsResponse) ProtoReflect() protoreflect.Message

func (*ListConnectorsResponse) Reset 

func (x *ListConnectorsResponse) Reset()

func (*ListConnectorsResponse) String 

func (x *ListConnectorsResponse) String() string

type ListPipelinesRequest 

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
}

func (*ListPipelinesRequest) Descriptor deprecated 

func (*ListPipelinesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListPipelinesRequest.ProtoReflect.Descriptor instead.

func (*ListPipelinesRequest) GetName added in v0.2.0 

func (x *ListPipelinesRequest) GetName() string

func (*ListPipelinesRequest) ProtoMessage 

func (*ListPipelinesRequest) ProtoMessage()

func (*ListPipelinesRequest) ProtoReflect 

func (x *ListPipelinesRequest) ProtoReflect() protoreflect.Message

func (*ListPipelinesRequest) Reset 

func (x *ListPipelinesRequest) Reset()

func (*ListPipelinesRequest) String 

func (x *ListPipelinesRequest) String() string

type ListPipelinesResponse 

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

func (*ListPipelinesResponse) Descriptor deprecated 

func (*ListPipelinesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListPipelinesResponse.ProtoReflect.Descriptor instead.

func (*ListPipelinesResponse) GetPipelines 

func (x *ListPipelinesResponse) GetPipelines() []*Pipeline

func (*ListPipelinesResponse) ProtoMessage 

func (*ListPipelinesResponse) ProtoMessage()

func (*ListPipelinesResponse) ProtoReflect 

func (x *ListPipelinesResponse) ProtoReflect() protoreflect.Message

func (*ListPipelinesResponse) Reset 

func (x *ListPipelinesResponse) Reset()

func (*ListPipelinesResponse) String 

func (x *ListPipelinesResponse) String() string

type ListPluginsRequest deprecated added in v0.2.0 

type ListPluginsRequest struct {

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

Deprecated: use ConnectorService.ListConnectorPlugins instead.

Deprecated: Marked as deprecated in api/v1/api.proto.

func (*ListPluginsRequest) Descriptor deprecated added in v0.2.0 

func (*ListPluginsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListPluginsRequest.ProtoReflect.Descriptor instead.

func (*ListPluginsRequest) GetName added in v0.2.0 

func (x *ListPluginsRequest) GetName() string

func (*ListPluginsRequest) ProtoMessage added in v0.2.0 

func (*ListPluginsRequest) ProtoMessage()

func (*ListPluginsRequest) ProtoReflect added in v0.2.0 

func (x *ListPluginsRequest) ProtoReflect() protoreflect.Message

func (*ListPluginsRequest) Reset added in v0.2.0 

func (x *ListPluginsRequest) Reset()

func (*ListPluginsRequest) String added in v0.2.0 

func (x *ListPluginsRequest) String() string

type ListPluginsResponse deprecated added in v0.2.0 

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

Deprecated: use ConnectorService.ListConnectorPlugins instead.

Deprecated: Marked as deprecated in api/v1/api.proto.

func (*ListPluginsResponse) Descriptor deprecated added in v0.2.0 

func (*ListPluginsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListPluginsResponse.ProtoReflect.Descriptor instead.

func (*ListPluginsResponse) GetPlugins added in v0.2.0 

func (x *ListPluginsResponse) GetPlugins() []*PluginSpecifications

func (*ListPluginsResponse) ProtoMessage added in v0.2.0 

func (*ListPluginsResponse) ProtoMessage()

func (*ListPluginsResponse) ProtoReflect added in v0.2.0 

func (x *ListPluginsResponse) ProtoReflect() protoreflect.Message

func (*ListPluginsResponse) Reset added in v0.2.0 

func (x *ListPluginsResponse) Reset()

func (*ListPluginsResponse) String added in v0.2.0 

func (x *ListPluginsResponse) String() string

type ListProcessorPluginsRequest added in v0.9.0 

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
}

func (*ListProcessorPluginsRequest) Descriptor deprecated added in v0.9.0 

func (*ListProcessorPluginsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListProcessorPluginsRequest.ProtoReflect.Descriptor instead.

func (*ListProcessorPluginsRequest) GetName added in v0.9.0 

func (x *ListProcessorPluginsRequest) GetName() string

func (*ListProcessorPluginsRequest) ProtoMessage added in v0.9.0 

func (*ListProcessorPluginsRequest) ProtoMessage()

func (*ListProcessorPluginsRequest) ProtoReflect added in v0.9.0 

func (x *ListProcessorPluginsRequest) ProtoReflect() protoreflect.Message

func (*ListProcessorPluginsRequest) Reset added in v0.9.0 

func (x *ListProcessorPluginsRequest) Reset()

func (*ListProcessorPluginsRequest) String added in v0.9.0 

func (x *ListProcessorPluginsRequest) String() string

type ListProcessorPluginsResponse added in v0.9.0 

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

func (*ListProcessorPluginsResponse) Descriptor deprecated added in v0.9.0 

func (*ListProcessorPluginsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListProcessorPluginsResponse.ProtoReflect.Descriptor instead.

func (*ListProcessorPluginsResponse) GetPlugins added in v0.9.0 

func (x *ListProcessorPluginsResponse) GetPlugins() []*ProcessorPluginSpecifications

func (*ListProcessorPluginsResponse) ProtoMessage added in v0.9.0 

func (*ListProcessorPluginsResponse) ProtoMessage()

func (*ListProcessorPluginsResponse) ProtoReflect added in v0.9.0 

func (x *ListProcessorPluginsResponse) ProtoReflect() protoreflect.Message

func (*ListProcessorPluginsResponse) Reset added in v0.9.0 

func (x *ListProcessorPluginsResponse) Reset()

func (*ListProcessorPluginsResponse) String added in v0.9.0 

func (x *ListProcessorPluginsResponse) String() string

type ListProcessorsRequest 

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

func (*ListProcessorsRequest) Descriptor deprecated 

func (*ListProcessorsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListProcessorsRequest.ProtoReflect.Descriptor instead.

func (*ListProcessorsRequest) GetParentIds 

func (x *ListProcessorsRequest) GetParentIds() []string

func (*ListProcessorsRequest) ProtoMessage 

func (*ListProcessorsRequest) ProtoMessage()

func (*ListProcessorsRequest) ProtoReflect 

func (x *ListProcessorsRequest) ProtoReflect() protoreflect.Message

func (*ListProcessorsRequest) Reset 

func (x *ListProcessorsRequest) Reset()

func (*ListProcessorsRequest) String 

func (x *ListProcessorsRequest) String() string

type ListProcessorsResponse 

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

func (*ListProcessorsResponse) Descriptor deprecated 

func (*ListProcessorsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListProcessorsResponse.ProtoReflect.Descriptor instead.

func (*ListProcessorsResponse) GetProcessors 

func (x *ListProcessorsResponse) GetProcessors() []*Processor

func (*ListProcessorsResponse) ProtoMessage 

func (*ListProcessorsResponse) ProtoMessage()

func (*ListProcessorsResponse) ProtoReflect 

func (x *ListProcessorsResponse) ProtoReflect() protoreflect.Message

func (*ListProcessorsResponse) Reset 

func (x *ListProcessorsResponse) Reset()

func (*ListProcessorsResponse) String 

func (x *ListProcessorsResponse) String() string

type Pipeline 

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
}

func (*Pipeline) Descriptor deprecated 

func (*Pipeline) Descriptor() ([]byte, []int)

Deprecated: Use Pipeline.ProtoReflect.Descriptor instead.

func (*Pipeline) GetConfig 

func (x *Pipeline) GetConfig() *Pipeline_Config

func (*Pipeline) GetConnectorIds 

func (x *Pipeline) GetConnectorIds() []string

func (*Pipeline) GetCreatedAt added in v0.2.1 

func (x *Pipeline) GetCreatedAt() *timestamppb.Timestamp

func (*Pipeline) GetId 

func (x *Pipeline) GetId() string

func (*Pipeline) GetProcessorIds 

func (x *Pipeline) GetProcessorIds() []string

func (*Pipeline) GetState 

func (x *Pipeline) GetState() *Pipeline_State

func (*Pipeline) GetUpdatedAt added in v0.2.1 

func (x *Pipeline) GetUpdatedAt() *timestamppb.Timestamp

func (*Pipeline) ProtoMessage 

func (*Pipeline) ProtoMessage()

func (*Pipeline) ProtoReflect 

func (x *Pipeline) ProtoReflect() protoreflect.Message

func (*Pipeline) Reset 

func (x *Pipeline) Reset()

func (*Pipeline) String 

func (x *Pipeline) String() string

type PipelineServiceClient 

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)
}

PipelineServiceClient is the client API for PipelineService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

PipelineService exposes functionality for managing pipelines. Endpoints in this service can be used to create, fetch, modify or delete a pipeline. Entities connected to a pipeline (e.g. processors, connectors) can be fetched together with a pipeline, although they can not be modified through this service. Modifying these entities needs to be done through the service responsible for managing the corresponding entity.

func NewPipelineServiceClient 

func NewPipelineServiceClient(cc grpc.ClientConnInterface) PipelineServiceClient

type PipelineServiceServer 

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
}

PipelineServiceServer is the server API for PipelineService service. All implementations must embed UnimplementedPipelineServiceServer for forward compatibility

PipelineService exposes functionality for managing pipelines. Endpoints in this service can be used to create, fetch, modify or delete a pipeline. Entities connected to a pipeline (e.g. processors, connectors) can be fetched together with a pipeline, although they can not be modified through this service. Modifying these entities needs to be done through the service responsible for managing the corresponding entity.

type Pipeline_Config 

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
}

func (*Pipeline_Config) Descriptor deprecated 

func (*Pipeline_Config) Descriptor() ([]byte, []int)

Deprecated: Use Pipeline_Config.ProtoReflect.Descriptor instead.

func (*Pipeline_Config) GetDescription 

func (x *Pipeline_Config) GetDescription() string

func (*Pipeline_Config) GetName 

func (x *Pipeline_Config) GetName() string

func (*Pipeline_Config) ProtoMessage 

func (*Pipeline_Config) ProtoMessage()

func (*Pipeline_Config) ProtoReflect 

func (x *Pipeline_Config) ProtoReflect() protoreflect.Message

func (*Pipeline_Config) Reset 

func (x *Pipeline_Config) Reset()

func (*Pipeline_Config) String 

func (x *Pipeline_Config) String() string

type Pipeline_DLQ added in v0.6.0 

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
}

func (*Pipeline_DLQ) Descriptor deprecated added in v0.6.0 

func (*Pipeline_DLQ) Descriptor() ([]byte, []int)

Deprecated: Use Pipeline_DLQ.ProtoReflect.Descriptor instead.

func (*Pipeline_DLQ) GetPlugin added in v0.6.0 

func (x *Pipeline_DLQ) GetPlugin() string

func (*Pipeline_DLQ) GetSettings added in v0.6.0 

func (x *Pipeline_DLQ) GetSettings() map[string]string

func (*Pipeline_DLQ) GetWindowNackThreshold added in v0.6.0 

func (x *Pipeline_DLQ) GetWindowNackThreshold() uint64

func (*Pipeline_DLQ) GetWindowSize added in v0.6.0 

func (x *Pipeline_DLQ) GetWindowSize() uint64

func (*Pipeline_DLQ) ProtoMessage added in v0.6.0 

func (*Pipeline_DLQ) ProtoMessage()

func (*Pipeline_DLQ) ProtoReflect added in v0.6.0 

func (x *Pipeline_DLQ) ProtoReflect() protoreflect.Message

func (*Pipeline_DLQ) Reset added in v0.6.0 

func (x *Pipeline_DLQ) Reset()

func (*Pipeline_DLQ) String added in v0.6.0 

func (x *Pipeline_DLQ) String() string

type Pipeline_State 

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
}

func (*Pipeline_State) Descriptor deprecated 

func (*Pipeline_State) Descriptor() ([]byte, []int)

Deprecated: Use Pipeline_State.ProtoReflect.Descriptor instead.

func (*Pipeline_State) GetError 

func (x *Pipeline_State) GetError() string

func (*Pipeline_State) GetStatus 

func (x *Pipeline_State) GetStatus() Pipeline_Status

func (*Pipeline_State) ProtoMessage 

func (*Pipeline_State) ProtoMessage()

func (*Pipeline_State) ProtoReflect 

func (x *Pipeline_State) ProtoReflect() protoreflect.Message

func (*Pipeline_State) Reset 

func (x *Pipeline_State) Reset()

func (*Pipeline_State) String 

func (x *Pipeline_State) String() string

type Pipeline_Status 

type Pipeline_Status int32

Status describes the pipeline status. 

const (
	Pipeline_STATUS_UNSPECIFIED Pipeline_Status = 0
	// Pipeline is running.
	Pipeline_STATUS_RUNNING Pipeline_Status = 1
	// Pipeline gracefully stopped.
	Pipeline_STATUS_STOPPED Pipeline_Status = 2
	// Pipeline stopped with an error (see State.error).
	Pipeline_STATUS_DEGRADED Pipeline_Status = 3
)

func (Pipeline_Status) Descriptor 

func (Pipeline_Status) Descriptor() protoreflect.EnumDescriptor

func (Pipeline_Status) Enum 

func (x Pipeline_Status) Enum() *Pipeline_Status

func (Pipeline_Status) EnumDescriptor deprecated 

func (Pipeline_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Pipeline_Status.Descriptor instead.

func (Pipeline_Status) Number 

func (x Pipeline_Status) Number() protoreflect.EnumNumber

func (Pipeline_Status) String 

func (x Pipeline_Status) String() string

func (Pipeline_Status) Type 

func (Pipeline_Status) Type() protoreflect.EnumType

type PluginServiceClient deprecated added in v0.2.0 

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

PluginServiceClient is the client API for PluginService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

Deprecated: use ConnectorService and ProcessorService instead.

func NewPluginServiceClient added in v0.2.0 

func NewPluginServiceClient(cc grpc.ClientConnInterface) PluginServiceClient

type PluginServiceServer deprecated added in v0.2.0 

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

PluginServiceServer is the server API for PluginService service. All implementations must embed UnimplementedPluginServiceServer for forward compatibility

Deprecated: use ConnectorService and ProcessorService instead.

type PluginSpecifications deprecated added in v0.2.0 

type PluginSpecifications struct {
	Name              string                                     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Summary           string                                     `protobuf:"bytes,2,opt,name=summary,proto3" json:"summary,omitempty"`
	Description       string                                     `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Version           string                                     `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	Author            string                                     `protobuf:"bytes,5,opt,name=author,proto3" json:"author,omitempty"`
	DestinationParams map[string]*PluginSpecifications_Parameter `` /* 200-byte string literal not displayed */
	SourceParams      map[string]*PluginSpecifications_Parameter `` /* 185-byte string literal not displayed */
	// contains filtered or unexported fields
}

Deprecated: use ConnectorPluginSpecifications instead.

Deprecated: Marked as deprecated in api/v1/api.proto.

func (*PluginSpecifications) Descriptor deprecated added in v0.2.0 

func (*PluginSpecifications) Descriptor() ([]byte, []int)

Deprecated: Use PluginSpecifications.ProtoReflect.Descriptor instead.

func (*PluginSpecifications) GetAuthor added in v0.2.0 

func (x *PluginSpecifications) GetAuthor() string

func (*PluginSpecifications) GetDescription added in v0.2.0 

func (x *PluginSpecifications) GetDescription() string

func (*PluginSpecifications) GetDestinationParams added in v0.2.0 

func (x *PluginSpecifications) GetDestinationParams() map[string]*PluginSpecifications_Parameter

func (*PluginSpecifications) GetName added in v0.2.0 

func (x *PluginSpecifications) GetName() string

func (*PluginSpecifications) GetSourceParams added in v0.2.0 

func (x *PluginSpecifications) GetSourceParams() map[string]*PluginSpecifications_Parameter

func (*PluginSpecifications) GetSummary added in v0.2.0 

func (x *PluginSpecifications) GetSummary() string

func (*PluginSpecifications) GetVersion added in v0.2.0 

func (x *PluginSpecifications) GetVersion() string

func (*PluginSpecifications) ProtoMessage added in v0.2.0 

func (*PluginSpecifications) ProtoMessage()

func (*PluginSpecifications) ProtoReflect added in v0.2.0 

func (x *PluginSpecifications) ProtoReflect() protoreflect.Message

func (*PluginSpecifications) Reset added in v0.2.0 

func (x *PluginSpecifications) Reset()

func (*PluginSpecifications) String added in v0.2.0 

func (x *PluginSpecifications) String() string

type PluginSpecifications_Parameter deprecated added in v0.2.0 

type PluginSpecifications_Parameter struct {
	Description string                                       `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	Default     string                                       `protobuf:"bytes,2,opt,name=default,proto3" json:"default,omitempty"`
	Type        PluginSpecifications_Parameter_Type          `protobuf:"varint,3,opt,name=type,proto3,enum=api.v1.PluginSpecifications_Parameter_Type" json:"type,omitempty"`
	Validations []*PluginSpecifications_Parameter_Validation `protobuf:"bytes,4,rep,name=validations,proto3" json:"validations,omitempty"`
	// contains filtered or unexported fields
}

Deprecated: use config.v1.Parameter instead.

Deprecated: Marked as deprecated in api/v1/api.proto.

func (*PluginSpecifications_Parameter) Descriptor deprecated added in v0.2.0 

func (*PluginSpecifications_Parameter) Descriptor() ([]byte, []int)

Deprecated: Use PluginSpecifications_Parameter.ProtoReflect.Descriptor instead.

func (*PluginSpecifications_Parameter) GetDefault added in v0.2.0 

func (x *PluginSpecifications_Parameter) GetDefault() string

func (*PluginSpecifications_Parameter) GetDescription added in v0.2.0 

func (x *PluginSpecifications_Parameter) GetDescription() string

func (*PluginSpecifications_Parameter) GetType added in v0.2.0 

func (x *PluginSpecifications_Parameter) GetType() PluginSpecifications_Parameter_Type

func (*PluginSpecifications_Parameter) GetValidations added in v0.2.0 

func (x *PluginSpecifications_Parameter) GetValidations() []*PluginSpecifications_Parameter_Validation

func (*PluginSpecifications_Parameter) ProtoMessage added in v0.2.0 

func (*PluginSpecifications_Parameter) ProtoMessage()

func (*PluginSpecifications_Parameter) ProtoReflect added in v0.2.0 

func (x *PluginSpecifications_Parameter) ProtoReflect() protoreflect.Message

func (*PluginSpecifications_Parameter) Reset added in v0.2.0 

func (x *PluginSpecifications_Parameter) Reset()

func (*PluginSpecifications_Parameter) String added in v0.2.0 

func (x *PluginSpecifications_Parameter) String() string

type PluginSpecifications_Parameter_Type deprecated added in v0.2.0 

type PluginSpecifications_Parameter_Type int32

Deprecated: use config.v1.Parameter.Type instead.

Deprecated: Marked as deprecated in api/v1/api.proto. 

const (
	PluginSpecifications_Parameter_TYPE_UNSPECIFIED PluginSpecifications_Parameter_Type = 0
	// Parameter is a string.
	PluginSpecifications_Parameter_TYPE_STRING PluginSpecifications_Parameter_Type = 1
	// Parameter is an integer.
	PluginSpecifications_Parameter_TYPE_INT PluginSpecifications_Parameter_Type = 2
	// Parameter is a float.
	PluginSpecifications_Parameter_TYPE_FLOAT PluginSpecifications_Parameter_Type = 3
	// Parameter is a boolean.
	PluginSpecifications_Parameter_TYPE_BOOL PluginSpecifications_Parameter_Type = 4
	// Parameter is a file.
	PluginSpecifications_Parameter_TYPE_FILE PluginSpecifications_Parameter_Type = 5
	// Parameter is a duration.
	PluginSpecifications_Parameter_TYPE_DURATION PluginSpecifications_Parameter_Type = 6
)

func (PluginSpecifications_Parameter_Type) Descriptor added in v0.2.0 

func (PluginSpecifications_Parameter_Type) Descriptor() protoreflect.EnumDescriptor

func (PluginSpecifications_Parameter_Type) Enum added in v0.2.0 

func (x PluginSpecifications_Parameter_Type) Enum() *PluginSpecifications_Parameter_Type

func (PluginSpecifications_Parameter_Type) EnumDescriptor deprecated added in v0.2.0 

func (PluginSpecifications_Parameter_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use PluginSpecifications_Parameter_Type.Descriptor instead.

func (PluginSpecifications_Parameter_Type) Number added in v0.2.0 

func (x PluginSpecifications_Parameter_Type) Number() protoreflect.EnumNumber

func (PluginSpecifications_Parameter_Type) String added in v0.2.0 

func (x PluginSpecifications_Parameter_Type) String() string

func (PluginSpecifications_Parameter_Type) Type added in v0.2.0 

func (PluginSpecifications_Parameter_Type) Type() protoreflect.EnumType

type PluginSpecifications_Parameter_Validation deprecated added in v0.2.0 

type PluginSpecifications_Parameter_Validation struct {
	Type PluginSpecifications_Parameter_Validation_Type `protobuf:"varint,1,opt,name=type,proto3,enum=api.v1.PluginSpecifications_Parameter_Validation_Type" json:"type,omitempty"`
	// The value to be compared with the parameter,
	// or a comma separated list in case of Validation.TYPE_INCLUSION or Validation.TYPE_EXCLUSION.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Deprecated: use config.v1.Validation instead.

Deprecated: Marked as deprecated in api/v1/api.proto.

func (*PluginSpecifications_Parameter_Validation) Descriptor deprecated added in v0.2.0 

func (*PluginSpecifications_Parameter_Validation) Descriptor() ([]byte, []int)

Deprecated: Use PluginSpecifications_Parameter_Validation.ProtoReflect.Descriptor instead.

func (*PluginSpecifications_Parameter_Validation) GetType added in v0.2.0 

func (x *PluginSpecifications_Parameter_Validation) GetType() PluginSpecifications_Parameter_Validation_Type

func (*PluginSpecifications_Parameter_Validation) GetValue added in v0.2.0 

func (x *PluginSpecifications_Parameter_Validation) GetValue() string

func (*PluginSpecifications_Parameter_Validation) ProtoMessage added in v0.2.0 

func (*PluginSpecifications_Parameter_Validation) ProtoMessage()

func (*PluginSpecifications_Parameter_Validation) ProtoReflect added in v0.2.0 

func (x *PluginSpecifications_Parameter_Validation) ProtoReflect() protoreflect.Message

func (*PluginSpecifications_Parameter_Validation) Reset added in v0.2.0 

func (x *PluginSpecifications_Parameter_Validation) Reset()

func (*PluginSpecifications_Parameter_Validation) String added in v0.2.0 

func (x *PluginSpecifications_Parameter_Validation) String() string

type PluginSpecifications_Parameter_Validation_Type deprecated added in v0.2.0 

type PluginSpecifications_Parameter_Validation_Type int32

Deprecated: use config.v1.Validation.Type instead.

Deprecated: Marked as deprecated in api/v1/api.proto. 

const (
	PluginSpecifications_Parameter_Validation_TYPE_UNSPECIFIED PluginSpecifications_Parameter_Validation_Type = 0
	// Parameter must be present.
	PluginSpecifications_Parameter_Validation_TYPE_REQUIRED PluginSpecifications_Parameter_Validation_Type = 1
	// Parameter must be greater than {value}.
	PluginSpecifications_Parameter_Validation_TYPE_GREATER_THAN PluginSpecifications_Parameter_Validation_Type = 2
	// Parameter must be less than {value}.
	PluginSpecifications_Parameter_Validation_TYPE_LESS_THAN PluginSpecifications_Parameter_Validation_Type = 3
	// Parameter must be included in the comma separated list {value}.
	PluginSpecifications_Parameter_Validation_TYPE_INCLUSION PluginSpecifications_Parameter_Validation_Type = 4
	// Parameter must not be included in the comma separated list {value}.
	PluginSpecifications_Parameter_Validation_TYPE_EXCLUSION PluginSpecifications_Parameter_Validation_Type = 5
	// Parameter must match the regex {value}.
	PluginSpecifications_Parameter_Validation_TYPE_REGEX PluginSpecifications_Parameter_Validation_Type = 6
)

func (PluginSpecifications_Parameter_Validation_Type) Descriptor added in v0.2.0 

func (PluginSpecifications_Parameter_Validation_Type) Descriptor() protoreflect.EnumDescriptor

func (PluginSpecifications_Parameter_Validation_Type) Enum added in v0.2.0 

func (x PluginSpecifications_Parameter_Validation_Type) Enum() *PluginSpecifications_Parameter_Validation_Type

func (PluginSpecifications_Parameter_Validation_Type) EnumDescriptor deprecated added in v0.2.0 

func (PluginSpecifications_Parameter_Validation_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use PluginSpecifications_Parameter_Validation_Type.Descriptor instead.

func (PluginSpecifications_Parameter_Validation_Type) Number added in v0.2.0 

func (x PluginSpecifications_Parameter_Validation_Type) Number() protoreflect.EnumNumber

func (PluginSpecifications_Parameter_Validation_Type) String added in v0.2.0 

func (x PluginSpecifications_Parameter_Validation_Type) String() string

func (PluginSpecifications_Parameter_Validation_Type) Type added in v0.2.0 

func (PluginSpecifications_Parameter_Validation_Type) Type() protoreflect.EnumType

type Processor 

type Processor struct {
	Id     string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Config *Processor_Config `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// Condition is a goTemplate formatted string, the value provided to the template is a sdk.Record, it should evaluate
	// to a boolean value, indicating a condition to run the processor for a specific record or not. (template functions
	// provided by `sprig` are injected)
	Condition string                 `protobuf:"bytes,9,opt,name=condition,proto3" json:"condition,omitempty"`
	Plugin    string                 `protobuf:"bytes,5,opt,name=plugin,proto3" json:"plugin,omitempty"`
	Parent    *Processor_Parent      `protobuf:"bytes,6,opt,name=parent,proto3" json:"parent,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
}

func (*Processor) Descriptor deprecated 

func (*Processor) Descriptor() ([]byte, []int)

Deprecated: Use Processor.ProtoReflect.Descriptor instead.

func (*Processor) GetCondition added in v0.8.1 

func (x *Processor) GetCondition() string

func (*Processor) GetConfig 

func (x *Processor) GetConfig() *Processor_Config

func (*Processor) GetCreatedAt added in v0.2.1 

func (x *Processor) GetCreatedAt() *timestamppb.Timestamp

func (*Processor) GetId 

func (x *Processor) GetId() string

func (*Processor) GetParent 

func (x *Processor) GetParent() *Processor_Parent

func (*Processor) GetPlugin added in v0.9.0 

func (x *Processor) GetPlugin() string

func (*Processor) GetUpdatedAt added in v0.2.1 

func (x *Processor) GetUpdatedAt() *timestamppb.Timestamp

func (*Processor) ProtoMessage 

func (*Processor) ProtoMessage()

func (*Processor) ProtoReflect 

func (x *Processor) ProtoReflect() protoreflect.Message

func (*Processor) Reset 

func (x *Processor) Reset()

func (*Processor) String 

func (x *Processor) String() string

type ProcessorPluginSpecifications added in v0.9.0 

type ProcessorPluginSpecifications 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
	// processor plugin.
	Parameters map[string]*v1.Parameter `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

ProcessorPluginSpecifications describes the specifications of a processor plugin.

func (*ProcessorPluginSpecifications) Descriptor deprecated added in v0.9.0 

func (*ProcessorPluginSpecifications) Descriptor() ([]byte, []int)

Deprecated: Use ProcessorPluginSpecifications.ProtoReflect.Descriptor instead.

func (*ProcessorPluginSpecifications) GetAuthor added in v0.9.0 

func (x *ProcessorPluginSpecifications) GetAuthor() string

func (*ProcessorPluginSpecifications) GetDescription added in v0.9.0 

func (x *ProcessorPluginSpecifications) GetDescription() string

func (*ProcessorPluginSpecifications) GetName added in v0.9.0 

func (x *ProcessorPluginSpecifications) GetName() string

func (*ProcessorPluginSpecifications) GetParameters added in v0.9.0 

func (x *ProcessorPluginSpecifications) GetParameters() map[string]*v1.Parameter

func (*ProcessorPluginSpecifications) GetSummary added in v0.9.0 

func (x *ProcessorPluginSpecifications) GetSummary() string

func (*ProcessorPluginSpecifications) GetVersion added in v0.9.0 

func (x *ProcessorPluginSpecifications) GetVersion() string

func (*ProcessorPluginSpecifications) ProtoMessage added in v0.9.0 

func (*ProcessorPluginSpecifications) ProtoMessage()

func (*ProcessorPluginSpecifications) ProtoReflect added in v0.9.0 

func (x *ProcessorPluginSpecifications) ProtoReflect() protoreflect.Message

func (*ProcessorPluginSpecifications) Reset added in v0.9.0 

func (x *ProcessorPluginSpecifications) Reset()

func (*ProcessorPluginSpecifications) String added in v0.9.0 

func (x *ProcessorPluginSpecifications) String() string

type ProcessorServiceClient 

type ProcessorServiceClient interface {
	ListProcessors(ctx context.Context, in *ListProcessorsRequest, opts ...grpc.CallOption) (*ListProcessorsResponse, error)
	// InspectProcessorIn streams records coming into the specified processor
	InspectProcessorIn(ctx context.Context, in *InspectProcessorInRequest, opts ...grpc.CallOption) (ProcessorService_InspectProcessorInClient, error)
	// InspectProcessorOut streams the output records from the specified processor
	InspectProcessorOut(ctx context.Context, in *InspectProcessorOutRequest, opts ...grpc.CallOption) (ProcessorService_InspectProcessorOutClient, error)
	GetProcessor(ctx context.Context, in *GetProcessorRequest, opts ...grpc.CallOption) (*GetProcessorResponse, error)
	CreateProcessor(ctx context.Context, in *CreateProcessorRequest, opts ...grpc.CallOption) (*CreateProcessorResponse, error)
	UpdateProcessor(ctx context.Context, in *UpdateProcessorRequest, opts ...grpc.CallOption) (*UpdateProcessorResponse, error)
	DeleteProcessor(ctx context.Context, in *DeleteProcessorRequest, opts ...grpc.CallOption) (*DeleteProcessorResponse, error)
	ListProcessorPlugins(ctx context.Context, in *ListProcessorPluginsRequest, opts ...grpc.CallOption) (*ListProcessorPluginsResponse, error)
}

ProcessorServiceClient is the client API for ProcessorService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

ProcessorService exposes CRUD functionality for managing processors.

func NewProcessorServiceClient 

func NewProcessorServiceClient(cc grpc.ClientConnInterface) ProcessorServiceClient

type ProcessorServiceServer 

type ProcessorServiceServer interface {
	ListProcessors(context.Context, *ListProcessorsRequest) (*ListProcessorsResponse, error)
	// InspectProcessorIn streams records coming into the specified processor
	InspectProcessorIn(*InspectProcessorInRequest, ProcessorService_InspectProcessorInServer) error
	// InspectProcessorOut streams the output records from the specified processor
	InspectProcessorOut(*InspectProcessorOutRequest, ProcessorService_InspectProcessorOutServer) error
	GetProcessor(context.Context, *GetProcessorRequest) (*GetProcessorResponse, error)
	CreateProcessor(context.Context, *CreateProcessorRequest) (*CreateProcessorResponse, error)
	UpdateProcessor(context.Context, *UpdateProcessorRequest) (*UpdateProcessorResponse, error)
	DeleteProcessor(context.Context, *DeleteProcessorRequest) (*DeleteProcessorResponse, error)
	ListProcessorPlugins(context.Context, *ListProcessorPluginsRequest) (*ListProcessorPluginsResponse, error)
	// contains filtered or unexported methods
}

ProcessorServiceServer is the server API for ProcessorService service. All implementations must embed UnimplementedProcessorServiceServer for forward compatibility

ProcessorService exposes CRUD functionality for managing processors.

type ProcessorService_InspectProcessorInClient added in v0.6.0 

type ProcessorService_InspectProcessorInClient interface {
	Recv() (*InspectProcessorInResponse, error)
	grpc.ClientStream
}

type ProcessorService_InspectProcessorInServer added in v0.6.0 

type ProcessorService_InspectProcessorInServer interface {
	Send(*InspectProcessorInResponse) error
	grpc.ServerStream
}

type ProcessorService_InspectProcessorOutClient added in v0.6.0 

type ProcessorService_InspectProcessorOutClient interface {
	Recv() (*InspectProcessorOutResponse, error)
	grpc.ClientStream
}

type ProcessorService_InspectProcessorOutServer added in v0.6.0 

type ProcessorService_InspectProcessorOutServer interface {
	Send(*InspectProcessorOutResponse) error
	grpc.ServerStream
}

type Processor_Config 

type Processor_Config struct {
	Settings map[string]string `` /* 157-byte string literal not displayed */
	Workers  int32             `protobuf:"varint,2,opt,name=workers,proto3" json:"workers,omitempty"`
	// contains filtered or unexported fields
}

func (*Processor_Config) Descriptor deprecated 

func (*Processor_Config) Descriptor() ([]byte, []int)

Deprecated: Use Processor_Config.ProtoReflect.Descriptor instead.

func (*Processor_Config) GetSettings 

func (x *Processor_Config) GetSettings() map[string]string

func (*Processor_Config) GetWorkers added in v0.6.0 

func (x *Processor_Config) GetWorkers() int32

func (*Processor_Config) ProtoMessage 

func (*Processor_Config) ProtoMessage()

func (*Processor_Config) ProtoReflect 

func (x *Processor_Config) ProtoReflect() protoreflect.Message

func (*Processor_Config) Reset 

func (x *Processor_Config) Reset()

func (*Processor_Config) String 

func (x *Processor_Config) String() string

type Processor_Parent 

type Processor_Parent struct {
	Type Processor_Parent_Type `protobuf:"varint,1,opt,name=type,proto3,enum=api.v1.Processor_Parent_Type" json:"type,omitempty"`
	Id   string                `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*Processor_Parent) Descriptor deprecated 

func (*Processor_Parent) Descriptor() ([]byte, []int)

Deprecated: Use Processor_Parent.ProtoReflect.Descriptor instead.

func (*Processor_Parent) GetId 

func (x *Processor_Parent) GetId() string

func (*Processor_Parent) GetType 

func (x *Processor_Parent) GetType() Processor_Parent_Type

func (*Processor_Parent) ProtoMessage 

func (*Processor_Parent) ProtoMessage()

func (*Processor_Parent) ProtoReflect 

func (x *Processor_Parent) ProtoReflect() protoreflect.Message

func (*Processor_Parent) Reset 

func (x *Processor_Parent) Reset()

func (*Processor_Parent) String 

func (x *Processor_Parent) String() string

type Processor_Parent_Type 

type Processor_Parent_Type int32

Type shows the processor's parent type. 

const (
	Processor_Parent_TYPE_UNSPECIFIED Processor_Parent_Type = 0
	// Processor parent is a connector.
	Processor_Parent_TYPE_CONNECTOR Processor_Parent_Type = 1
	// Processor parent is a pipeline.
	Processor_Parent_TYPE_PIPELINE Processor_Parent_Type = 2
)

func (Processor_Parent_Type) Descriptor 

func (Processor_Parent_Type) Descriptor() protoreflect.EnumDescriptor

func (Processor_Parent_Type) Enum 

func (x Processor_Parent_Type) Enum() *Processor_Parent_Type

func (Processor_Parent_Type) EnumDescriptor deprecated 

func (Processor_Parent_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Processor_Parent_Type.Descriptor instead.

func (Processor_Parent_Type) Number 

func (x Processor_Parent_Type) Number() protoreflect.EnumNumber

func (Processor_Parent_Type) String 

func (x Processor_Parent_Type) String() string

func (Processor_Parent_Type) Type 

func (Processor_Parent_Type) Type() protoreflect.EnumType

type StartPipelineRequest 

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

func (*StartPipelineRequest) Descriptor deprecated 

func (*StartPipelineRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartPipelineRequest.ProtoReflect.Descriptor instead.

func (*StartPipelineRequest) GetId 

func (x *StartPipelineRequest) GetId() string

func (*StartPipelineRequest) ProtoMessage 

func (*StartPipelineRequest) ProtoMessage()

func (*StartPipelineRequest) ProtoReflect 

func (x *StartPipelineRequest) ProtoReflect() protoreflect.Message

func (*StartPipelineRequest) Reset 

func (x *StartPipelineRequest) Reset()

func (*StartPipelineRequest) String 

func (x *StartPipelineRequest) String() string

type StartPipelineResponse 

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

func (*StartPipelineResponse) Descriptor deprecated 

func (*StartPipelineResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartPipelineResponse.ProtoReflect.Descriptor instead.

func (*StartPipelineResponse) ProtoMessage 

func (*StartPipelineResponse) ProtoMessage()

func (*StartPipelineResponse) ProtoReflect 

func (x *StartPipelineResponse) ProtoReflect() protoreflect.Message

func (*StartPipelineResponse) Reset 

func (x *StartPipelineResponse) Reset()

func (*StartPipelineResponse) String 

func (x *StartPipelineResponse) String() string

type StopPipelineRequest 

type StopPipelineRequest struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Force bool   `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*StopPipelineRequest) Descriptor deprecated 

func (*StopPipelineRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopPipelineRequest.ProtoReflect.Descriptor instead.

func (*StopPipelineRequest) GetForce added in v0.6.0 

func (x *StopPipelineRequest) GetForce() bool

func (*StopPipelineRequest) GetId 

func (x *StopPipelineRequest) GetId() string

func (*StopPipelineRequest) ProtoMessage 

func (*StopPipelineRequest) ProtoMessage()

func (*StopPipelineRequest) ProtoReflect 

func (x *StopPipelineRequest) ProtoReflect() protoreflect.Message

func (*StopPipelineRequest) Reset 

func (x *StopPipelineRequest) Reset()

func (*StopPipelineRequest) String 

func (x *StopPipelineRequest) String() string

type StopPipelineResponse 

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

func (*StopPipelineResponse) Descriptor deprecated 

func (*StopPipelineResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopPipelineResponse.ProtoReflect.Descriptor instead.

func (*StopPipelineResponse) ProtoMessage 

func (*StopPipelineResponse) ProtoMessage()

func (*StopPipelineResponse) ProtoReflect 

func (x *StopPipelineResponse) ProtoReflect() protoreflect.Message

func (*StopPipelineResponse) Reset 

func (x *StopPipelineResponse) Reset()

func (*StopPipelineResponse) String 

func (x *StopPipelineResponse) String() string

type UnimplementedConnectorServiceServer 

type UnimplementedConnectorServiceServer struct {
}

UnimplementedConnectorServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedConnectorServiceServer) CreateConnector 

func (UnimplementedConnectorServiceServer) CreateConnector(context.Context, *CreateConnectorRequest) (*CreateConnectorResponse, error)

func (UnimplementedConnectorServiceServer) DeleteConnector 

func (UnimplementedConnectorServiceServer) DeleteConnector(context.Context, *DeleteConnectorRequest) (*DeleteConnectorResponse, error)

func (UnimplementedConnectorServiceServer) GetConnector 

func (UnimplementedConnectorServiceServer) GetConnector(context.Context, *GetConnectorRequest) (*GetConnectorResponse, error)

func (UnimplementedConnectorServiceServer) InspectConnector added in v0.6.0 

func (UnimplementedConnectorServiceServer) InspectConnector(*InspectConnectorRequest, ConnectorService_InspectConnectorServer) error

func (UnimplementedConnectorServiceServer) ListConnectorPlugins added in v0.9.0 

func (UnimplementedConnectorServiceServer) ListConnectorPlugins(context.Context, *ListConnectorPluginsRequest) (*ListConnectorPluginsResponse, error)

func (UnimplementedConnectorServiceServer) ListConnectors 

func (UnimplementedConnectorServiceServer) ListConnectors(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)

func (UnimplementedConnectorServiceServer) UpdateConnector 

func (UnimplementedConnectorServiceServer) UpdateConnector(context.Context, *UpdateConnectorRequest) (*UpdateConnectorResponse, error)

func (UnimplementedConnectorServiceServer) ValidateConnector added in v0.2.1 

func (UnimplementedConnectorServiceServer) ValidateConnector(context.Context, *ValidateConnectorRequest) (*ValidateConnectorResponse, error)

type UnimplementedInformationServiceServer 

type UnimplementedInformationServiceServer struct {
}

UnimplementedInformationServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedInformationServiceServer) GetInfo 

func (UnimplementedInformationServiceServer) GetInfo(context.Context, *GetInfoRequest) (*GetInfoResponse, error)

type UnimplementedPipelineServiceServer 

type UnimplementedPipelineServiceServer struct {
}

UnimplementedPipelineServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPipelineServiceServer) CreatePipeline 

func (UnimplementedPipelineServiceServer) CreatePipeline(context.Context, *CreatePipelineRequest) (*CreatePipelineResponse, error)

func (UnimplementedPipelineServiceServer) DeletePipeline 

func (UnimplementedPipelineServiceServer) DeletePipeline(context.Context, *DeletePipelineRequest) (*DeletePipelineResponse, error)

func (UnimplementedPipelineServiceServer) ExportPipeline 

func (UnimplementedPipelineServiceServer) ExportPipeline(context.Context, *ExportPipelineRequest) (*ExportPipelineResponse, error)

func (UnimplementedPipelineServiceServer) GetDLQ added in v0.6.0 

func (UnimplementedPipelineServiceServer) GetDLQ(context.Context, *GetDLQRequest) (*GetDLQResponse, error)

func (UnimplementedPipelineServiceServer) GetPipeline 

func (UnimplementedPipelineServiceServer) GetPipeline(context.Context, *GetPipelineRequest) (*GetPipelineResponse, error)

func (UnimplementedPipelineServiceServer) ImportPipeline 

func (UnimplementedPipelineServiceServer) ImportPipeline(context.Context, *ImportPipelineRequest) (*ImportPipelineResponse, error)

func (UnimplementedPipelineServiceServer) ListPipelines 

func (UnimplementedPipelineServiceServer) ListPipelines(context.Context, *ListPipelinesRequest) (*ListPipelinesResponse, error)

func (UnimplementedPipelineServiceServer) StartPipeline 

func (UnimplementedPipelineServiceServer) StartPipeline(context.Context, *StartPipelineRequest) (*StartPipelineResponse, error)

func (UnimplementedPipelineServiceServer) StopPipeline 

func (UnimplementedPipelineServiceServer) StopPipeline(context.Context, *StopPipelineRequest) (*StopPipelineResponse, error)

func (UnimplementedPipelineServiceServer) UpdateDLQ added in v0.6.0 

func (UnimplementedPipelineServiceServer) UpdateDLQ(context.Context, *UpdateDLQRequest) (*UpdateDLQResponse, error)

func (UnimplementedPipelineServiceServer) UpdatePipeline 

func (UnimplementedPipelineServiceServer) UpdatePipeline(context.Context, *UpdatePipelineRequest) (*UpdatePipelineResponse, error)

type UnimplementedPluginServiceServer added in v0.2.0 

type UnimplementedPluginServiceServer struct {
}

UnimplementedPluginServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPluginServiceServer) ListPlugins added in v0.2.0 

func (UnimplementedPluginServiceServer) ListPlugins(context.Context, *ListPluginsRequest) (*ListPluginsResponse, error)

type UnimplementedProcessorServiceServer 

type UnimplementedProcessorServiceServer struct {
}

UnimplementedProcessorServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProcessorServiceServer) CreateProcessor 

func (UnimplementedProcessorServiceServer) CreateProcessor(context.Context, *CreateProcessorRequest) (*CreateProcessorResponse, error)

func (UnimplementedProcessorServiceServer) DeleteProcessor 

func (UnimplementedProcessorServiceServer) DeleteProcessor(context.Context, *DeleteProcessorRequest) (*DeleteProcessorResponse, error)

func (UnimplementedProcessorServiceServer) GetProcessor 

func (UnimplementedProcessorServiceServer) GetProcessor(context.Context, *GetProcessorRequest) (*GetProcessorResponse, error)

func (UnimplementedProcessorServiceServer) InspectProcessorIn added in v0.6.0 

func (UnimplementedProcessorServiceServer) InspectProcessorIn(*InspectProcessorInRequest, ProcessorService_InspectProcessorInServer) error

func (UnimplementedProcessorServiceServer) InspectProcessorOut added in v0.6.0 

func (UnimplementedProcessorServiceServer) InspectProcessorOut(*InspectProcessorOutRequest, ProcessorService_InspectProcessorOutServer) error

func (UnimplementedProcessorServiceServer) ListProcessorPlugins added in v0.9.0 

func (UnimplementedProcessorServiceServer) ListProcessorPlugins(context.Context, *ListProcessorPluginsRequest) (*ListProcessorPluginsResponse, error)

func (UnimplementedProcessorServiceServer) ListProcessors 

func (UnimplementedProcessorServiceServer) ListProcessors(context.Context, *ListProcessorsRequest) (*ListProcessorsResponse, error)

func (UnimplementedProcessorServiceServer) UpdateProcessor 

func (UnimplementedProcessorServiceServer) UpdateProcessor(context.Context, *UpdateProcessorRequest) (*UpdateProcessorResponse, error)

type UnsafeConnectorServiceServer 

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

UnsafeConnectorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ConnectorServiceServer will result in compilation errors.

type UnsafeInformationServiceServer 

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

UnsafeInformationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to InformationServiceServer will result in compilation errors.

type UnsafePipelineServiceServer 

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

UnsafePipelineServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PipelineServiceServer will result in compilation errors.

type UnsafePluginServiceServer added in v0.2.0 

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

UnsafePluginServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PluginServiceServer will result in compilation errors.

type UnsafeProcessorServiceServer 

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

UnsafeProcessorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProcessorServiceServer will result in compilation errors.

type UpdateConnectorRequest 

type UpdateConnectorRequest struct {
	Id     string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Config *Connector_Config `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConnectorRequest) Descriptor deprecated 

func (*UpdateConnectorRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConnectorRequest.ProtoReflect.Descriptor instead.

func (*UpdateConnectorRequest) GetConfig 

func (x *UpdateConnectorRequest) GetConfig() *Connector_Config

func (*UpdateConnectorRequest) GetId 

func (x *UpdateConnectorRequest) GetId() string

func (*UpdateConnectorRequest) ProtoMessage 

func (*UpdateConnectorRequest) ProtoMessage()

func (*UpdateConnectorRequest) ProtoReflect 

func (x *UpdateConnectorRequest) ProtoReflect() protoreflect.Message

func (*UpdateConnectorRequest) Reset 

func (x *UpdateConnectorRequest) Reset()

func (*UpdateConnectorRequest) String 

func (x *UpdateConnectorRequest) String() string

type UpdateConnectorResponse 

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

func (*UpdateConnectorResponse) Descriptor deprecated 

func (*UpdateConnectorResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConnectorResponse.ProtoReflect.Descriptor instead.

func (*UpdateConnectorResponse) GetConnector 

func (x *UpdateConnectorResponse) GetConnector() *Connector

func (*UpdateConnectorResponse) ProtoMessage 

func (*UpdateConnectorResponse) ProtoMessage()

func (*UpdateConnectorResponse) ProtoReflect 

func (x *UpdateConnectorResponse) ProtoReflect() protoreflect.Message

func (*UpdateConnectorResponse) Reset 

func (x *UpdateConnectorResponse) Reset()

func (*UpdateConnectorResponse) String 

func (x *UpdateConnectorResponse) String() string

type UpdateDLQRequest added in v0.6.0 

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

func (*UpdateDLQRequest) Descriptor deprecated added in v0.6.0 

func (*UpdateDLQRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDLQRequest.ProtoReflect.Descriptor instead.

func (*UpdateDLQRequest) GetDlq added in v0.6.0 

func (x *UpdateDLQRequest) GetDlq() *Pipeline_DLQ

func (*UpdateDLQRequest) GetId added in v0.6.0 

func (x *UpdateDLQRequest) GetId() string

func (*UpdateDLQRequest) ProtoMessage added in v0.6.0 

func (*UpdateDLQRequest) ProtoMessage()

func (*UpdateDLQRequest) ProtoReflect added in v0.6.0 

func (x *UpdateDLQRequest) ProtoReflect() protoreflect.Message

func (*UpdateDLQRequest) Reset added in v0.6.0 

func (x *UpdateDLQRequest) Reset()

func (*UpdateDLQRequest) String added in v0.6.0 

func (x *UpdateDLQRequest) String() string

type UpdateDLQResponse added in v0.6.0 

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

func (*UpdateDLQResponse) Descriptor deprecated added in v0.6.0 

func (*UpdateDLQResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDLQResponse.ProtoReflect.Descriptor instead.

func (*UpdateDLQResponse) GetDlq added in v0.6.0 

func (x *UpdateDLQResponse) GetDlq() *Pipeline_DLQ

func (*UpdateDLQResponse) ProtoMessage added in v0.6.0 

func (*UpdateDLQResponse) ProtoMessage()

func (*UpdateDLQResponse) ProtoReflect added in v0.6.0 

func (x *UpdateDLQResponse) ProtoReflect() protoreflect.Message

func (*UpdateDLQResponse) Reset added in v0.6.0 

func (x *UpdateDLQResponse) Reset()

func (*UpdateDLQResponse) String added in v0.6.0 

func (x *UpdateDLQResponse) String() string

type UpdatePipelineRequest 

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

func (*UpdatePipelineRequest) Descriptor deprecated 

func (*UpdatePipelineRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdatePipelineRequest.ProtoReflect.Descriptor instead.

func (*UpdatePipelineRequest) GetConfig 

func (x *UpdatePipelineRequest) GetConfig() *Pipeline_Config

func (*UpdatePipelineRequest) GetId 

func (x *UpdatePipelineRequest) GetId() string

func (*UpdatePipelineRequest) ProtoMessage 

func (*UpdatePipelineRequest) ProtoMessage()

func (*UpdatePipelineRequest) ProtoReflect 

func (x *UpdatePipelineRequest) ProtoReflect() protoreflect.Message

func (*UpdatePipelineRequest) Reset 

func (x *UpdatePipelineRequest) Reset()

func (*UpdatePipelineRequest) String 

func (x *UpdatePipelineRequest) String() string

type UpdatePipelineResponse 

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

func (*UpdatePipelineResponse) Descriptor deprecated 

func (*UpdatePipelineResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdatePipelineResponse.ProtoReflect.Descriptor instead.

func (*UpdatePipelineResponse) GetPipeline 

func (x *UpdatePipelineResponse) GetPipeline() *Pipeline

func (*UpdatePipelineResponse) ProtoMessage 

func (*UpdatePipelineResponse) ProtoMessage()

func (*UpdatePipelineResponse) ProtoReflect 

func (x *UpdatePipelineResponse) ProtoReflect() protoreflect.Message

func (*UpdatePipelineResponse) Reset 

func (x *UpdatePipelineResponse) Reset()

func (*UpdatePipelineResponse) String 

func (x *UpdatePipelineResponse) String() string

type UpdateProcessorRequest 

type UpdateProcessorRequest struct {
	Id     string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Config *Processor_Config `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateProcessorRequest) Descriptor deprecated 

func (*UpdateProcessorRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateProcessorRequest.ProtoReflect.Descriptor instead.

func (*UpdateProcessorRequest) GetConfig 

func (x *UpdateProcessorRequest) GetConfig() *Processor_Config

func (*UpdateProcessorRequest) GetId 

func (x *UpdateProcessorRequest) GetId() string

func (*UpdateProcessorRequest) ProtoMessage 

func (*UpdateProcessorRequest) ProtoMessage()

func (*UpdateProcessorRequest) ProtoReflect 

func (x *UpdateProcessorRequest) ProtoReflect() protoreflect.Message

func (*UpdateProcessorRequest) Reset 

func (x *UpdateProcessorRequest) Reset()

func (*UpdateProcessorRequest) String 

func (x *UpdateProcessorRequest) String() string

type UpdateProcessorResponse 

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

func (*UpdateProcessorResponse) Descriptor deprecated 

func (*UpdateProcessorResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateProcessorResponse.ProtoReflect.Descriptor instead.

func (*UpdateProcessorResponse) GetProcessor 

func (x *UpdateProcessorResponse) GetProcessor() *Processor

func (*UpdateProcessorResponse) ProtoMessage 

func (*UpdateProcessorResponse) ProtoMessage()

func (*UpdateProcessorResponse) ProtoReflect 

func (x *UpdateProcessorResponse) ProtoReflect() protoreflect.Message

func (*UpdateProcessorResponse) Reset 

func (x *UpdateProcessorResponse) Reset()

func (*UpdateProcessorResponse) String 

func (x *UpdateProcessorResponse) String() string

type ValidateConnectorRequest added in v0.2.1 

type ValidateConnectorRequest struct {
	Type Connector_Type `protobuf:"varint,1,opt,name=type,proto3,enum=api.v1.Connector_Type" json:"type,omitempty"`
	// Plugin name is the name of the builtin plugin (builtin:name), or the absolute path of a standalone plugin.
	Plugin string `protobuf:"bytes,2,opt,name=plugin,proto3" json:"plugin,omitempty"`
	// Configurations for the connector to get validated
	Config *Connector_Config `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateConnectorRequest) Descriptor deprecated added in v0.2.1 

func (*ValidateConnectorRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateConnectorRequest.ProtoReflect.Descriptor instead.

func (*ValidateConnectorRequest) GetConfig added in v0.2.1 

func (x *ValidateConnectorRequest) GetConfig() *Connector_Config

func (*ValidateConnectorRequest) GetPlugin added in v0.2.1 

func (x *ValidateConnectorRequest) GetPlugin() string

func (*ValidateConnectorRequest) GetType added in v0.2.1 

func (x *ValidateConnectorRequest) GetType() Connector_Type

func (*ValidateConnectorRequest) ProtoMessage added in v0.2.1 

func (*ValidateConnectorRequest) ProtoMessage()

func (*ValidateConnectorRequest) ProtoReflect added in v0.2.1 

func (x *ValidateConnectorRequest) ProtoReflect() protoreflect.Message

func (*ValidateConnectorRequest) Reset added in v0.2.1 

func (x *ValidateConnectorRequest) Reset()

func (*ValidateConnectorRequest) String added in v0.2.1 

func (x *ValidateConnectorRequest) String() string

type ValidateConnectorResponse added in v0.2.1 

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

func (*ValidateConnectorResponse) Descriptor deprecated added in v0.2.1 

func (*ValidateConnectorResponse) Descriptor() ([]byte, []int)

Deprecated: Use ValidateConnectorResponse.ProtoReflect.Descriptor instead.

func (*ValidateConnectorResponse) ProtoMessage added in v0.2.1 

func (*ValidateConnectorResponse) ProtoMessage()

func (*ValidateConnectorResponse) ProtoReflect added in v0.2.1 

func (x *ValidateConnectorResponse) ProtoReflect() protoreflect.Message

func (*ValidateConnectorResponse) Reset added in v0.2.1 

func (x *ValidateConnectorResponse) Reset()

func (*ValidateConnectorResponse) String added in v0.2.1 

func (x *ValidateConnectorResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.