connectorv1

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Mar 17, 2023 License: Apache-2.0 Imports: 10 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	SourcePlugin_Configure_FullMethodName          = "/connector.v1.SourcePlugin/Configure"
	SourcePlugin_Start_FullMethodName              = "/connector.v1.SourcePlugin/Start"
	SourcePlugin_Run_FullMethodName                = "/connector.v1.SourcePlugin/Run"
	SourcePlugin_Stop_FullMethodName               = "/connector.v1.SourcePlugin/Stop"
	SourcePlugin_Teardown_FullMethodName           = "/connector.v1.SourcePlugin/Teardown"
	SourcePlugin_LifecycleOnCreated_FullMethodName = "/connector.v1.SourcePlugin/LifecycleOnCreated"
	SourcePlugin_LifecycleOnUpdated_FullMethodName = "/connector.v1.SourcePlugin/LifecycleOnUpdated"
	SourcePlugin_LifecycleOnDeleted_FullMethodName = "/connector.v1.SourcePlugin/LifecycleOnDeleted"
)
View Source 
const (
	DestinationPlugin_Configure_FullMethodName          = "/connector.v1.DestinationPlugin/Configure"
	DestinationPlugin_Start_FullMethodName              = "/connector.v1.DestinationPlugin/Start"
	DestinationPlugin_Run_FullMethodName                = "/connector.v1.DestinationPlugin/Run"
	DestinationPlugin_Stop_FullMethodName               = "/connector.v1.DestinationPlugin/Stop"
	DestinationPlugin_Teardown_FullMethodName           = "/connector.v1.DestinationPlugin/Teardown"
	DestinationPlugin_LifecycleOnCreated_FullMethodName = "/connector.v1.DestinationPlugin/LifecycleOnCreated"
	DestinationPlugin_LifecycleOnUpdated_FullMethodName = "/connector.v1.DestinationPlugin/LifecycleOnUpdated"
	DestinationPlugin_LifecycleOnDeleted_FullMethodName = "/connector.v1.DestinationPlugin/LifecycleOnDeleted"
)
View Source 
const (
	SpecifierPlugin_Specify_FullMethodName = "/connector.v1.SpecifierPlugin/Specify"
)

Variables

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

Enum value maps for Specifier_Parameter_Type.

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

Enum value maps for Specifier_Parameter_Validation_Type.

View Source 
var (
	// optional string metadata_conduit_source_plugin_name = 20000;
	E_MetadataConduitSourcePluginName = &file_connector_v1_connector_proto_extTypes[0]
	// optional string metadata_conduit_source_plugin_version = 20001;
	E_MetadataConduitSourcePluginVersion = &file_connector_v1_connector_proto_extTypes[1]
	// optional string metadata_conduit_destination_plugin_name = 20002;
	E_MetadataConduitDestinationPluginName = &file_connector_v1_connector_proto_extTypes[2]
	// optional string metadata_conduit_destination_plugin_version = 20003;
	E_MetadataConduitDestinationPluginVersion = &file_connector_v1_connector_proto_extTypes[3]
)

Extension fields to descriptorpb.FileOptions.

View Source 
var DestinationPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "connector.v1.DestinationPlugin",
	HandlerType: (*DestinationPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Configure",
			Handler:    _DestinationPlugin_Configure_Handler,
		},
		{
			MethodName: "Start",
			Handler:    _DestinationPlugin_Start_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _DestinationPlugin_Stop_Handler,
		},
		{
			MethodName: "Teardown",
			Handler:    _DestinationPlugin_Teardown_Handler,
		},
		{
			MethodName: "LifecycleOnCreated",
			Handler:    _DestinationPlugin_LifecycleOnCreated_Handler,
		},
		{
			MethodName: "LifecycleOnUpdated",
			Handler:    _DestinationPlugin_LifecycleOnUpdated_Handler,
		},
		{
			MethodName: "LifecycleOnDeleted",
			Handler:    _DestinationPlugin_LifecycleOnDeleted_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Run",
			Handler:       _DestinationPlugin_Run_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "connector/v1/connector.proto",
}

DestinationPlugin_ServiceDesc is the grpc.ServiceDesc for DestinationPlugin 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_connector_v1_connector_proto protoreflect.FileDescriptor
View Source 
var SourcePlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "connector.v1.SourcePlugin",
	HandlerType: (*SourcePluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Configure",
			Handler:    _SourcePlugin_Configure_Handler,
		},
		{
			MethodName: "Start",
			Handler:    _SourcePlugin_Start_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _SourcePlugin_Stop_Handler,
		},
		{
			MethodName: "Teardown",
			Handler:    _SourcePlugin_Teardown_Handler,
		},
		{
			MethodName: "LifecycleOnCreated",
			Handler:    _SourcePlugin_LifecycleOnCreated_Handler,
		},
		{
			MethodName: "LifecycleOnUpdated",
			Handler:    _SourcePlugin_LifecycleOnUpdated_Handler,
		},
		{
			MethodName: "LifecycleOnDeleted",
			Handler:    _SourcePlugin_LifecycleOnDeleted_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Run",
			Handler:       _SourcePlugin_Run_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "connector/v1/connector.proto",
}

SourcePlugin_ServiceDesc is the grpc.ServiceDesc for SourcePlugin 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 SpecifierPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "connector.v1.SpecifierPlugin",
	HandlerType: (*SpecifierPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Specify",
			Handler:    _SpecifierPlugin_Specify_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "connector/v1/connector.proto",
}

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

Functions

func RegisterDestinationPluginServer 

func RegisterDestinationPluginServer(s grpc.ServiceRegistrar, srv DestinationPluginServer)

func RegisterSourcePluginServer 

func RegisterSourcePluginServer(s grpc.ServiceRegistrar, srv SourcePluginServer)

func RegisterSpecifierPluginServer 

func RegisterSpecifierPluginServer(s grpc.ServiceRegistrar, srv SpecifierPluginServer)

Types

type Destination 

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

func (*Destination) Descriptor deprecated 

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

Deprecated: Use Destination.ProtoReflect.Descriptor instead.

func (*Destination) ProtoMessage 

func (*Destination) ProtoMessage()

func (*Destination) ProtoReflect 

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

func (*Destination) Reset 

func (x *Destination) Reset()

func (*Destination) String 

func (x *Destination) String() string

type DestinationPluginClient 

type DestinationPluginClient interface {
	// Configure is the first function to be called in a plugin. It provides the
	// plugin with the configuration that needs to be validated and stored. In
	// case the configuration is not valid it should return an error status.
	Configure(ctx context.Context, in *Destination_Configure_Request, opts ...grpc.CallOption) (*Destination_Configure_Response, error)
	// Start is called after Configure to signal the plugin it can prepare to
	// start writing records. If needed, the plugin should open connections in
	// this function.
	Start(ctx context.Context, in *Destination_Start_Request, opts ...grpc.CallOption) (*Destination_Start_Response, error)
	// Run will open a bidirectional stream between Conduit and the plugin.
	// Conduit will be streaming records to the plugin that should be written
	// to the 3rd party resource. The plugin is responsible for sending
	// acknowledgments back to Conduit once a record has been processed. The
	// acknowledgment should contain an error in case a record could not be
	// successfully processed. The stream should still stay open in case Conduit
	// is able to recover from the error and the pipeline keeps running.
	Run(ctx context.Context, opts ...grpc.CallOption) (DestinationPlugin_RunClient, error)
	// Stop signals to the plugin that the record with the specified position is
	// the last one and no more records will be written to the stream after it.
	// Once the plugin receives the last record it should flush any records that
	// might be cached and not yet written to the 3rd party resource.
	Stop(ctx context.Context, in *Destination_Stop_Request, opts ...grpc.CallOption) (*Destination_Stop_Response, error)
	// Teardown signals to the plugin that there will be no more calls to any
	// other function. After Teardown returns, the plugin should be ready for a
	// graceful shutdown.
	Teardown(ctx context.Context, in *Destination_Teardown_Request, opts ...grpc.CallOption) (*Destination_Teardown_Response, error)
	// LifecycleOnCreated is called after Configure and before Start when the
	// connector is run for the first time. This call will be skipped if a
	// connector was already started before. This method can be used to do some
	// initialization that needs to happen only once in the lifetime of a
	// connector (e.g. create a bucket). Anything that the connector creates in
	// this method is considered to be owned by this connector and should be
	// cleaned up in LifecycleOnDeleted.
	LifecycleOnCreated(ctx context.Context, in *Destination_Lifecycle_OnCreated_Request, opts ...grpc.CallOption) (*Destination_Lifecycle_OnCreated_Response, error)
	// LifecycleOnUpdated is called after Configure and before Start when the
	// connector configuration has changed since the last run. This call will be
	// skipped if the connector configuration did not change. It can be used to
	// update anything that was initialized in LifecycleOnCreated, in case the
	// configuration change affects it.
	LifecycleOnUpdated(ctx context.Context, in *Destination_Lifecycle_OnUpdated_Request, opts ...grpc.CallOption) (*Destination_Lifecycle_OnUpdated_Response, error)
	// LifecycleOnDeleted is called when the connector was deleted. It will be the
	// only method that is called in that case. This method can be used to clean
	// up anything that was initialized in LifecycleOnCreated.
	LifecycleOnDeleted(ctx context.Context, in *Destination_Lifecycle_OnDeleted_Request, opts ...grpc.CallOption) (*Destination_Lifecycle_OnDeleted_Response, error)
}

DestinationPluginClient is the client API for DestinationPlugin 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 NewDestinationPluginClient 

func NewDestinationPluginClient(cc grpc.ClientConnInterface) DestinationPluginClient

type DestinationPluginServer 

type DestinationPluginServer interface {
	// Configure is the first function to be called in a plugin. It provides the
	// plugin with the configuration that needs to be validated and stored. In
	// case the configuration is not valid it should return an error status.
	Configure(context.Context, *Destination_Configure_Request) (*Destination_Configure_Response, error)
	// Start is called after Configure to signal the plugin it can prepare to
	// start writing records. If needed, the plugin should open connections in
	// this function.
	Start(context.Context, *Destination_Start_Request) (*Destination_Start_Response, error)
	// Run will open a bidirectional stream between Conduit and the plugin.
	// Conduit will be streaming records to the plugin that should be written
	// to the 3rd party resource. The plugin is responsible for sending
	// acknowledgments back to Conduit once a record has been processed. The
	// acknowledgment should contain an error in case a record could not be
	// successfully processed. The stream should still stay open in case Conduit
	// is able to recover from the error and the pipeline keeps running.
	Run(DestinationPlugin_RunServer) error
	// Stop signals to the plugin that the record with the specified position is
	// the last one and no more records will be written to the stream after it.
	// Once the plugin receives the last record it should flush any records that
	// might be cached and not yet written to the 3rd party resource.
	Stop(context.Context, *Destination_Stop_Request) (*Destination_Stop_Response, error)
	// Teardown signals to the plugin that there will be no more calls to any
	// other function. After Teardown returns, the plugin should be ready for a
	// graceful shutdown.
	Teardown(context.Context, *Destination_Teardown_Request) (*Destination_Teardown_Response, error)
	// LifecycleOnCreated is called after Configure and before Start when the
	// connector is run for the first time. This call will be skipped if a
	// connector was already started before. This method can be used to do some
	// initialization that needs to happen only once in the lifetime of a
	// connector (e.g. create a bucket). Anything that the connector creates in
	// this method is considered to be owned by this connector and should be
	// cleaned up in LifecycleOnDeleted.
	LifecycleOnCreated(context.Context, *Destination_Lifecycle_OnCreated_Request) (*Destination_Lifecycle_OnCreated_Response, error)
	// LifecycleOnUpdated is called after Configure and before Start when the
	// connector configuration has changed since the last run. This call will be
	// skipped if the connector configuration did not change. It can be used to
	// update anything that was initialized in LifecycleOnCreated, in case the
	// configuration change affects it.
	LifecycleOnUpdated(context.Context, *Destination_Lifecycle_OnUpdated_Request) (*Destination_Lifecycle_OnUpdated_Response, error)
	// LifecycleOnDeleted is called when the connector was deleted. It will be the
	// only method that is called in that case. This method can be used to clean
	// up anything that was initialized in LifecycleOnCreated.
	LifecycleOnDeleted(context.Context, *Destination_Lifecycle_OnDeleted_Request) (*Destination_Lifecycle_OnDeleted_Response, error)
	// contains filtered or unexported methods
}

DestinationPluginServer is the server API for DestinationPlugin service. All implementations must embed UnimplementedDestinationPluginServer for forward compatibility

type DestinationPlugin_RunClient 

type DestinationPlugin_RunClient interface {
	Send(*Destination_Run_Request) error
	Recv() (*Destination_Run_Response, error)
	grpc.ClientStream
}

type DestinationPlugin_RunServer 

type DestinationPlugin_RunServer interface {
	Send(*Destination_Run_Response) error
	Recv() (*Destination_Run_Request, error)
	grpc.ServerStream
}

type Destination_Configure 

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

func (*Destination_Configure) Descriptor deprecated 

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

Deprecated: Use Destination_Configure.ProtoReflect.Descriptor instead.

func (*Destination_Configure) ProtoMessage 

func (*Destination_Configure) ProtoMessage()

func (*Destination_Configure) ProtoReflect 

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

func (*Destination_Configure) Reset 

func (x *Destination_Configure) Reset()

func (*Destination_Configure) String 

func (x *Destination_Configure) String() string

type Destination_Configure_Request 

type Destination_Configure_Request struct {

	// Config contains the raw plugin settings.
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Destination_Configure_Request) Descriptor deprecated 

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

Deprecated: Use Destination_Configure_Request.ProtoReflect.Descriptor instead.

func (*Destination_Configure_Request) GetConfig 

func (x *Destination_Configure_Request) GetConfig() map[string]string

func (*Destination_Configure_Request) ProtoMessage 

func (*Destination_Configure_Request) ProtoMessage()

func (*Destination_Configure_Request) ProtoReflect 

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

func (*Destination_Configure_Request) Reset 

func (x *Destination_Configure_Request) Reset()

func (*Destination_Configure_Request) String 

func (x *Destination_Configure_Request) String() string

type Destination_Configure_Response 

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

func (*Destination_Configure_Response) Descriptor deprecated 

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

Deprecated: Use Destination_Configure_Response.ProtoReflect.Descriptor instead.

func (*Destination_Configure_Response) ProtoMessage 

func (*Destination_Configure_Response) ProtoMessage()

func (*Destination_Configure_Response) ProtoReflect 

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

func (*Destination_Configure_Response) Reset 

func (x *Destination_Configure_Response) Reset()

func (*Destination_Configure_Response) String 

func (x *Destination_Configure_Response) String() string

type Destination_Lifecycle added in v0.5.0 

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

func (*Destination_Lifecycle) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Destination_Lifecycle.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle) ProtoMessage added in v0.5.0 

func (*Destination_Lifecycle) ProtoMessage()

func (*Destination_Lifecycle) ProtoReflect added in v0.5.0 

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

func (*Destination_Lifecycle) Reset added in v0.5.0 

func (x *Destination_Lifecycle) Reset()

func (*Destination_Lifecycle) String added in v0.5.0 

func (x *Destination_Lifecycle) String() string

type Destination_Lifecycle_OnCreated added in v0.5.0 

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

func (*Destination_Lifecycle_OnCreated) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Destination_Lifecycle_OnCreated.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnCreated) ProtoMessage added in v0.5.0 

func (*Destination_Lifecycle_OnCreated) ProtoMessage()

func (*Destination_Lifecycle_OnCreated) ProtoReflect added in v0.5.0 

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

func (*Destination_Lifecycle_OnCreated) Reset added in v0.5.0 

func (x *Destination_Lifecycle_OnCreated) Reset()

func (*Destination_Lifecycle_OnCreated) String added in v0.5.0 

func (x *Destination_Lifecycle_OnCreated) String() string

type Destination_Lifecycle_OnCreated_Request added in v0.5.0 

type Destination_Lifecycle_OnCreated_Request struct {

	// This is the connector configuration that was also passed to
	// Configure, therefore it's already validated.
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Destination_Lifecycle_OnCreated_Request) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Destination_Lifecycle_OnCreated_Request.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnCreated_Request) GetConfig added in v0.5.0 

func (x *Destination_Lifecycle_OnCreated_Request) GetConfig() map[string]string

func (*Destination_Lifecycle_OnCreated_Request) ProtoMessage added in v0.5.0 

func (*Destination_Lifecycle_OnCreated_Request) ProtoMessage()

func (*Destination_Lifecycle_OnCreated_Request) ProtoReflect added in v0.5.0 

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

func (*Destination_Lifecycle_OnCreated_Request) Reset added in v0.5.0 

func (x *Destination_Lifecycle_OnCreated_Request) Reset()

func (*Destination_Lifecycle_OnCreated_Request) String added in v0.5.0 

func (x *Destination_Lifecycle_OnCreated_Request) String() string

type Destination_Lifecycle_OnCreated_Response added in v0.5.0 

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

func (*Destination_Lifecycle_OnCreated_Response) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Destination_Lifecycle_OnCreated_Response.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnCreated_Response) ProtoMessage added in v0.5.0 

func (*Destination_Lifecycle_OnCreated_Response) ProtoMessage()

func (*Destination_Lifecycle_OnCreated_Response) ProtoReflect added in v0.5.0 

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

func (*Destination_Lifecycle_OnCreated_Response) Reset added in v0.5.0 

func (x *Destination_Lifecycle_OnCreated_Response) Reset()

func (*Destination_Lifecycle_OnCreated_Response) String added in v0.5.0 

func (x *Destination_Lifecycle_OnCreated_Response) String() string

type Destination_Lifecycle_OnDeleted added in v0.5.0 

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

func (*Destination_Lifecycle_OnDeleted) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Destination_Lifecycle_OnDeleted.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnDeleted) ProtoMessage added in v0.5.0 

func (*Destination_Lifecycle_OnDeleted) ProtoMessage()

func (*Destination_Lifecycle_OnDeleted) ProtoReflect added in v0.5.0 

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

func (*Destination_Lifecycle_OnDeleted) Reset added in v0.5.0 

func (x *Destination_Lifecycle_OnDeleted) Reset()

func (*Destination_Lifecycle_OnDeleted) String added in v0.5.0 

func (x *Destination_Lifecycle_OnDeleted) String() string

type Destination_Lifecycle_OnDeleted_Request added in v0.5.0 

type Destination_Lifecycle_OnDeleted_Request struct {

	// This is the old connector configuration that was used the last time
	// the connector was running. It was valid at that time, since it passed
	// through the Configure function.
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Destination_Lifecycle_OnDeleted_Request) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Destination_Lifecycle_OnDeleted_Request.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnDeleted_Request) GetConfig added in v0.5.0 

func (x *Destination_Lifecycle_OnDeleted_Request) GetConfig() map[string]string

func (*Destination_Lifecycle_OnDeleted_Request) ProtoMessage added in v0.5.0 

func (*Destination_Lifecycle_OnDeleted_Request) ProtoMessage()

func (*Destination_Lifecycle_OnDeleted_Request) ProtoReflect added in v0.5.0 

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

func (*Destination_Lifecycle_OnDeleted_Request) Reset added in v0.5.0 

func (x *Destination_Lifecycle_OnDeleted_Request) Reset()

func (*Destination_Lifecycle_OnDeleted_Request) String added in v0.5.0 

func (x *Destination_Lifecycle_OnDeleted_Request) String() string

type Destination_Lifecycle_OnDeleted_Response added in v0.5.0 

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

func (*Destination_Lifecycle_OnDeleted_Response) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Destination_Lifecycle_OnDeleted_Response.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnDeleted_Response) ProtoMessage added in v0.5.0 

func (*Destination_Lifecycle_OnDeleted_Response) ProtoMessage()

func (*Destination_Lifecycle_OnDeleted_Response) ProtoReflect added in v0.5.0 

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

func (*Destination_Lifecycle_OnDeleted_Response) Reset added in v0.5.0 

func (x *Destination_Lifecycle_OnDeleted_Response) Reset()

func (*Destination_Lifecycle_OnDeleted_Response) String added in v0.5.0 

func (x *Destination_Lifecycle_OnDeleted_Response) String() string

type Destination_Lifecycle_OnUpdated added in v0.5.0 

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

func (*Destination_Lifecycle_OnUpdated) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Destination_Lifecycle_OnUpdated.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnUpdated) ProtoMessage added in v0.5.0 

func (*Destination_Lifecycle_OnUpdated) ProtoMessage()

func (*Destination_Lifecycle_OnUpdated) ProtoReflect added in v0.5.0 

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

func (*Destination_Lifecycle_OnUpdated) Reset added in v0.5.0 

func (x *Destination_Lifecycle_OnUpdated) Reset()

func (*Destination_Lifecycle_OnUpdated) String added in v0.5.0 

func (x *Destination_Lifecycle_OnUpdated) String() string

type Destination_Lifecycle_OnUpdated_Request added in v0.5.0 

type Destination_Lifecycle_OnUpdated_Request struct {

	// This is the old connector configuration that was used the last time
	// the connector was running. It was valid at that time, since it passed
	// through the Configure function.
	ConfigBefore map[string]string `` /* 185-byte string literal not displayed */
	// This is the new connector configuration that was also passed to
	// Configure, therefore it's already validated.
	ConfigAfter map[string]string `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Destination_Lifecycle_OnUpdated_Request) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Destination_Lifecycle_OnUpdated_Request.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnUpdated_Request) GetConfigAfter added in v0.5.0 

func (x *Destination_Lifecycle_OnUpdated_Request) GetConfigAfter() map[string]string

func (*Destination_Lifecycle_OnUpdated_Request) GetConfigBefore added in v0.5.0 

func (x *Destination_Lifecycle_OnUpdated_Request) GetConfigBefore() map[string]string

func (*Destination_Lifecycle_OnUpdated_Request) ProtoMessage added in v0.5.0 

func (*Destination_Lifecycle_OnUpdated_Request) ProtoMessage()

func (*Destination_Lifecycle_OnUpdated_Request) ProtoReflect added in v0.5.0 

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

func (*Destination_Lifecycle_OnUpdated_Request) Reset added in v0.5.0 

func (x *Destination_Lifecycle_OnUpdated_Request) Reset()

func (*Destination_Lifecycle_OnUpdated_Request) String added in v0.5.0 

func (x *Destination_Lifecycle_OnUpdated_Request) String() string

type Destination_Lifecycle_OnUpdated_Response added in v0.5.0 

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

func (*Destination_Lifecycle_OnUpdated_Response) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Destination_Lifecycle_OnUpdated_Response.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnUpdated_Response) ProtoMessage added in v0.5.0 

func (*Destination_Lifecycle_OnUpdated_Response) ProtoMessage()

func (*Destination_Lifecycle_OnUpdated_Response) ProtoReflect added in v0.5.0 

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

func (*Destination_Lifecycle_OnUpdated_Response) Reset added in v0.5.0 

func (x *Destination_Lifecycle_OnUpdated_Response) Reset()

func (*Destination_Lifecycle_OnUpdated_Response) String added in v0.5.0 

func (x *Destination_Lifecycle_OnUpdated_Response) String() string

type Destination_Run 

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

func (*Destination_Run) Descriptor deprecated 

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

Deprecated: Use Destination_Run.ProtoReflect.Descriptor instead.

func (*Destination_Run) ProtoMessage 

func (*Destination_Run) ProtoMessage()

func (*Destination_Run) ProtoReflect 

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

func (*Destination_Run) Reset 

func (x *Destination_Run) Reset()

func (*Destination_Run) String 

func (x *Destination_Run) String() string

type Destination_Run_Request 

type Destination_Run_Request struct {

	// Record contains the OpenCDC record that should be written to the 3rd
	// party resource.
	Record *v1.Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*Destination_Run_Request) Descriptor deprecated 

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

Deprecated: Use Destination_Run_Request.ProtoReflect.Descriptor instead.

func (*Destination_Run_Request) GetRecord 

func (x *Destination_Run_Request) GetRecord() *v1.Record

func (*Destination_Run_Request) ProtoMessage 

func (*Destination_Run_Request) ProtoMessage()

func (*Destination_Run_Request) ProtoReflect 

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

func (*Destination_Run_Request) Reset 

func (x *Destination_Run_Request) Reset()

func (*Destination_Run_Request) String 

func (x *Destination_Run_Request) String() string

type Destination_Run_Response 

type Destination_Run_Response struct {

	// This is the position of the record that was processed.
	AckPosition []byte `protobuf:"bytes,1,opt,name=ack_position,json=ackPosition,proto3" json:"ack_position,omitempty"`
	// Error should be empty if the record was successfully processed or
	// should contain a descriptive message in case the record
	// processing failed.
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*Destination_Run_Response) Descriptor deprecated 

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

Deprecated: Use Destination_Run_Response.ProtoReflect.Descriptor instead.

func (*Destination_Run_Response) GetAckPosition 

func (x *Destination_Run_Response) GetAckPosition() []byte

func (*Destination_Run_Response) GetError 

func (x *Destination_Run_Response) GetError() string

func (*Destination_Run_Response) ProtoMessage 

func (*Destination_Run_Response) ProtoMessage()

func (*Destination_Run_Response) ProtoReflect 

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

func (*Destination_Run_Response) Reset 

func (x *Destination_Run_Response) Reset()

func (*Destination_Run_Response) String 

func (x *Destination_Run_Response) String() string

type Destination_Start 

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

func (*Destination_Start) Descriptor deprecated 

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

Deprecated: Use Destination_Start.ProtoReflect.Descriptor instead.

func (*Destination_Start) ProtoMessage 

func (*Destination_Start) ProtoMessage()

func (*Destination_Start) ProtoReflect 

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

func (*Destination_Start) Reset 

func (x *Destination_Start) Reset()

func (*Destination_Start) String 

func (x *Destination_Start) String() string

type Destination_Start_Request 

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

func (*Destination_Start_Request) Descriptor deprecated 

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

Deprecated: Use Destination_Start_Request.ProtoReflect.Descriptor instead.

func (*Destination_Start_Request) ProtoMessage 

func (*Destination_Start_Request) ProtoMessage()

func (*Destination_Start_Request) ProtoReflect 

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

func (*Destination_Start_Request) Reset 

func (x *Destination_Start_Request) Reset()

func (*Destination_Start_Request) String 

func (x *Destination_Start_Request) String() string

type Destination_Start_Response 

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

func (*Destination_Start_Response) Descriptor deprecated 

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

Deprecated: Use Destination_Start_Response.ProtoReflect.Descriptor instead.

func (*Destination_Start_Response) ProtoMessage 

func (*Destination_Start_Response) ProtoMessage()

func (*Destination_Start_Response) ProtoReflect 

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

func (*Destination_Start_Response) Reset 

func (x *Destination_Start_Response) Reset()

func (*Destination_Start_Response) String 

func (x *Destination_Start_Response) String() string

type Destination_Stop 

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

func (*Destination_Stop) Descriptor deprecated 

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

Deprecated: Use Destination_Stop.ProtoReflect.Descriptor instead.

func (*Destination_Stop) ProtoMessage 

func (*Destination_Stop) ProtoMessage()

func (*Destination_Stop) ProtoReflect 

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

func (*Destination_Stop) Reset 

func (x *Destination_Stop) Reset()

func (*Destination_Stop) String 

func (x *Destination_Stop) String() string

type Destination_Stop_Request 

type Destination_Stop_Request struct {

	// This is the position of the last record that was sent into the stream.
	// Conduit won't send any records after a record with this position is
	// received.
	LastPosition []byte `protobuf:"bytes,1,opt,name=last_position,json=lastPosition,proto3" json:"last_position,omitempty"`
	// contains filtered or unexported fields
}

func (*Destination_Stop_Request) Descriptor deprecated 

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

Deprecated: Use Destination_Stop_Request.ProtoReflect.Descriptor instead.

func (*Destination_Stop_Request) GetLastPosition 

func (x *Destination_Stop_Request) GetLastPosition() []byte

func (*Destination_Stop_Request) ProtoMessage 

func (*Destination_Stop_Request) ProtoMessage()

func (*Destination_Stop_Request) ProtoReflect 

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

func (*Destination_Stop_Request) Reset 

func (x *Destination_Stop_Request) Reset()

func (*Destination_Stop_Request) String 

func (x *Destination_Stop_Request) String() string

type Destination_Stop_Response 

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

func (*Destination_Stop_Response) Descriptor deprecated 

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

Deprecated: Use Destination_Stop_Response.ProtoReflect.Descriptor instead.

func (*Destination_Stop_Response) ProtoMessage 

func (*Destination_Stop_Response) ProtoMessage()

func (*Destination_Stop_Response) ProtoReflect 

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

func (*Destination_Stop_Response) Reset 

func (x *Destination_Stop_Response) Reset()

func (*Destination_Stop_Response) String 

func (x *Destination_Stop_Response) String() string

type Destination_Teardown 

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

func (*Destination_Teardown) Descriptor deprecated 

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

Deprecated: Use Destination_Teardown.ProtoReflect.Descriptor instead.

func (*Destination_Teardown) ProtoMessage 

func (*Destination_Teardown) ProtoMessage()

func (*Destination_Teardown) ProtoReflect 

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

func (*Destination_Teardown) Reset 

func (x *Destination_Teardown) Reset()

func (*Destination_Teardown) String 

func (x *Destination_Teardown) String() string

type Destination_Teardown_Request 

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

func (*Destination_Teardown_Request) Descriptor deprecated 

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

Deprecated: Use Destination_Teardown_Request.ProtoReflect.Descriptor instead.

func (*Destination_Teardown_Request) ProtoMessage 

func (*Destination_Teardown_Request) ProtoMessage()

func (*Destination_Teardown_Request) ProtoReflect 

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

func (*Destination_Teardown_Request) Reset 

func (x *Destination_Teardown_Request) Reset()

func (*Destination_Teardown_Request) String 

func (x *Destination_Teardown_Request) String() string

type Destination_Teardown_Response 

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

func (*Destination_Teardown_Response) Descriptor deprecated 

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

Deprecated: Use Destination_Teardown_Response.ProtoReflect.Descriptor instead.

func (*Destination_Teardown_Response) ProtoMessage 

func (*Destination_Teardown_Response) ProtoMessage()

func (*Destination_Teardown_Response) ProtoReflect 

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

func (*Destination_Teardown_Response) Reset 

func (x *Destination_Teardown_Response) Reset()

func (*Destination_Teardown_Response) String 

func (x *Destination_Teardown_Response) String() string

type Source 

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

func (*Source) Descriptor deprecated 

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

Deprecated: Use Source.ProtoReflect.Descriptor instead.

func (*Source) ProtoMessage 

func (*Source) ProtoMessage()

func (*Source) ProtoReflect 

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

func (*Source) Reset 

func (x *Source) Reset()

func (*Source) String 

func (x *Source) String() string

type SourcePluginClient 

type SourcePluginClient interface {
	// Configure is the first function to be called in a plugin. It provides the
	// plugin with the configuration that needs to be validated and stored. In
	// case the configuration is not valid it should return an error status.
	Configure(ctx context.Context, in *Source_Configure_Request, opts ...grpc.CallOption) (*Source_Configure_Response, error)
	// Start is called after Configure to signal the plugin it can prepare to
	// start producing records. If needed, the plugin should open connections in
	// this function. The position parameter will contain the position of the
	// last record that was successfully processed. The Source should therefore
	// start producing records after this position.
	Start(ctx context.Context, in *Source_Start_Request, opts ...grpc.CallOption) (*Source_Start_Response, error)
	// Run will open a bidirectional stream between Conduit and the plugin.
	// The plugin is responsible for fetching records from 3rd party resources
	// and sending them as responses to Conduit. Conduit will process the
	// records asynchronously and send acknowledgments back to the plugin to
	// signal that a record at a certain position was processed. Acknowledgments
	// will be sent back to the connector in the same order as the records
	// produced by the connector. If a record could not be processed by Conduit,
	// the stream will be closed without an acknowledgment being sent back to the
	// connector.
	Run(ctx context.Context, opts ...grpc.CallOption) (SourcePlugin_RunClient, error)
	// Stop signals to the plugin to stop retrieving new records and flush any
	// records that might be cached into the stream. It should block until it can
	// determine the last record that will be sent to the stream and return the
	// position of the last record. Conduit will keep the stream open until it
	// receives the last record and sends back any outstanding acknowledgments.
	// If Conduit did not send an acknowledgment for a record after the stream is
	// closed, it should be interpreted as a negative acknowledgment.
	Stop(ctx context.Context, in *Source_Stop_Request, opts ...grpc.CallOption) (*Source_Stop_Response, error)
	// Teardown signals to the plugin that there will be no more calls to any
	// other function. After Teardown returns, the plugin should be ready for a
	// graceful shutdown.
	Teardown(ctx context.Context, in *Source_Teardown_Request, opts ...grpc.CallOption) (*Source_Teardown_Response, error)
	// LifecycleOnCreated is called after Configure and before Start when the
	// connector is run for the first time. This call will be skipped if a
	// connector was already started before. This method can be used to do some
	// initialization that needs to happen only once in the lifetime of a
	// connector (e.g. create a replication slot). Anything that the connector
	// creates in this method is considered to be owned by this connector and
	// should be cleaned up in LifecycleOnDeleted.
	LifecycleOnCreated(ctx context.Context, in *Source_Lifecycle_OnCreated_Request, opts ...grpc.CallOption) (*Source_Lifecycle_OnCreated_Response, error)
	// LifecycleOnUpdated is called after Configure and before Start when the
	// connector configuration has changed since the last run. This call will be
	// skipped if the connector configuration did not change. It can be used to
	// update anything that was initialized in LifecycleOnCreated, in case the
	// configuration change affects it.
	LifecycleOnUpdated(ctx context.Context, in *Source_Lifecycle_OnUpdated_Request, opts ...grpc.CallOption) (*Source_Lifecycle_OnUpdated_Response, error)
	// LifecycleOnDeleted is called when the connector was deleted. It will be the
	// only method that is called in that case. This method can be used to clean
	// up anything that was initialized in LifecycleOnCreated.
	LifecycleOnDeleted(ctx context.Context, in *Source_Lifecycle_OnDeleted_Request, opts ...grpc.CallOption) (*Source_Lifecycle_OnDeleted_Response, error)
}

SourcePluginClient is the client API for SourcePlugin 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 NewSourcePluginClient 

func NewSourcePluginClient(cc grpc.ClientConnInterface) SourcePluginClient

type SourcePluginServer 

type SourcePluginServer interface {
	// Configure is the first function to be called in a plugin. It provides the
	// plugin with the configuration that needs to be validated and stored. In
	// case the configuration is not valid it should return an error status.
	Configure(context.Context, *Source_Configure_Request) (*Source_Configure_Response, error)
	// Start is called after Configure to signal the plugin it can prepare to
	// start producing records. If needed, the plugin should open connections in
	// this function. The position parameter will contain the position of the
	// last record that was successfully processed. The Source should therefore
	// start producing records after this position.
	Start(context.Context, *Source_Start_Request) (*Source_Start_Response, error)
	// Run will open a bidirectional stream between Conduit and the plugin.
	// The plugin is responsible for fetching records from 3rd party resources
	// and sending them as responses to Conduit. Conduit will process the
	// records asynchronously and send acknowledgments back to the plugin to
	// signal that a record at a certain position was processed. Acknowledgments
	// will be sent back to the connector in the same order as the records
	// produced by the connector. If a record could not be processed by Conduit,
	// the stream will be closed without an acknowledgment being sent back to the
	// connector.
	Run(SourcePlugin_RunServer) error
	// Stop signals to the plugin to stop retrieving new records and flush any
	// records that might be cached into the stream. It should block until it can
	// determine the last record that will be sent to the stream and return the
	// position of the last record. Conduit will keep the stream open until it
	// receives the last record and sends back any outstanding acknowledgments.
	// If Conduit did not send an acknowledgment for a record after the stream is
	// closed, it should be interpreted as a negative acknowledgment.
	Stop(context.Context, *Source_Stop_Request) (*Source_Stop_Response, error)
	// Teardown signals to the plugin that there will be no more calls to any
	// other function. After Teardown returns, the plugin should be ready for a
	// graceful shutdown.
	Teardown(context.Context, *Source_Teardown_Request) (*Source_Teardown_Response, error)
	// LifecycleOnCreated is called after Configure and before Start when the
	// connector is run for the first time. This call will be skipped if a
	// connector was already started before. This method can be used to do some
	// initialization that needs to happen only once in the lifetime of a
	// connector (e.g. create a replication slot). Anything that the connector
	// creates in this method is considered to be owned by this connector and
	// should be cleaned up in LifecycleOnDeleted.
	LifecycleOnCreated(context.Context, *Source_Lifecycle_OnCreated_Request) (*Source_Lifecycle_OnCreated_Response, error)
	// LifecycleOnUpdated is called after Configure and before Start when the
	// connector configuration has changed since the last run. This call will be
	// skipped if the connector configuration did not change. It can be used to
	// update anything that was initialized in LifecycleOnCreated, in case the
	// configuration change affects it.
	LifecycleOnUpdated(context.Context, *Source_Lifecycle_OnUpdated_Request) (*Source_Lifecycle_OnUpdated_Response, error)
	// LifecycleOnDeleted is called when the connector was deleted. It will be the
	// only method that is called in that case. This method can be used to clean
	// up anything that was initialized in LifecycleOnCreated.
	LifecycleOnDeleted(context.Context, *Source_Lifecycle_OnDeleted_Request) (*Source_Lifecycle_OnDeleted_Response, error)
	// contains filtered or unexported methods
}

SourcePluginServer is the server API for SourcePlugin service. All implementations must embed UnimplementedSourcePluginServer for forward compatibility

type SourcePlugin_RunClient 

type SourcePlugin_RunClient interface {
	Send(*Source_Run_Request) error
	Recv() (*Source_Run_Response, error)
	grpc.ClientStream
}

type SourcePlugin_RunServer 

type SourcePlugin_RunServer interface {
	Send(*Source_Run_Response) error
	Recv() (*Source_Run_Request, error)
	grpc.ServerStream
}

type Source_Configure 

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

func (*Source_Configure) Descriptor deprecated 

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

Deprecated: Use Source_Configure.ProtoReflect.Descriptor instead.

func (*Source_Configure) ProtoMessage 

func (*Source_Configure) ProtoMessage()

func (*Source_Configure) ProtoReflect 

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

func (*Source_Configure) Reset 

func (x *Source_Configure) Reset()

func (*Source_Configure) String 

func (x *Source_Configure) String() string

type Source_Configure_Request 

type Source_Configure_Request struct {

	// Config contains the raw plugin settings.
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Source_Configure_Request) Descriptor deprecated 

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

Deprecated: Use Source_Configure_Request.ProtoReflect.Descriptor instead.

func (*Source_Configure_Request) GetConfig 

func (x *Source_Configure_Request) GetConfig() map[string]string

func (*Source_Configure_Request) ProtoMessage 

func (*Source_Configure_Request) ProtoMessage()

func (*Source_Configure_Request) ProtoReflect 

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

func (*Source_Configure_Request) Reset 

func (x *Source_Configure_Request) Reset()

func (*Source_Configure_Request) String 

func (x *Source_Configure_Request) String() string

type Source_Configure_Response 

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

func (*Source_Configure_Response) Descriptor deprecated 

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

Deprecated: Use Source_Configure_Response.ProtoReflect.Descriptor instead.

func (*Source_Configure_Response) ProtoMessage 

func (*Source_Configure_Response) ProtoMessage()

func (*Source_Configure_Response) ProtoReflect 

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

func (*Source_Configure_Response) Reset 

func (x *Source_Configure_Response) Reset()

func (*Source_Configure_Response) String 

func (x *Source_Configure_Response) String() string

type Source_Lifecycle added in v0.5.0 

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

func (*Source_Lifecycle) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Source_Lifecycle.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle) ProtoMessage added in v0.5.0 

func (*Source_Lifecycle) ProtoMessage()

func (*Source_Lifecycle) ProtoReflect added in v0.5.0 

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

func (*Source_Lifecycle) Reset added in v0.5.0 

func (x *Source_Lifecycle) Reset()

func (*Source_Lifecycle) String added in v0.5.0 

func (x *Source_Lifecycle) String() string

type Source_Lifecycle_OnCreated added in v0.5.0 

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

func (*Source_Lifecycle_OnCreated) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Source_Lifecycle_OnCreated.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnCreated) ProtoMessage added in v0.5.0 

func (*Source_Lifecycle_OnCreated) ProtoMessage()

func (*Source_Lifecycle_OnCreated) ProtoReflect added in v0.5.0 

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

func (*Source_Lifecycle_OnCreated) Reset added in v0.5.0 

func (x *Source_Lifecycle_OnCreated) Reset()

func (*Source_Lifecycle_OnCreated) String added in v0.5.0 

func (x *Source_Lifecycle_OnCreated) String() string

type Source_Lifecycle_OnCreated_Request added in v0.5.0 

type Source_Lifecycle_OnCreated_Request struct {

	// This is the connector configuration that was also passed to
	// Configure, therefore it's already validated.
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Source_Lifecycle_OnCreated_Request) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Source_Lifecycle_OnCreated_Request.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnCreated_Request) GetConfig added in v0.5.0 

func (x *Source_Lifecycle_OnCreated_Request) GetConfig() map[string]string

func (*Source_Lifecycle_OnCreated_Request) ProtoMessage added in v0.5.0 

func (*Source_Lifecycle_OnCreated_Request) ProtoMessage()

func (*Source_Lifecycle_OnCreated_Request) ProtoReflect added in v0.5.0 

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

func (*Source_Lifecycle_OnCreated_Request) Reset added in v0.5.0 

func (x *Source_Lifecycle_OnCreated_Request) Reset()

func (*Source_Lifecycle_OnCreated_Request) String added in v0.5.0 

func (x *Source_Lifecycle_OnCreated_Request) String() string

type Source_Lifecycle_OnCreated_Response added in v0.5.0 

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

func (*Source_Lifecycle_OnCreated_Response) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Source_Lifecycle_OnCreated_Response.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnCreated_Response) ProtoMessage added in v0.5.0 

func (*Source_Lifecycle_OnCreated_Response) ProtoMessage()

func (*Source_Lifecycle_OnCreated_Response) ProtoReflect added in v0.5.0 

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

func (*Source_Lifecycle_OnCreated_Response) Reset added in v0.5.0 

func (x *Source_Lifecycle_OnCreated_Response) Reset()

func (*Source_Lifecycle_OnCreated_Response) String added in v0.5.0 

func (x *Source_Lifecycle_OnCreated_Response) String() string

type Source_Lifecycle_OnDeleted added in v0.5.0 

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

func (*Source_Lifecycle_OnDeleted) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Source_Lifecycle_OnDeleted.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnDeleted) ProtoMessage added in v0.5.0 

func (*Source_Lifecycle_OnDeleted) ProtoMessage()

func (*Source_Lifecycle_OnDeleted) ProtoReflect added in v0.5.0 

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

func (*Source_Lifecycle_OnDeleted) Reset added in v0.5.0 

func (x *Source_Lifecycle_OnDeleted) Reset()

func (*Source_Lifecycle_OnDeleted) String added in v0.5.0 

func (x *Source_Lifecycle_OnDeleted) String() string

type Source_Lifecycle_OnDeleted_Request added in v0.5.0 

type Source_Lifecycle_OnDeleted_Request struct {

	// This is the old connector configuration that was used the last time
	// the connector was running. It was valid at that time, since it passed
	// through the Configure function.
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Source_Lifecycle_OnDeleted_Request) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Source_Lifecycle_OnDeleted_Request.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnDeleted_Request) GetConfig added in v0.5.0 

func (x *Source_Lifecycle_OnDeleted_Request) GetConfig() map[string]string

func (*Source_Lifecycle_OnDeleted_Request) ProtoMessage added in v0.5.0 

func (*Source_Lifecycle_OnDeleted_Request) ProtoMessage()

func (*Source_Lifecycle_OnDeleted_Request) ProtoReflect added in v0.5.0 

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

func (*Source_Lifecycle_OnDeleted_Request) Reset added in v0.5.0 

func (x *Source_Lifecycle_OnDeleted_Request) Reset()

func (*Source_Lifecycle_OnDeleted_Request) String added in v0.5.0 

func (x *Source_Lifecycle_OnDeleted_Request) String() string

type Source_Lifecycle_OnDeleted_Response added in v0.5.0 

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

func (*Source_Lifecycle_OnDeleted_Response) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Source_Lifecycle_OnDeleted_Response.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnDeleted_Response) ProtoMessage added in v0.5.0 

func (*Source_Lifecycle_OnDeleted_Response) ProtoMessage()

func (*Source_Lifecycle_OnDeleted_Response) ProtoReflect added in v0.5.0 

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

func (*Source_Lifecycle_OnDeleted_Response) Reset added in v0.5.0 

func (x *Source_Lifecycle_OnDeleted_Response) Reset()

func (*Source_Lifecycle_OnDeleted_Response) String added in v0.5.0 

func (x *Source_Lifecycle_OnDeleted_Response) String() string

type Source_Lifecycle_OnUpdated added in v0.5.0 

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

func (*Source_Lifecycle_OnUpdated) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Source_Lifecycle_OnUpdated.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnUpdated) ProtoMessage added in v0.5.0 

func (*Source_Lifecycle_OnUpdated) ProtoMessage()

func (*Source_Lifecycle_OnUpdated) ProtoReflect added in v0.5.0 

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

func (*Source_Lifecycle_OnUpdated) Reset added in v0.5.0 

func (x *Source_Lifecycle_OnUpdated) Reset()

func (*Source_Lifecycle_OnUpdated) String added in v0.5.0 

func (x *Source_Lifecycle_OnUpdated) String() string

type Source_Lifecycle_OnUpdated_Request added in v0.5.0 

type Source_Lifecycle_OnUpdated_Request struct {

	// This is the old connector configuration that was used the last time
	// the connector was running. It was valid at that time, since it passed
	// through the Configure function.
	ConfigBefore map[string]string `` /* 185-byte string literal not displayed */
	// This is the new connector configuration that was also passed to
	// Configure, therefore it's already validated.
	ConfigAfter map[string]string `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Source_Lifecycle_OnUpdated_Request) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Source_Lifecycle_OnUpdated_Request.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnUpdated_Request) GetConfigAfter added in v0.5.0 

func (x *Source_Lifecycle_OnUpdated_Request) GetConfigAfter() map[string]string

func (*Source_Lifecycle_OnUpdated_Request) GetConfigBefore added in v0.5.0 

func (x *Source_Lifecycle_OnUpdated_Request) GetConfigBefore() map[string]string

func (*Source_Lifecycle_OnUpdated_Request) ProtoMessage added in v0.5.0 

func (*Source_Lifecycle_OnUpdated_Request) ProtoMessage()

func (*Source_Lifecycle_OnUpdated_Request) ProtoReflect added in v0.5.0 

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

func (*Source_Lifecycle_OnUpdated_Request) Reset added in v0.5.0 

func (x *Source_Lifecycle_OnUpdated_Request) Reset()

func (*Source_Lifecycle_OnUpdated_Request) String added in v0.5.0 

func (x *Source_Lifecycle_OnUpdated_Request) String() string

type Source_Lifecycle_OnUpdated_Response added in v0.5.0 

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

func (*Source_Lifecycle_OnUpdated_Response) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Source_Lifecycle_OnUpdated_Response.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnUpdated_Response) ProtoMessage added in v0.5.0 

func (*Source_Lifecycle_OnUpdated_Response) ProtoMessage()

func (*Source_Lifecycle_OnUpdated_Response) ProtoReflect added in v0.5.0 

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

func (*Source_Lifecycle_OnUpdated_Response) Reset added in v0.5.0 

func (x *Source_Lifecycle_OnUpdated_Response) Reset()

func (*Source_Lifecycle_OnUpdated_Response) String added in v0.5.0 

func (x *Source_Lifecycle_OnUpdated_Response) String() string

type Source_Run 

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

func (*Source_Run) Descriptor deprecated 

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

Deprecated: Use Source_Run.ProtoReflect.Descriptor instead.

func (*Source_Run) ProtoMessage 

func (*Source_Run) ProtoMessage()

func (*Source_Run) ProtoReflect 

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

func (*Source_Run) Reset 

func (x *Source_Run) Reset()

func (*Source_Run) String 

func (x *Source_Run) String() string

type Source_Run_Request 

type Source_Run_Request struct {

	// This is the position of the record that was successfully
	// processed.
	AckPosition []byte `protobuf:"bytes,1,opt,name=ack_position,json=ackPosition,proto3" json:"ack_position,omitempty"`
	// contains filtered or unexported fields
}

func (*Source_Run_Request) Descriptor deprecated 

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

Deprecated: Use Source_Run_Request.ProtoReflect.Descriptor instead.

func (*Source_Run_Request) GetAckPosition 

func (x *Source_Run_Request) GetAckPosition() []byte

func (*Source_Run_Request) ProtoMessage 

func (*Source_Run_Request) ProtoMessage()

func (*Source_Run_Request) ProtoReflect 

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

func (*Source_Run_Request) Reset 

func (x *Source_Run_Request) Reset()

func (*Source_Run_Request) String 

func (x *Source_Run_Request) String() string

type Source_Run_Response 

type Source_Run_Response struct {

	// Record contains the OpenCDC record read by the source from the 3rd
	// party resource.
	Record *v1.Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*Source_Run_Response) Descriptor deprecated 

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

Deprecated: Use Source_Run_Response.ProtoReflect.Descriptor instead.

func (*Source_Run_Response) GetRecord 

func (x *Source_Run_Response) GetRecord() *v1.Record

func (*Source_Run_Response) ProtoMessage 

func (*Source_Run_Response) ProtoMessage()

func (*Source_Run_Response) ProtoReflect 

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

func (*Source_Run_Response) Reset 

func (x *Source_Run_Response) Reset()

func (*Source_Run_Response) String 

func (x *Source_Run_Response) String() string

type Source_Start 

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

func (*Source_Start) Descriptor deprecated 

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

Deprecated: Use Source_Start.ProtoReflect.Descriptor instead.

func (*Source_Start) ProtoMessage 

func (*Source_Start) ProtoMessage()

func (*Source_Start) ProtoReflect 

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

func (*Source_Start) Reset 

func (x *Source_Start) Reset()

func (*Source_Start) String 

func (x *Source_Start) String() string

type Source_Start_Request 

type Source_Start_Request struct {

	// This is the position of the last record that was successfully
	// processed. The Source should start producing records after this
	// position.
	Position []byte `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

func (*Source_Start_Request) Descriptor deprecated 

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

Deprecated: Use Source_Start_Request.ProtoReflect.Descriptor instead.

func (*Source_Start_Request) GetPosition 

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

func (*Source_Start_Request) ProtoMessage 

func (*Source_Start_Request) ProtoMessage()

func (*Source_Start_Request) ProtoReflect 

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

func (*Source_Start_Request) Reset 

func (x *Source_Start_Request) Reset()

func (*Source_Start_Request) String 

func (x *Source_Start_Request) String() string

type Source_Start_Response 

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

func (*Source_Start_Response) Descriptor deprecated 

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

Deprecated: Use Source_Start_Response.ProtoReflect.Descriptor instead.

func (*Source_Start_Response) ProtoMessage 

func (*Source_Start_Response) ProtoMessage()

func (*Source_Start_Response) ProtoReflect 

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

func (*Source_Start_Response) Reset 

func (x *Source_Start_Response) Reset()

func (*Source_Start_Response) String 

func (x *Source_Start_Response) String() string

type Source_Stop 

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

func (*Source_Stop) Descriptor deprecated 

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

Deprecated: Use Source_Stop.ProtoReflect.Descriptor instead.

func (*Source_Stop) ProtoMessage 

func (*Source_Stop) ProtoMessage()

func (*Source_Stop) ProtoReflect 

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

func (*Source_Stop) Reset 

func (x *Source_Stop) Reset()

func (*Source_Stop) String 

func (x *Source_Stop) String() string

type Source_Stop_Request 

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

func (*Source_Stop_Request) Descriptor deprecated 

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

Deprecated: Use Source_Stop_Request.ProtoReflect.Descriptor instead.

func (*Source_Stop_Request) ProtoMessage 

func (*Source_Stop_Request) ProtoMessage()

func (*Source_Stop_Request) ProtoReflect 

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

func (*Source_Stop_Request) Reset 

func (x *Source_Stop_Request) Reset()

func (*Source_Stop_Request) String 

func (x *Source_Stop_Request) String() string

type Source_Stop_Response 

type Source_Stop_Response struct {

	// This is the position of the last record in the stream, Conduit
	// won't process records after this position anymore. After the
	// record with this position is received by Conduit and all
	// outstanding acknowledgments were delivered to the connector, the
	// stream will be closed.
	LastPosition []byte `protobuf:"bytes,1,opt,name=last_position,json=lastPosition,proto3" json:"last_position,omitempty"`
	// contains filtered or unexported fields
}

func (*Source_Stop_Response) Descriptor deprecated 

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

Deprecated: Use Source_Stop_Response.ProtoReflect.Descriptor instead.

func (*Source_Stop_Response) GetLastPosition 

func (x *Source_Stop_Response) GetLastPosition() []byte

func (*Source_Stop_Response) ProtoMessage 

func (*Source_Stop_Response) ProtoMessage()

func (*Source_Stop_Response) ProtoReflect 

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

func (*Source_Stop_Response) Reset 

func (x *Source_Stop_Response) Reset()

func (*Source_Stop_Response) String 

func (x *Source_Stop_Response) String() string

type Source_Teardown 

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

func (*Source_Teardown) Descriptor deprecated 

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

Deprecated: Use Source_Teardown.ProtoReflect.Descriptor instead.

func (*Source_Teardown) ProtoMessage 

func (*Source_Teardown) ProtoMessage()

func (*Source_Teardown) ProtoReflect 

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

func (*Source_Teardown) Reset 

func (x *Source_Teardown) Reset()

func (*Source_Teardown) String 

func (x *Source_Teardown) String() string

type Source_Teardown_Request 

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

func (*Source_Teardown_Request) Descriptor deprecated 

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

Deprecated: Use Source_Teardown_Request.ProtoReflect.Descriptor instead.

func (*Source_Teardown_Request) ProtoMessage 

func (*Source_Teardown_Request) ProtoMessage()

func (*Source_Teardown_Request) ProtoReflect 

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

func (*Source_Teardown_Request) Reset 

func (x *Source_Teardown_Request) Reset()

func (*Source_Teardown_Request) String 

func (x *Source_Teardown_Request) String() string

type Source_Teardown_Response 

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

func (*Source_Teardown_Response) Descriptor deprecated 

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

Deprecated: Use Source_Teardown_Response.ProtoReflect.Descriptor instead.

func (*Source_Teardown_Response) ProtoMessage 

func (*Source_Teardown_Response) ProtoMessage()

func (*Source_Teardown_Response) ProtoReflect 

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

func (*Source_Teardown_Response) Reset 

func (x *Source_Teardown_Response) Reset()

func (*Source_Teardown_Response) String 

func (x *Source_Teardown_Response) String() string

type Specifier 

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

func (*Specifier) Descriptor deprecated 

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

Deprecated: Use Specifier.ProtoReflect.Descriptor instead.

func (*Specifier) ProtoMessage 

func (*Specifier) ProtoMessage()

func (*Specifier) ProtoReflect 

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

func (*Specifier) Reset 

func (x *Specifier) Reset()

func (*Specifier) String 

func (x *Specifier) String() string

type SpecifierPluginClient 

type SpecifierPluginClient interface {
	// Specify should return the plugin specification.
	Specify(ctx context.Context, in *Specifier_Specify_Request, opts ...grpc.CallOption) (*Specifier_Specify_Response, error)
}

SpecifierPluginClient is the client API for SpecifierPlugin 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 NewSpecifierPluginClient 

func NewSpecifierPluginClient(cc grpc.ClientConnInterface) SpecifierPluginClient

type SpecifierPluginServer 

type SpecifierPluginServer interface {
	// Specify should return the plugin specification.
	Specify(context.Context, *Specifier_Specify_Request) (*Specifier_Specify_Response, error)
	// contains filtered or unexported methods
}

SpecifierPluginServer is the server API for SpecifierPlugin service. All implementations must embed UnimplementedSpecifierPluginServer for forward compatibility

type Specifier_Parameter 

type Specifier_Parameter struct {

	// Default is the default value of the parameter. If there is no default
	// value use an empty string.
	Default string `protobuf:"bytes,1,opt,name=default,proto3" json:"default,omitempty"`
	// Required defines whether the parameter has to be provided when
	// configuring the plugin.
	// Deprecated: add a validation of type TYPE_REQUIRED to the validations list.
	//
	// Deprecated: Marked as deprecated in connector/v1/connector.proto.
	Required bool `protobuf:"varint,2,opt,name=required,proto3" json:"required,omitempty"`
	// Description explains what the parameter does and how to configure it.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Type defines the parameter data type.
	Type Specifier_Parameter_Type `protobuf:"varint,4,opt,name=type,proto3,enum=connector.v1.Specifier_Parameter_Type" json:"type,omitempty"`
	// Validations are validations to be made on the parameter.
	Validations []*Specifier_Parameter_Validation `protobuf:"bytes,5,rep,name=validations,proto3" json:"validations,omitempty"`
	// contains filtered or unexported fields
}

Parameter describes a single config parameter.

func (*Specifier_Parameter) Descriptor deprecated 

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

Deprecated: Use Specifier_Parameter.ProtoReflect.Descriptor instead.

func (*Specifier_Parameter) GetDefault 

func (x *Specifier_Parameter) GetDefault() string

func (*Specifier_Parameter) GetDescription 

func (x *Specifier_Parameter) GetDescription() string

func (*Specifier_Parameter) GetRequired deprecated 

func (x *Specifier_Parameter) GetRequired() bool

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

func (*Specifier_Parameter) GetType 

func (x *Specifier_Parameter) GetType() Specifier_Parameter_Type

func (*Specifier_Parameter) GetValidations 

func (x *Specifier_Parameter) GetValidations() []*Specifier_Parameter_Validation

func (*Specifier_Parameter) ProtoMessage 

func (*Specifier_Parameter) ProtoMessage()

func (*Specifier_Parameter) ProtoReflect 

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

func (*Specifier_Parameter) Reset 

func (x *Specifier_Parameter) Reset()

func (*Specifier_Parameter) String 

func (x *Specifier_Parameter) String() string

type Specifier_Parameter_Type 

type Specifier_Parameter_Type int32

Type shows the parameter type. 

const (
	Specifier_Parameter_TYPE_UNSPECIFIED Specifier_Parameter_Type = 0
	// Parameter is a string.
	Specifier_Parameter_TYPE_STRING Specifier_Parameter_Type = 1
	// Parameter is an integer.
	Specifier_Parameter_TYPE_INT Specifier_Parameter_Type = 2
	// Parameter is a float.
	Specifier_Parameter_TYPE_FLOAT Specifier_Parameter_Type = 3
	// Parameter is a boolean.
	Specifier_Parameter_TYPE_BOOL Specifier_Parameter_Type = 4
	// Parameter is a file.
	Specifier_Parameter_TYPE_FILE Specifier_Parameter_Type = 5
	// Parameter is a duration.
	Specifier_Parameter_TYPE_DURATION Specifier_Parameter_Type = 6
)

func (Specifier_Parameter_Type) Descriptor 

func (Specifier_Parameter_Type) Descriptor() protoreflect.EnumDescriptor

func (Specifier_Parameter_Type) Enum 

func (x Specifier_Parameter_Type) Enum() *Specifier_Parameter_Type

func (Specifier_Parameter_Type) EnumDescriptor deprecated 

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

Deprecated: Use Specifier_Parameter_Type.Descriptor instead.

func (Specifier_Parameter_Type) Number 

func (x Specifier_Parameter_Type) Number() protoreflect.EnumNumber

func (Specifier_Parameter_Type) String 

func (x Specifier_Parameter_Type) String() string

func (Specifier_Parameter_Type) Type 

func (Specifier_Parameter_Type) Type() protoreflect.EnumType

type Specifier_Parameter_Validation 

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

Validation to be made on the parameter.

func (*Specifier_Parameter_Validation) Descriptor deprecated 

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

Deprecated: Use Specifier_Parameter_Validation.ProtoReflect.Descriptor instead.

func (*Specifier_Parameter_Validation) GetType 

func (x *Specifier_Parameter_Validation) GetType() Specifier_Parameter_Validation_Type

func (*Specifier_Parameter_Validation) GetValue 

func (x *Specifier_Parameter_Validation) GetValue() string

func (*Specifier_Parameter_Validation) ProtoMessage 

func (*Specifier_Parameter_Validation) ProtoMessage()

func (*Specifier_Parameter_Validation) ProtoReflect 

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

func (*Specifier_Parameter_Validation) Reset 

func (x *Specifier_Parameter_Validation) Reset()

func (*Specifier_Parameter_Validation) String 

func (x *Specifier_Parameter_Validation) String() string

type Specifier_Parameter_Validation_Type 

type Specifier_Parameter_Validation_Type int32
const (
	Specifier_Parameter_Validation_TYPE_UNSPECIFIED Specifier_Parameter_Validation_Type = 0
	// Parameter must be present.
	Specifier_Parameter_Validation_TYPE_REQUIRED Specifier_Parameter_Validation_Type = 1
	// Parameter must be greater than {value}.
	Specifier_Parameter_Validation_TYPE_GREATER_THAN Specifier_Parameter_Validation_Type = 2
	// Parameter must be less than {value}.
	Specifier_Parameter_Validation_TYPE_LESS_THAN Specifier_Parameter_Validation_Type = 3
	// Parameter must be included in the comma separated list {value}.
	Specifier_Parameter_Validation_TYPE_INCLUSION Specifier_Parameter_Validation_Type = 4
	// Parameter must not be included in the comma separated list {value}.
	Specifier_Parameter_Validation_TYPE_EXCLUSION Specifier_Parameter_Validation_Type = 5
	// Parameter must match the regex {value}.
	Specifier_Parameter_Validation_TYPE_REGEX Specifier_Parameter_Validation_Type = 6
)

func (Specifier_Parameter_Validation_Type) Descriptor 

func (Specifier_Parameter_Validation_Type) Descriptor() protoreflect.EnumDescriptor

func (Specifier_Parameter_Validation_Type) Enum 

func (x Specifier_Parameter_Validation_Type) Enum() *Specifier_Parameter_Validation_Type

func (Specifier_Parameter_Validation_Type) EnumDescriptor deprecated 

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

Deprecated: Use Specifier_Parameter_Validation_Type.Descriptor instead.

func (Specifier_Parameter_Validation_Type) Number 

func (x Specifier_Parameter_Validation_Type) Number() protoreflect.EnumNumber

func (Specifier_Parameter_Validation_Type) String 

func (x Specifier_Parameter_Validation_Type) String() string

func (Specifier_Parameter_Validation_Type) Type 

func (Specifier_Parameter_Validation_Type) Type() protoreflect.EnumType

type Specifier_Specify 

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

func (*Specifier_Specify) Descriptor deprecated 

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

Deprecated: Use Specifier_Specify.ProtoReflect.Descriptor instead.

func (*Specifier_Specify) ProtoMessage 

func (*Specifier_Specify) ProtoMessage()

func (*Specifier_Specify) ProtoReflect 

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

func (*Specifier_Specify) Reset 

func (x *Specifier_Specify) Reset()

func (*Specifier_Specify) String 

func (x *Specifier_Specify) String() string

type Specifier_Specify_Request 

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

func (*Specifier_Specify_Request) Descriptor deprecated 

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

Deprecated: Use Specifier_Specify_Request.ProtoReflect.Descriptor instead.

func (*Specifier_Specify_Request) ProtoMessage 

func (*Specifier_Specify_Request) ProtoMessage()

func (*Specifier_Specify_Request) ProtoReflect 

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

func (*Specifier_Specify_Request) Reset 

func (x *Specifier_Specify_Request) Reset()

func (*Specifier_Specify_Request) String 

func (x *Specifier_Specify_Request) String() string

type Specifier_Specify_Response 

type Specifier_Specify_Response struct {

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

func (*Specifier_Specify_Response) Descriptor deprecated 

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

Deprecated: Use Specifier_Specify_Response.ProtoReflect.Descriptor instead.

func (*Specifier_Specify_Response) GetAuthor 

func (x *Specifier_Specify_Response) GetAuthor() string

func (*Specifier_Specify_Response) GetDescription 

func (x *Specifier_Specify_Response) GetDescription() string

func (*Specifier_Specify_Response) GetDestinationParams 

func (x *Specifier_Specify_Response) GetDestinationParams() map[string]*Specifier_Parameter

func (*Specifier_Specify_Response) GetName 

func (x *Specifier_Specify_Response) GetName() string

func (*Specifier_Specify_Response) GetSourceParams 

func (x *Specifier_Specify_Response) GetSourceParams() map[string]*Specifier_Parameter

func (*Specifier_Specify_Response) GetSummary 

func (x *Specifier_Specify_Response) GetSummary() string

func (*Specifier_Specify_Response) GetVersion 

func (x *Specifier_Specify_Response) GetVersion() string

func (*Specifier_Specify_Response) ProtoMessage 

func (*Specifier_Specify_Response) ProtoMessage()

func (*Specifier_Specify_Response) ProtoReflect 

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

func (*Specifier_Specify_Response) Reset 

func (x *Specifier_Specify_Response) Reset()

func (*Specifier_Specify_Response) String 

func (x *Specifier_Specify_Response) String() string

type UnimplementedDestinationPluginServer 

type UnimplementedDestinationPluginServer struct {
}

UnimplementedDestinationPluginServer must be embedded to have forward compatible implementations.

func (UnimplementedDestinationPluginServer) Configure 

func (UnimplementedDestinationPluginServer) Configure(context.Context, *Destination_Configure_Request) (*Destination_Configure_Response, error)

func (UnimplementedDestinationPluginServer) LifecycleOnCreated added in v0.5.0 

func (UnimplementedDestinationPluginServer) LifecycleOnCreated(context.Context, *Destination_Lifecycle_OnCreated_Request) (*Destination_Lifecycle_OnCreated_Response, error)

func (UnimplementedDestinationPluginServer) LifecycleOnDeleted added in v0.5.0 

func (UnimplementedDestinationPluginServer) LifecycleOnDeleted(context.Context, *Destination_Lifecycle_OnDeleted_Request) (*Destination_Lifecycle_OnDeleted_Response, error)

func (UnimplementedDestinationPluginServer) LifecycleOnUpdated added in v0.5.0 

func (UnimplementedDestinationPluginServer) LifecycleOnUpdated(context.Context, *Destination_Lifecycle_OnUpdated_Request) (*Destination_Lifecycle_OnUpdated_Response, error)

func (UnimplementedDestinationPluginServer) Run 

func (UnimplementedDestinationPluginServer) Run(DestinationPlugin_RunServer) error

func (UnimplementedDestinationPluginServer) Start 

func (UnimplementedDestinationPluginServer) Start(context.Context, *Destination_Start_Request) (*Destination_Start_Response, error)

func (UnimplementedDestinationPluginServer) Stop 

func (UnimplementedDestinationPluginServer) Stop(context.Context, *Destination_Stop_Request) (*Destination_Stop_Response, error)

func (UnimplementedDestinationPluginServer) Teardown 

func (UnimplementedDestinationPluginServer) Teardown(context.Context, *Destination_Teardown_Request) (*Destination_Teardown_Response, error)

type UnimplementedSourcePluginServer 

type UnimplementedSourcePluginServer struct {
}

UnimplementedSourcePluginServer must be embedded to have forward compatible implementations.

func (UnimplementedSourcePluginServer) Configure 

func (UnimplementedSourcePluginServer) Configure(context.Context, *Source_Configure_Request) (*Source_Configure_Response, error)

func (UnimplementedSourcePluginServer) LifecycleOnCreated added in v0.5.0 

func (UnimplementedSourcePluginServer) LifecycleOnCreated(context.Context, *Source_Lifecycle_OnCreated_Request) (*Source_Lifecycle_OnCreated_Response, error)

func (UnimplementedSourcePluginServer) LifecycleOnDeleted added in v0.5.0 

func (UnimplementedSourcePluginServer) LifecycleOnDeleted(context.Context, *Source_Lifecycle_OnDeleted_Request) (*Source_Lifecycle_OnDeleted_Response, error)

func (UnimplementedSourcePluginServer) LifecycleOnUpdated added in v0.5.0 

func (UnimplementedSourcePluginServer) LifecycleOnUpdated(context.Context, *Source_Lifecycle_OnUpdated_Request) (*Source_Lifecycle_OnUpdated_Response, error)

func (UnimplementedSourcePluginServer) Run 

func (UnimplementedSourcePluginServer) Run(SourcePlugin_RunServer) error

func (UnimplementedSourcePluginServer) Start 

func (UnimplementedSourcePluginServer) Start(context.Context, *Source_Start_Request) (*Source_Start_Response, error)

func (UnimplementedSourcePluginServer) Stop 

func (UnimplementedSourcePluginServer) Stop(context.Context, *Source_Stop_Request) (*Source_Stop_Response, error)

func (UnimplementedSourcePluginServer) Teardown 

func (UnimplementedSourcePluginServer) Teardown(context.Context, *Source_Teardown_Request) (*Source_Teardown_Response, error)

type UnimplementedSpecifierPluginServer 

type UnimplementedSpecifierPluginServer struct {
}

UnimplementedSpecifierPluginServer must be embedded to have forward compatible implementations.

func (UnimplementedSpecifierPluginServer) Specify 

func (UnimplementedSpecifierPluginServer) Specify(context.Context, *Specifier_Specify_Request) (*Specifier_Specify_Response, error)

type UnsafeDestinationPluginServer 

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

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

type UnsafeSourcePluginServer 

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

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

type UnsafeSpecifierPluginServer 

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

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

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.