api

Nov 8, 2024

Changes in this version

type UpdateConnectorRequest

+ Plugin string

+ func (x *UpdateConnectorRequest) GetPlugin() string

type UpdateProcessorRequest

+ Plugin string

+ func (x *UpdateProcessorRequest) GetPlugin() string

Oct 9, 2024

Changes in this version

type Pipeline_Status

+ const Pipeline_STATUS_RECOVERING

Mar 7, 2024

Changes in this version

+ const ConnectorService_ListConnectorPlugins_FullMethodName

+ const ProcessorService_ListProcessorPlugins_FullMethodName

+ type ConnectorPluginSpecifications struct

+ Author string

+ Description string

+ DestinationParams map[string]*v1.Parameter

+ Name string

+ SourceParams map[string]*v1.Parameter

+ Summary string

+ Version string

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

+ func (*ConnectorPluginSpecifications) ProtoMessage()

+ func (x *ConnectorPluginSpecifications) GetAuthor() string

+ func (x *ConnectorPluginSpecifications) GetDescription() string

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

+ func (x *ConnectorPluginSpecifications) GetName() string

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

+ func (x *ConnectorPluginSpecifications) GetSummary() string

+ func (x *ConnectorPluginSpecifications) GetVersion() string

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

+ func (x *ConnectorPluginSpecifications) Reset()

+ func (x *ConnectorPluginSpecifications) String() string

type ConnectorServiceClient

+ ListConnectorPlugins func(ctx context.Context, in *ListConnectorPluginsRequest, opts ...grpc.CallOption) (*ListConnectorPluginsResponse, error)

type ConnectorServiceServer

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

type CreateProcessorRequest

+ Plugin string

+ func (x *CreateProcessorRequest) GetPlugin() string

+ type ListConnectorPluginsRequest struct

+ Name string

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

+ func (*ListConnectorPluginsRequest) ProtoMessage()

+ func (x *ListConnectorPluginsRequest) GetName() string

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

+ func (x *ListConnectorPluginsRequest) Reset()

+ func (x *ListConnectorPluginsRequest) String() string

+ type ListConnectorPluginsResponse struct

+ Plugins []*ConnectorPluginSpecifications

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

+ func (*ListConnectorPluginsResponse) ProtoMessage()

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

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

+ func (x *ListConnectorPluginsResponse) Reset()

+ func (x *ListConnectorPluginsResponse) String() string

+ type ListProcessorPluginsRequest struct

+ Name string

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

+ func (*ListProcessorPluginsRequest) ProtoMessage()

+ func (x *ListProcessorPluginsRequest) GetName() string

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

+ func (x *ListProcessorPluginsRequest) Reset()

+ func (x *ListProcessorPluginsRequest) String() string

+ type ListProcessorPluginsResponse struct

+ Plugins []*ProcessorPluginSpecifications

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

+ func (*ListProcessorPluginsResponse) ProtoMessage()

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

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

+ func (x *ListProcessorPluginsResponse) Reset()

+ func (x *ListProcessorPluginsResponse) String() string

type Processor

+ Plugin string

+ func (x *Processor) GetPlugin() string

+ type ProcessorPluginSpecifications struct

+ Author string

+ Description string

+ Name string

+ Parameters map[string]*v1.Parameter

+ Summary string

+ Version string

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

+ func (*ProcessorPluginSpecifications) ProtoMessage()

+ func (x *ProcessorPluginSpecifications) GetAuthor() string

+ func (x *ProcessorPluginSpecifications) GetDescription() string

+ func (x *ProcessorPluginSpecifications) GetName() string

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

+ func (x *ProcessorPluginSpecifications) GetSummary() string

+ func (x *ProcessorPluginSpecifications) GetVersion() string

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

+ func (x *ProcessorPluginSpecifications) Reset()

+ func (x *ProcessorPluginSpecifications) String() string

type ProcessorServiceClient

+ ListProcessorPlugins func(ctx context.Context, in *ListProcessorPluginsRequest, opts ...grpc.CallOption) (*ListProcessorPluginsResponse, error)

type ProcessorServiceServer

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

type UnimplementedConnectorServiceServer

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

type UnimplementedProcessorServiceServer

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

Mar 6, 2024

Changes in this version

type CreateProcessorRequest

+ Condition string

+ func (x *CreateProcessorRequest) GetCondition() string

type Processor

+ Condition string

+ func (x *Processor) GetCondition() string

Apr 11, 2023

Changes in this version

+ const ConnectorService_CreateConnector_FullMethodName

+ const ConnectorService_DeleteConnector_FullMethodName

+ const ConnectorService_GetConnector_FullMethodName

+ const ConnectorService_InspectConnector_FullMethodName

+ const ConnectorService_ListConnectors_FullMethodName

+ const ConnectorService_UpdateConnector_FullMethodName

+ const ConnectorService_ValidateConnector_FullMethodName

+ const InformationService_GetInfo_FullMethodName

+ const PipelineService_CreatePipeline_FullMethodName

+ const PipelineService_DeletePipeline_FullMethodName

+ const PipelineService_ExportPipeline_FullMethodName

+ const PipelineService_GetDLQ_FullMethodName

+ const PipelineService_GetPipeline_FullMethodName

+ const PipelineService_ImportPipeline_FullMethodName

+ const PipelineService_ListPipelines_FullMethodName

+ const PipelineService_StartPipeline_FullMethodName

+ const PipelineService_StopPipeline_FullMethodName

+ const PipelineService_UpdateDLQ_FullMethodName

+ const PipelineService_UpdatePipeline_FullMethodName

+ const PluginService_ListPlugins_FullMethodName

+ const ProcessorService_CreateProcessor_FullMethodName

+ const ProcessorService_DeleteProcessor_FullMethodName

+ const ProcessorService_GetProcessor_FullMethodName

+ const ProcessorService_InspectProcessorIn_FullMethodName

+ const ProcessorService_InspectProcessorOut_FullMethodName

+ const ProcessorService_ListProcessors_FullMethodName

+ const ProcessorService_UpdateProcessor_FullMethodName

type ConnectorServiceClient

+ InspectConnector func(ctx context.Context, in *InspectConnectorRequest, opts ...grpc.CallOption) (ConnectorService_InspectConnectorClient, error)

type ConnectorServiceServer

+ InspectConnector func(*InspectConnectorRequest, ConnectorService_InspectConnectorServer) error

+ type ConnectorService_InspectConnectorClient interface

+ Recv func() (*InspectConnectorResponse, error)

+ type ConnectorService_InspectConnectorServer interface

+ Send func(*InspectConnectorResponse) error

+ type GetDLQRequest struct

+ Id string

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

+ func (*GetDLQRequest) ProtoMessage()

+ func (x *GetDLQRequest) GetId() string

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

+ func (x *GetDLQRequest) Reset()

+ func (x *GetDLQRequest) String() string

+ type GetDLQResponse struct

+ Dlq *Pipeline_DLQ

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

+ func (*GetDLQResponse) ProtoMessage()

+ func (x *GetDLQResponse) GetDlq() *Pipeline_DLQ

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

+ func (x *GetDLQResponse) Reset()

+ func (x *GetDLQResponse) String() string

+ type InspectConnectorRequest struct

+ Id string

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

+ func (*InspectConnectorRequest) ProtoMessage()

+ func (x *InspectConnectorRequest) GetId() string

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

+ func (x *InspectConnectorRequest) Reset()

+ func (x *InspectConnectorRequest) String() string

+ type InspectConnectorResponse struct

+ Record *v1.Record

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

+ func (*InspectConnectorResponse) ProtoMessage()

+ func (x *InspectConnectorResponse) GetRecord() *v1.Record

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

+ func (x *InspectConnectorResponse) Reset()

+ func (x *InspectConnectorResponse) String() string

+ type InspectProcessorInRequest struct

+ Id string

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

+ func (*InspectProcessorInRequest) ProtoMessage()

+ func (x *InspectProcessorInRequest) GetId() string

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

+ func (x *InspectProcessorInRequest) Reset()

+ func (x *InspectProcessorInRequest) String() string

+ type InspectProcessorInResponse struct

+ Record *v1.Record

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

+ func (*InspectProcessorInResponse) ProtoMessage()

+ func (x *InspectProcessorInResponse) GetRecord() *v1.Record

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

+ func (x *InspectProcessorInResponse) Reset()

+ func (x *InspectProcessorInResponse) String() string

+ type InspectProcessorOutRequest struct

+ Id string

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

+ func (*InspectProcessorOutRequest) ProtoMessage()

+ func (x *InspectProcessorOutRequest) GetId() string

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

+ func (x *InspectProcessorOutRequest) Reset()

+ func (x *InspectProcessorOutRequest) String() string

+ type InspectProcessorOutResponse struct

+ Record *v1.Record

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

+ func (*InspectProcessorOutResponse) ProtoMessage()

+ func (x *InspectProcessorOutResponse) GetRecord() *v1.Record

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

+ func (x *InspectProcessorOutResponse) Reset()

+ func (x *InspectProcessorOutResponse) String() string

type PipelineServiceClient

+ GetDLQ func(ctx context.Context, in *GetDLQRequest, opts ...grpc.CallOption) (*GetDLQResponse, error)

+ UpdateDLQ func(ctx context.Context, in *UpdateDLQRequest, opts ...grpc.CallOption) (*UpdateDLQResponse, error)

type PipelineServiceServer

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

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

+ type Pipeline_DLQ struct

+ Plugin string

+ Settings map[string]string

+ WindowNackThreshold uint64

+ WindowSize uint64

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

+ func (*Pipeline_DLQ) ProtoMessage()

+ func (x *Pipeline_DLQ) GetPlugin() string

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

+ func (x *Pipeline_DLQ) GetWindowNackThreshold() uint64

+ func (x *Pipeline_DLQ) GetWindowSize() uint64

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

+ func (x *Pipeline_DLQ) Reset()

+ func (x *Pipeline_DLQ) String() string

type PluginSpecifications_Parameter_Type

+ const PluginSpecifications_Parameter_TYPE_FLOAT

+ const PluginSpecifications_Parameter_TYPE_INT

type ProcessorServiceClient

+ InspectProcessorIn func(ctx context.Context, in *InspectProcessorInRequest, opts ...grpc.CallOption) (ProcessorService_InspectProcessorInClient, error)

+ InspectProcessorOut func(ctx context.Context, in *InspectProcessorOutRequest, opts ...grpc.CallOption) (ProcessorService_InspectProcessorOutClient, error)

type ProcessorServiceServer

+ InspectProcessorIn func(*InspectProcessorInRequest, ProcessorService_InspectProcessorInServer) error

+ InspectProcessorOut func(*InspectProcessorOutRequest, ProcessorService_InspectProcessorOutServer) error

+ type ProcessorService_InspectProcessorInClient interface

+ Recv func() (*InspectProcessorInResponse, error)

+ type ProcessorService_InspectProcessorInServer interface

+ Send func(*InspectProcessorInResponse) error

+ type ProcessorService_InspectProcessorOutClient interface

+ Recv func() (*InspectProcessorOutResponse, error)

+ type ProcessorService_InspectProcessorOutServer interface

+ Send func(*InspectProcessorOutResponse) error

type Processor_Config

+ Workers int32

+ func (x *Processor_Config) GetWorkers() int32

type StopPipelineRequest

+ Force bool

+ func (x *StopPipelineRequest) GetForce() bool

type UnimplementedConnectorServiceServer

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

type UnimplementedPipelineServiceServer

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

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

type UnimplementedProcessorServiceServer

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

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

+ type UpdateDLQRequest struct

+ Dlq *Pipeline_DLQ

+ Id string

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

+ func (*UpdateDLQRequest) ProtoMessage()

+ func (x *UpdateDLQRequest) GetDlq() *Pipeline_DLQ

+ func (x *UpdateDLQRequest) GetId() string

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

+ func (x *UpdateDLQRequest) Reset()

+ func (x *UpdateDLQRequest) String() string

+ type UpdateDLQResponse struct

+ Dlq *Pipeline_DLQ

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

+ func (*UpdateDLQResponse) ProtoMessage()

+ func (x *UpdateDLQResponse) GetDlq() *Pipeline_DLQ

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

+ func (x *UpdateDLQResponse) Reset()

+ func (x *UpdateDLQResponse) String() string

May 12, 2022

Changes in this version

type Connector

+ CreatedAt *timestamppb.Timestamp

+ UpdatedAt *timestamppb.Timestamp

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

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

type ConnectorServiceClient

+ ValidateConnector func(ctx context.Context, in *ValidateConnectorRequest, opts ...grpc.CallOption) (*ValidateConnectorResponse, error)

type ConnectorServiceServer

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

type Pipeline

+ CreatedAt *timestamppb.Timestamp

+ UpdatedAt *timestamppb.Timestamp

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

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

type Processor

+ CreatedAt *timestamppb.Timestamp

+ UpdatedAt *timestamppb.Timestamp

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

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

type UnimplementedConnectorServiceServer

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

+ type ValidateConnectorRequest struct

+ Config *Connector_Config

+ Plugin string

+ Type Connector_Type

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

+ func (*ValidateConnectorRequest) ProtoMessage()

+ func (x *ValidateConnectorRequest) GetConfig() *Connector_Config

+ func (x *ValidateConnectorRequest) GetPlugin() string

+ func (x *ValidateConnectorRequest) GetType() Connector_Type

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

+ func (x *ValidateConnectorRequest) Reset()

+ func (x *ValidateConnectorRequest) String() string

+ type ValidateConnectorResponse struct

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

+ func (*ValidateConnectorResponse) ProtoMessage()

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

+ func (x *ValidateConnectorResponse) Reset()

+ func (x *ValidateConnectorResponse) String() string

Apr 5, 2022

Changes in this version

+ var PluginService_ServiceDesc = grpc.ServiceDesc

+ var PluginSpecifications_Parameter_Type_name = map[int32]string

+ var PluginSpecifications_Parameter_Type_value = map[string]int32

+ var PluginSpecifications_Parameter_Validation_Type_name = map[int32]string

+ var PluginSpecifications_Parameter_Validation_Type_value = map[string]int32

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

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

+ func RegisterPluginServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterPluginServiceServer(s grpc.ServiceRegistrar, srv PluginServiceServer)

type ListPipelinesRequest

+ Name string

+ func (x *ListPipelinesRequest) GetName() string

+ type ListPluginsRequest struct

+ Name string

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

+ func (*ListPluginsRequest) ProtoMessage()

+ func (x *ListPluginsRequest) GetName() string

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

+ func (x *ListPluginsRequest) Reset()

+ func (x *ListPluginsRequest) String() string

+ type ListPluginsResponse struct

+ Plugins []*PluginSpecifications

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

+ func (*ListPluginsResponse) ProtoMessage()

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

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

+ func (x *ListPluginsResponse) Reset()

+ func (x *ListPluginsResponse) String() string

+ type PluginServiceClient interface

+ ListPlugins func(ctx context.Context, in *ListPluginsRequest, opts ...grpc.CallOption) (*ListPluginsResponse, error)

+ func NewPluginServiceClient(cc grpc.ClientConnInterface) PluginServiceClient

+ type PluginServiceServer interface

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

+ type PluginSpecifications struct

+ Author string

+ Description string

+ DestinationParams map[string]*PluginSpecifications_Parameter

+ Name string

+ SourceParams map[string]*PluginSpecifications_Parameter

+ Summary string

+ Version string

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

+ func (*PluginSpecifications) ProtoMessage()

+ func (x *PluginSpecifications) GetAuthor() string

+ func (x *PluginSpecifications) GetDescription() string

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

+ func (x *PluginSpecifications) GetName() string

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

+ func (x *PluginSpecifications) GetSummary() string

+ func (x *PluginSpecifications) GetVersion() string

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

+ func (x *PluginSpecifications) Reset()

+ func (x *PluginSpecifications) String() string

+ type PluginSpecifications_Parameter struct

+ Default string

+ Description string

+ Type PluginSpecifications_Parameter_Type

+ Validations []*PluginSpecifications_Parameter_Validation

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

+ func (*PluginSpecifications_Parameter) ProtoMessage()

+ func (x *PluginSpecifications_Parameter) GetDefault() string

+ func (x *PluginSpecifications_Parameter) GetDescription() string

+ func (x *PluginSpecifications_Parameter) GetType() PluginSpecifications_Parameter_Type

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

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

+ func (x *PluginSpecifications_Parameter) Reset()

+ func (x *PluginSpecifications_Parameter) String() string

+ type PluginSpecifications_Parameter_Type int32

+ const PluginSpecifications_Parameter_TYPE_BOOL

+ const PluginSpecifications_Parameter_TYPE_DURATION

+ const PluginSpecifications_Parameter_TYPE_FILE

+ const PluginSpecifications_Parameter_TYPE_NUMBER

+ const PluginSpecifications_Parameter_TYPE_STRING

+ const PluginSpecifications_Parameter_TYPE_UNSPECIFIED

+ func (PluginSpecifications_Parameter_Type) Descriptor() protoreflect.EnumDescriptor

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

+ func (PluginSpecifications_Parameter_Type) Type() protoreflect.EnumType

+ func (x PluginSpecifications_Parameter_Type) Enum() *PluginSpecifications_Parameter_Type

+ func (x PluginSpecifications_Parameter_Type) Number() protoreflect.EnumNumber

+ func (x PluginSpecifications_Parameter_Type) String() string

+ type PluginSpecifications_Parameter_Validation struct

+ Type PluginSpecifications_Parameter_Validation_Type

+ Value string

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

+ func (*PluginSpecifications_Parameter_Validation) ProtoMessage()

+ func (x *PluginSpecifications_Parameter_Validation) GetType() PluginSpecifications_Parameter_Validation_Type

+ func (x *PluginSpecifications_Parameter_Validation) GetValue() string

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

+ func (x *PluginSpecifications_Parameter_Validation) Reset()

+ func (x *PluginSpecifications_Parameter_Validation) String() string

+ type PluginSpecifications_Parameter_Validation_Type int32

+ const PluginSpecifications_Parameter_Validation_TYPE_EXCLUSION

+ const PluginSpecifications_Parameter_Validation_TYPE_GREATER_THAN

+ const PluginSpecifications_Parameter_Validation_TYPE_INCLUSION

+ const PluginSpecifications_Parameter_Validation_TYPE_LESS_THAN

+ const PluginSpecifications_Parameter_Validation_TYPE_REGEX

+ const PluginSpecifications_Parameter_Validation_TYPE_REQUIRED

+ const PluginSpecifications_Parameter_Validation_TYPE_UNSPECIFIED

+ func (PluginSpecifications_Parameter_Validation_Type) Descriptor() protoreflect.EnumDescriptor

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

+ func (PluginSpecifications_Parameter_Validation_Type) Type() protoreflect.EnumType

+ func (x PluginSpecifications_Parameter_Validation_Type) Enum() *PluginSpecifications_Parameter_Validation_Type

+ func (x PluginSpecifications_Parameter_Validation_Type) Number() protoreflect.EnumNumber

+ func (x PluginSpecifications_Parameter_Validation_Type) String() string

+ type UnimplementedPluginServiceServer struct

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

+ type UnsafePluginServiceServer interface

Jan 20, 2022

Changes in this version

+ var ConnectorService_ServiceDesc = grpc.ServiceDesc

+ var Connector_Type_name = map[int32]string

+ var Connector_Type_value = map[string]int32

+ var File_api_v1_api_proto protoreflect.FileDescriptor

+ var InformationService_ServiceDesc = grpc.ServiceDesc

+ var PipelineService_ServiceDesc = grpc.ServiceDesc

+ var Pipeline_Status_name = map[int32]string

+ var Pipeline_Status_value = map[string]int32

+ var ProcessorService_ServiceDesc = grpc.ServiceDesc

+ var Processor_Parent_Type_name = map[int32]string

+ var Processor_Parent_Type_value = map[string]int32

+ var Processor_Type_name = map[int32]string

+ var Processor_Type_value = map[string]int32

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

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

+ func RegisterConnectorServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterConnectorServiceServer(s grpc.ServiceRegistrar, srv ConnectorServiceServer)

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

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

+ func RegisterInformationServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterInformationServiceServer(s grpc.ServiceRegistrar, srv InformationServiceServer)

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

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

+ func RegisterPipelineServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterPipelineServiceServer(s grpc.ServiceRegistrar, srv PipelineServiceServer)

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

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

+ func RegisterProcessorServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterProcessorServiceServer(s grpc.ServiceRegistrar, srv ProcessorServiceServer)

+ type Connector struct

+ Config *Connector_Config

+ Id string

+ PipelineId string

+ Plugin string

+ ProcessorIds []string

+ State isConnector_State

+ Type Connector_Type

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

+ func (*Connector) ProtoMessage()

+ func (m *Connector) GetState() isConnector_State

+ func (x *Connector) GetConfig() *Connector_Config

+ func (x *Connector) GetDestinationState() *Connector_DestinationState

+ func (x *Connector) GetId() string

+ func (x *Connector) GetPipelineId() string

+ func (x *Connector) GetPlugin() string

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

+ func (x *Connector) GetSourceState() *Connector_SourceState

+ func (x *Connector) GetType() Connector_Type

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

+ func (x *Connector) Reset()

+ func (x *Connector) String() string

+ type ConnectorServiceClient interface

+ CreateConnector func(ctx context.Context, in *CreateConnectorRequest, opts ...grpc.CallOption) (*CreateConnectorResponse, error)

+ DeleteConnector func(ctx context.Context, in *DeleteConnectorRequest, opts ...grpc.CallOption) (*DeleteConnectorResponse, error)

+ GetConnector func(ctx context.Context, in *GetConnectorRequest, opts ...grpc.CallOption) (*GetConnectorResponse, error)

+ ListConnectors func(ctx context.Context, in *ListConnectorsRequest, opts ...grpc.CallOption) (*ListConnectorsResponse, error)

+ UpdateConnector func(ctx context.Context, in *UpdateConnectorRequest, opts ...grpc.CallOption) (*UpdateConnectorResponse, error)

+ func NewConnectorServiceClient(cc grpc.ClientConnInterface) ConnectorServiceClient

+ type ConnectorServiceServer interface

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

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

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

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

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

+ type Connector_Config struct

+ Name string

+ Settings map[string]string

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

+ func (*Connector_Config) ProtoMessage()

+ func (x *Connector_Config) GetName() string

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

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

+ func (x *Connector_Config) Reset()

+ func (x *Connector_Config) String() string

+ type Connector_DestinationState struct

+ Positions map[string][]byte

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

+ func (*Connector_DestinationState) ProtoMessage()

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

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

+ func (x *Connector_DestinationState) Reset()

+ func (x *Connector_DestinationState) String() string

+ type Connector_DestinationState_ struct

+ DestinationState *Connector_DestinationState

+ type Connector_SourceState struct

+ Position []byte

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

+ func (*Connector_SourceState) ProtoMessage()

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

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

+ func (x *Connector_SourceState) Reset()

+ func (x *Connector_SourceState) String() string

+ type Connector_SourceState_ struct

+ SourceState *Connector_SourceState

+ type Connector_Type int32

+ const Connector_TYPE_DESTINATION

+ const Connector_TYPE_SOURCE

+ const Connector_TYPE_UNSPECIFIED

+ func (Connector_Type) Descriptor() protoreflect.EnumDescriptor

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

+ func (Connector_Type) Type() protoreflect.EnumType

+ func (x Connector_Type) Enum() *Connector_Type

+ func (x Connector_Type) Number() protoreflect.EnumNumber

+ func (x Connector_Type) String() string

+ type CreateConnectorRequest struct

+ Config *Connector_Config

+ PipelineId string

+ Plugin string

+ Type Connector_Type

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

+ func (*CreateConnectorRequest) ProtoMessage()

+ func (x *CreateConnectorRequest) GetConfig() *Connector_Config

+ func (x *CreateConnectorRequest) GetPipelineId() string

+ func (x *CreateConnectorRequest) GetPlugin() string

+ func (x *CreateConnectorRequest) GetType() Connector_Type

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

+ func (x *CreateConnectorRequest) Reset()

+ func (x *CreateConnectorRequest) String() string

+ type CreateConnectorResponse struct

+ Connector *Connector

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

+ func (*CreateConnectorResponse) ProtoMessage()

+ func (x *CreateConnectorResponse) GetConnector() *Connector

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

+ func (x *CreateConnectorResponse) Reset()

+ func (x *CreateConnectorResponse) String() string

+ type CreatePipelineRequest struct

+ Config *Pipeline_Config

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

+ func (*CreatePipelineRequest) ProtoMessage()

+ func (x *CreatePipelineRequest) GetConfig() *Pipeline_Config

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

+ func (x *CreatePipelineRequest) Reset()

+ func (x *CreatePipelineRequest) String() string

+ type CreatePipelineResponse struct

+ Pipeline *Pipeline

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

+ func (*CreatePipelineResponse) ProtoMessage()

+ func (x *CreatePipelineResponse) GetPipeline() *Pipeline

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

+ func (x *CreatePipelineResponse) Reset()

+ func (x *CreatePipelineResponse) String() string

+ type CreateProcessorRequest struct

+ Config *Processor_Config

+ Name string

+ Parent *Processor_Parent

+ Type Processor_Type

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

+ func (*CreateProcessorRequest) ProtoMessage()

+ func (x *CreateProcessorRequest) GetConfig() *Processor_Config

+ func (x *CreateProcessorRequest) GetName() string

+ func (x *CreateProcessorRequest) GetParent() *Processor_Parent

+ func (x *CreateProcessorRequest) GetType() Processor_Type

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

+ func (x *CreateProcessorRequest) Reset()

+ func (x *CreateProcessorRequest) String() string

+ type CreateProcessorResponse struct

+ Processor *Processor

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

+ func (*CreateProcessorResponse) ProtoMessage()

+ func (x *CreateProcessorResponse) GetProcessor() *Processor

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

+ func (x *CreateProcessorResponse) Reset()

+ func (x *CreateProcessorResponse) String() string

+ type DeleteConnectorRequest struct

+ Id string

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

+ func (*DeleteConnectorRequest) ProtoMessage()

+ func (x *DeleteConnectorRequest) GetId() string

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

+ func (x *DeleteConnectorRequest) Reset()

+ func (x *DeleteConnectorRequest) String() string

+ type DeleteConnectorResponse struct

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

+ func (*DeleteConnectorResponse) ProtoMessage()

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

+ func (x *DeleteConnectorResponse) Reset()

+ func (x *DeleteConnectorResponse) String() string

+ type DeletePipelineRequest struct

+ Id string

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

+ func (*DeletePipelineRequest) ProtoMessage()

+ func (x *DeletePipelineRequest) GetId() string

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

+ func (x *DeletePipelineRequest) Reset()

+ func (x *DeletePipelineRequest) String() string

+ type DeletePipelineResponse struct

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

+ func (*DeletePipelineResponse) ProtoMessage()

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

+ func (x *DeletePipelineResponse) Reset()

+ func (x *DeletePipelineResponse) String() string

+ type DeleteProcessorRequest struct

+ Id string

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

+ func (*DeleteProcessorRequest) ProtoMessage()

+ func (x *DeleteProcessorRequest) GetId() string

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

+ func (x *DeleteProcessorRequest) Reset()

+ func (x *DeleteProcessorRequest) String() string

+ type DeleteProcessorResponse struct

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

+ func (*DeleteProcessorResponse) ProtoMessage()

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

+ func (x *DeleteProcessorResponse) Reset()

+ func (x *DeleteProcessorResponse) String() string

+ type ExportPipelineRequest struct

+ Id string

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

+ func (*ExportPipelineRequest) ProtoMessage()

+ func (x *ExportPipelineRequest) GetId() string

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

+ func (x *ExportPipelineRequest) Reset()

+ func (x *ExportPipelineRequest) String() string

+ type ExportPipelineResponse struct

+ Pipeline *Pipeline

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

+ func (*ExportPipelineResponse) ProtoMessage()

+ func (x *ExportPipelineResponse) GetPipeline() *Pipeline

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

+ func (x *ExportPipelineResponse) Reset()

+ func (x *ExportPipelineResponse) String() string

+ type GetConnectorRequest struct

+ Id string

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

+ func (*GetConnectorRequest) ProtoMessage()

+ func (x *GetConnectorRequest) GetId() string

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

+ func (x *GetConnectorRequest) Reset()

+ func (x *GetConnectorRequest) String() string

+ type GetConnectorResponse struct

+ Connector *Connector

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

+ func (*GetConnectorResponse) ProtoMessage()

+ func (x *GetConnectorResponse) GetConnector() *Connector

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

+ func (x *GetConnectorResponse) Reset()

+ func (x *GetConnectorResponse) String() string

+ type GetInfoRequest struct

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

+ func (*GetInfoRequest) ProtoMessage()

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

+ func (x *GetInfoRequest) Reset()

+ func (x *GetInfoRequest) String() string

+ type GetInfoResponse struct

+ Info *Info

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

+ func (*GetInfoResponse) ProtoMessage()

+ func (x *GetInfoResponse) GetInfo() *Info

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

+ func (x *GetInfoResponse) Reset()

+ func (x *GetInfoResponse) String() string

+ type GetPipelineRequest struct

+ Id string

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

+ func (*GetPipelineRequest) ProtoMessage()

+ func (x *GetPipelineRequest) GetId() string

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

+ func (x *GetPipelineRequest) Reset()

+ func (x *GetPipelineRequest) String() string

+ type GetPipelineResponse struct

+ Pipeline *Pipeline

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

+ func (*GetPipelineResponse) ProtoMessage()

+ func (x *GetPipelineResponse) GetPipeline() *Pipeline

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

+ func (x *GetPipelineResponse) Reset()

+ func (x *GetPipelineResponse) String() string

+ type GetProcessorRequest struct

+ Id string

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

+ func (*GetProcessorRequest) ProtoMessage()

+ func (x *GetProcessorRequest) GetId() string

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

+ func (x *GetProcessorRequest) Reset()

+ func (x *GetProcessorRequest) String() string

+ type GetProcessorResponse struct

+ Processor *Processor

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

+ func (*GetProcessorResponse) ProtoMessage()

+ func (x *GetProcessorResponse) GetProcessor() *Processor

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

+ func (x *GetProcessorResponse) Reset()

+ func (x *GetProcessorResponse) String() string

+ type ImportPipelineRequest struct

+ Pipeline *Pipeline

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

+ func (*ImportPipelineRequest) ProtoMessage()

+ func (x *ImportPipelineRequest) GetPipeline() *Pipeline

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

+ func (x *ImportPipelineRequest) Reset()

+ func (x *ImportPipelineRequest) String() string

+ type ImportPipelineResponse struct

+ Pipeline *Pipeline

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

+ func (*ImportPipelineResponse) ProtoMessage()

+ func (x *ImportPipelineResponse) GetPipeline() *Pipeline

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

+ func (x *ImportPipelineResponse) Reset()

+ func (x *ImportPipelineResponse) String() string

+ type Info struct

+ Arch string

+ Os string

+ Version string

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

+ func (*Info) ProtoMessage()

+ func (x *Info) GetArch() string

+ func (x *Info) GetOs() string

+ func (x *Info) GetVersion() string

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

+ func (x *Info) Reset()

+ func (x *Info) String() string

+ type InformationServiceClient interface

+ GetInfo func(ctx context.Context, in *GetInfoRequest, opts ...grpc.CallOption) (*GetInfoResponse, error)

+ func NewInformationServiceClient(cc grpc.ClientConnInterface) InformationServiceClient

+ type InformationServiceServer interface

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

+ type ListConnectorsRequest struct

+ PipelineId string

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

+ func (*ListConnectorsRequest) ProtoMessage()

+ func (x *ListConnectorsRequest) GetPipelineId() string

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

+ func (x *ListConnectorsRequest) Reset()

+ func (x *ListConnectorsRequest) String() string

+ type ListConnectorsResponse struct

+ Connectors []*Connector

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

+ func (*ListConnectorsResponse) ProtoMessage()

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

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

+ func (x *ListConnectorsResponse) Reset()

+ func (x *ListConnectorsResponse) String() string

+ type ListPipelinesRequest struct

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

+ func (*ListPipelinesRequest) ProtoMessage()

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

+ func (x *ListPipelinesRequest) Reset()

+ func (x *ListPipelinesRequest) String() string

+ type ListPipelinesResponse struct

+ Pipelines []*Pipeline

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

+ func (*ListPipelinesResponse) ProtoMessage()

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

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

+ func (x *ListPipelinesResponse) Reset()

+ func (x *ListPipelinesResponse) String() string

+ type ListProcessorsRequest struct

+ ParentIds []string

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

+ func (*ListProcessorsRequest) ProtoMessage()

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

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

+ func (x *ListProcessorsRequest) Reset()

+ func (x *ListProcessorsRequest) String() string

+ type ListProcessorsResponse struct

+ Processors []*Processor

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

+ func (*ListProcessorsResponse) ProtoMessage()

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

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

+ func (x *ListProcessorsResponse) Reset()

+ func (x *ListProcessorsResponse) String() string

+ type Pipeline struct

+ Config *Pipeline_Config

+ ConnectorIds []string

+ Id string

+ ProcessorIds []string

+ State *Pipeline_State

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

+ func (*Pipeline) ProtoMessage()

+ func (x *Pipeline) GetConfig() *Pipeline_Config

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

+ func (x *Pipeline) GetId() string

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

+ func (x *Pipeline) GetState() *Pipeline_State

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

+ func (x *Pipeline) Reset()

+ func (x *Pipeline) String() string

+ type PipelineServiceClient interface

+ CreatePipeline func(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*CreatePipelineResponse, error)

+ DeletePipeline func(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*DeletePipelineResponse, error)

+ ExportPipeline func(ctx context.Context, in *ExportPipelineRequest, opts ...grpc.CallOption) (*ExportPipelineResponse, error)

+ GetPipeline func(ctx context.Context, in *GetPipelineRequest, opts ...grpc.CallOption) (*GetPipelineResponse, error)

+ ImportPipeline func(ctx context.Context, in *ImportPipelineRequest, opts ...grpc.CallOption) (*ImportPipelineResponse, error)

+ ListPipelines func(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (*ListPipelinesResponse, error)

+ StartPipeline func(ctx context.Context, in *StartPipelineRequest, opts ...grpc.CallOption) (*StartPipelineResponse, error)

+ StopPipeline func(ctx context.Context, in *StopPipelineRequest, opts ...grpc.CallOption) (*StopPipelineResponse, error)

+ UpdatePipeline func(ctx context.Context, in *UpdatePipelineRequest, opts ...grpc.CallOption) (*UpdatePipelineResponse, error)

+ func NewPipelineServiceClient(cc grpc.ClientConnInterface) PipelineServiceClient

+ type PipelineServiceServer interface

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

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

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

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

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

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

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

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

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

+ type Pipeline_Config struct

+ Description string

+ Name string

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

+ func (*Pipeline_Config) ProtoMessage()

+ func (x *Pipeline_Config) GetDescription() string

+ func (x *Pipeline_Config) GetName() string

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

+ func (x *Pipeline_Config) Reset()

+ func (x *Pipeline_Config) String() string

+ type Pipeline_State struct

+ Error string

+ Status Pipeline_Status

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

+ func (*Pipeline_State) ProtoMessage()

+ func (x *Pipeline_State) GetError() string

+ func (x *Pipeline_State) GetStatus() Pipeline_Status

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

+ func (x *Pipeline_State) Reset()

+ func (x *Pipeline_State) String() string

+ type Pipeline_Status int32

+ const Pipeline_STATUS_DEGRADED

+ const Pipeline_STATUS_RUNNING

+ const Pipeline_STATUS_STOPPED

+ const Pipeline_STATUS_UNSPECIFIED

+ func (Pipeline_Status) Descriptor() protoreflect.EnumDescriptor

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

+ func (Pipeline_Status) Type() protoreflect.EnumType

+ func (x Pipeline_Status) Enum() *Pipeline_Status

+ func (x Pipeline_Status) Number() protoreflect.EnumNumber

+ func (x Pipeline_Status) String() string

+ type Processor struct

+ Config *Processor_Config

+ Id string

+ Name string

+ Parent *Processor_Parent

+ Type Processor_Type

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

+ func (*Processor) ProtoMessage()

+ func (x *Processor) GetConfig() *Processor_Config

+ func (x *Processor) GetId() string

+ func (x *Processor) GetName() string

+ func (x *Processor) GetParent() *Processor_Parent

+ func (x *Processor) GetType() Processor_Type

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

+ func (x *Processor) Reset()

+ func (x *Processor) String() string

+ type ProcessorServiceClient interface

+ CreateProcessor func(ctx context.Context, in *CreateProcessorRequest, opts ...grpc.CallOption) (*CreateProcessorResponse, error)

+ DeleteProcessor func(ctx context.Context, in *DeleteProcessorRequest, opts ...grpc.CallOption) (*DeleteProcessorResponse, error)

+ GetProcessor func(ctx context.Context, in *GetProcessorRequest, opts ...grpc.CallOption) (*GetProcessorResponse, error)

+ ListProcessors func(ctx context.Context, in *ListProcessorsRequest, opts ...grpc.CallOption) (*ListProcessorsResponse, error)

+ UpdateProcessor func(ctx context.Context, in *UpdateProcessorRequest, opts ...grpc.CallOption) (*UpdateProcessorResponse, error)

+ func NewProcessorServiceClient(cc grpc.ClientConnInterface) ProcessorServiceClient

+ type ProcessorServiceServer interface

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

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

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

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

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

+ type Processor_Config struct

+ Settings map[string]string

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

+ func (*Processor_Config) ProtoMessage()

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

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

+ func (x *Processor_Config) Reset()

+ func (x *Processor_Config) String() string

+ type Processor_Parent struct

+ Id string

+ Type Processor_Parent_Type

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

+ func (*Processor_Parent) ProtoMessage()

+ func (x *Processor_Parent) GetId() string

+ func (x *Processor_Parent) GetType() Processor_Parent_Type

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

+ func (x *Processor_Parent) Reset()

+ func (x *Processor_Parent) String() string

+ type Processor_Parent_Type int32

+ const Processor_Parent_TYPE_CONNECTOR

+ const Processor_Parent_TYPE_PIPELINE

+ const Processor_Parent_TYPE_UNSPECIFIED

+ func (Processor_Parent_Type) Descriptor() protoreflect.EnumDescriptor

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

+ func (Processor_Parent_Type) Type() protoreflect.EnumType

+ func (x Processor_Parent_Type) Enum() *Processor_Parent_Type

+ func (x Processor_Parent_Type) Number() protoreflect.EnumNumber

+ func (x Processor_Parent_Type) String() string

+ type Processor_Type int32

+ const Processor_TYPE_FILTER

+ const Processor_TYPE_TRANSFORM

+ const Processor_TYPE_UNSPECIFIED

+ func (Processor_Type) Descriptor() protoreflect.EnumDescriptor

+ func (Processor_Type) EnumDescriptor() ([]byte, []int)

+ func (Processor_Type) Type() protoreflect.EnumType

+ func (x Processor_Type) Enum() *Processor_Type

+ func (x Processor_Type) Number() protoreflect.EnumNumber

+ func (x Processor_Type) String() string

+ type StartPipelineRequest struct

+ Id string

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

+ func (*StartPipelineRequest) ProtoMessage()

+ func (x *StartPipelineRequest) GetId() string

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

+ func (x *StartPipelineRequest) Reset()

+ func (x *StartPipelineRequest) String() string

+ type StartPipelineResponse struct

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

+ func (*StartPipelineResponse) ProtoMessage()

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

+ func (x *StartPipelineResponse) Reset()

+ func (x *StartPipelineResponse) String() string

+ type StopPipelineRequest struct

+ Id string

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

+ func (*StopPipelineRequest) ProtoMessage()

+ func (x *StopPipelineRequest) GetId() string

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

+ func (x *StopPipelineRequest) Reset()

+ func (x *StopPipelineRequest) String() string

+ type StopPipelineResponse struct

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

+ func (*StopPipelineResponse) ProtoMessage()

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

+ func (x *StopPipelineResponse) Reset()

+ func (x *StopPipelineResponse) String() string

+ type UnimplementedConnectorServiceServer struct

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

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

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

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

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

+ type UnimplementedInformationServiceServer struct

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

+ type UnimplementedPipelineServiceServer struct

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

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

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

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

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

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

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

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

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

+ type UnimplementedProcessorServiceServer struct

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

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

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

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

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

+ type UnsafeConnectorServiceServer interface

+ type UnsafeInformationServiceServer interface

+ type UnsafePipelineServiceServer interface

+ type UnsafeProcessorServiceServer interface

+ type UpdateConnectorRequest struct

+ Config *Connector_Config

+ Id string

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

+ func (*UpdateConnectorRequest) ProtoMessage()

+ func (x *UpdateConnectorRequest) GetConfig() *Connector_Config

+ func (x *UpdateConnectorRequest) GetId() string

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

+ func (x *UpdateConnectorRequest) Reset()

+ func (x *UpdateConnectorRequest) String() string

+ type UpdateConnectorResponse struct

+ Connector *Connector

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

+ func (*UpdateConnectorResponse) ProtoMessage()

+ func (x *UpdateConnectorResponse) GetConnector() *Connector

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

+ func (x *UpdateConnectorResponse) Reset()

+ func (x *UpdateConnectorResponse) String() string

+ type UpdatePipelineRequest struct

+ Config *Pipeline_Config

+ Id string

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

+ func (*UpdatePipelineRequest) ProtoMessage()

+ func (x *UpdatePipelineRequest) GetConfig() *Pipeline_Config

+ func (x *UpdatePipelineRequest) GetId() string

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

+ func (x *UpdatePipelineRequest) Reset()

+ func (x *UpdatePipelineRequest) String() string

+ type UpdatePipelineResponse struct

+ Pipeline *Pipeline

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

+ func (*UpdatePipelineResponse) ProtoMessage()

+ func (x *UpdatePipelineResponse) GetPipeline() *Pipeline

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

+ func (x *UpdatePipelineResponse) Reset()

+ func (x *UpdatePipelineResponse) String() string

+ type UpdateProcessorRequest struct

+ Config *Processor_Config

+ Id string

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

+ func (*UpdateProcessorRequest) ProtoMessage()

+ func (x *UpdateProcessorRequest) GetConfig() *Processor_Config

+ func (x *UpdateProcessorRequest) GetId() string

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

+ func (x *UpdateProcessorRequest) Reset()

+ func (x *UpdateProcessorRequest) String() string

+ type UpdateProcessorResponse struct

+ Processor *Processor

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

+ func (*UpdateProcessorResponse) ProtoMessage()

+ func (x *UpdateProcessorResponse) GetProcessor() *Processor

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

+ func (x *UpdateProcessorResponse) Reset()

+ func (x *UpdateProcessorResponse) String() string