api

package
v0.2.0-nightly.20220214 Latest Latest
Warning

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

 Go to latest Published: Feb 11, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

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_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_TRANSFORM",
		2: "TYPE_FILTER",
	}
	Processor_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"TYPE_TRANSFORM":   1,
		"TYPE_FILTER":      2,
	}
)

Enum value maps for Processor_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 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: "UpdateConnector",
			Handler:    _ConnectorService_UpdateConnector_Handler,
		},
		{
			MethodName: "DeleteConnector",
			Handler:    _ConnectorService_DeleteConnector_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	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: "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 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,
		},
	},
	Streams:  []grpc.StreamDesc{},
	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 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"`
	// -- children connections ---------------------------------------------------
	ProcessorIds []string `protobuf:"bytes,8,rep,name=processor_ids,json=processorIds,proto3" json:"processor_ids,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) 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) 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 ConnectorServiceClient 

type ConnectorServiceClient interface {
	ListConnectors(ctx context.Context, in *ListConnectorsRequest, opts ...grpc.CallOption) (*ListConnectorsResponse, error)
	GetConnector(ctx context.Context, in *GetConnectorRequest, opts ...grpc.CallOption) (*GetConnectorResponse, error)
	CreateConnector(ctx context.Context, in *CreateConnectorRequest, opts ...grpc.CallOption) (*CreateConnectorResponse, error)
	UpdateConnector(ctx context.Context, in *UpdateConnectorRequest, opts ...grpc.CallOption) (*UpdateConnectorResponse, error)
	DeleteConnector(ctx context.Context, in *DeleteConnectorRequest, opts ...grpc.CallOption) (*DeleteConnectorResponse, 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.

func NewConnectorServiceClient 

func NewConnectorServiceClient(cc grpc.ClientConnInterface) ConnectorServiceClient

type ConnectorServiceServer 

type ConnectorServiceServer interface {
	ListConnectors(context.Context, *ListConnectorsRequest) (*ListConnectorsResponse, error)
	GetConnector(context.Context, *GetConnectorRequest) (*GetConnectorResponse, error)
	CreateConnector(context.Context, *CreateConnectorRequest) (*CreateConnectorResponse, error)
	UpdateConnector(context.Context, *UpdateConnectorRequest) (*UpdateConnectorResponse, error)
	DeleteConnector(context.Context, *DeleteConnectorRequest) (*DeleteConnectorResponse, error)
	// contains filtered or unexported methods
}

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

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
const (
	Connector_TYPE_UNSPECIFIED Connector_Type = 0
	Connector_TYPE_SOURCE      Connector_Type = 1
	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"`
	Plugin     string            `protobuf:"bytes,2,opt,name=plugin,proto3" json:"plugin,omitempty"`
	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 {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type   Processor_Type    `protobuf:"varint,2,opt,name=type,proto3,enum=api.v1.Processor_Type" 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"`
	// contains filtered or unexported fields
}

func (*CreateProcessorRequest) Descriptor deprecated 

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

Deprecated: Use CreateProcessorRequest.ProtoReflect.Descriptor instead.

func (*CreateProcessorRequest) GetConfig 

func (x *CreateProcessorRequest) GetConfig() *Processor_Config

func (*CreateProcessorRequest) GetName 

func (x *CreateProcessorRequest) GetName() string

func (*CreateProcessorRequest) GetParent 

func (x *CreateProcessorRequest) GetParent() *Processor_Parent

func (*CreateProcessorRequest) GetType 

func (x *CreateProcessorRequest) GetType() Processor_Type

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 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 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 {
	// contains filtered or unexported fields
}

func (*ListPipelinesRequest) Descriptor deprecated 

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

Deprecated: Use ListPipelinesRequest.ProtoReflect.Descriptor instead.

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 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"`
	// -- children connections ---------------------------------------------------
	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"`
	// 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) 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) 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)
	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.

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

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_State 

type Pipeline_State struct {
	Status Pipeline_Status `protobuf:"varint,1,opt,name=status,proto3,enum=api.v1.Pipeline_Status" json:"status,omitempty"`
	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
const (
	Pipeline_STATUS_UNSPECIFIED Pipeline_Status = 0
	Pipeline_STATUS_RUNNING     Pipeline_Status = 1
	Pipeline_STATUS_STOPPED     Pipeline_Status = 2
	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 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"`
	Name   string            `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Type   Processor_Type    `protobuf:"varint,5,opt,name=type,proto3,enum=api.v1.Processor_Type" json:"type,omitempty"`
	Parent *Processor_Parent `protobuf:"bytes,6,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

func (*Processor) Descriptor deprecated 

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

Deprecated: Use Processor.ProtoReflect.Descriptor instead.

func (*Processor) GetConfig 

func (x *Processor) GetConfig() *Processor_Config

func (*Processor) GetId 

func (x *Processor) GetId() string

func (*Processor) GetName 

func (x *Processor) GetName() string

func (*Processor) GetParent 

func (x *Processor) GetParent() *Processor_Parent

func (*Processor) GetType 

func (x *Processor) GetType() Processor_Type

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 ProcessorServiceClient 

type ProcessorServiceClient interface {
	ListProcessors(ctx context.Context, in *ListProcessorsRequest, opts ...grpc.CallOption) (*ListProcessorsResponse, 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)
}

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.

func NewProcessorServiceClient 

func NewProcessorServiceClient(cc grpc.ClientConnInterface) ProcessorServiceClient

type ProcessorServiceServer 

type ProcessorServiceServer interface {
	ListProcessors(context.Context, *ListProcessorsRequest) (*ListProcessorsResponse, 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)
	// contains filtered or unexported methods
}

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

type Processor_Config 

type Processor_Config struct {
	Settings map[string]string `` /* 157-byte string literal not displayed */
	// 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) 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
const (
	Processor_Parent_TYPE_UNSPECIFIED Processor_Parent_Type = 0
	Processor_Parent_TYPE_CONNECTOR   Processor_Parent_Type = 1
	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 Processor_Type 

type Processor_Type int32
const (
	Processor_TYPE_UNSPECIFIED Processor_Type = 0
	Processor_TYPE_TRANSFORM   Processor_Type = 1
	Processor_TYPE_FILTER      Processor_Type = 2
)

func (Processor_Type) Descriptor 

func (Processor_Type) Descriptor() protoreflect.EnumDescriptor

func (Processor_Type) Enum 

func (x Processor_Type) Enum() *Processor_Type

func (Processor_Type) EnumDescriptor deprecated 

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

Deprecated: Use Processor_Type.Descriptor instead.

func (Processor_Type) Number 

func (x Processor_Type) Number() protoreflect.EnumNumber

func (Processor_Type) String 

func (x Processor_Type) String() string

func (Processor_Type) Type 

func (Processor_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"`
	// contains filtered or unexported fields
}

func (*StopPipelineRequest) Descriptor deprecated 

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

Deprecated: Use StopPipelineRequest.ProtoReflect.Descriptor instead.

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

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

func (UnimplementedConnectorServiceServer) UpdateConnector 

func (UnimplementedConnectorServiceServer) UpdateConnector(context.Context, *UpdateConnectorRequest) (*UpdateConnectorResponse, 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) 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) UpdatePipeline 

func (UnimplementedPipelineServiceServer) UpdatePipeline(context.Context, *UpdatePipelineRequest) (*UpdatePipelineResponse, 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) 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 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 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

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.