connectorv2

package
v0.9.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

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

Variables

View Source 
var DestinationPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "connector.v2.DestinationPlugin",
	HandlerType: (*DestinationPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Configure",
			Handler:    _DestinationPlugin_Configure_Handler,
		},
		{
			MethodName: "Open",
			Handler:    _DestinationPlugin_Open_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/v2/destination.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_v2_destination_proto protoreflect.FileDescriptor
View Source 
var File_connector_v2_source_proto protoreflect.FileDescriptor
View Source 
var File_connector_v2_specifier_proto protoreflect.FileDescriptor
View Source 
var SourcePlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "connector.v2.SourcePlugin",
	HandlerType: (*SourcePluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Configure",
			Handler:    _SourcePlugin_Configure_Handler,
		},
		{
			MethodName: "Open",
			Handler:    _SourcePlugin_Open_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/v2/source.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.v2.SpecifierPlugin",
	HandlerType: (*SpecifierPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Specify",
			Handler:    _SpecifierPlugin_Specify_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "connector/v2/specifier.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)
	// Open 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.
	Open(ctx context.Context, in *Destination_Open_Request, opts ...grpc.CallOption) (*Destination_Open_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 Open 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 Open 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)
	// Open 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.
	Open(context.Context, *Destination_Open_Request) (*Destination_Open_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 Open 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 Open 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 

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

func (*Destination_Lifecycle) Descriptor deprecated 

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

Deprecated: Use Destination_Lifecycle.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle) ProtoMessage 

func (*Destination_Lifecycle) ProtoMessage()

func (*Destination_Lifecycle) ProtoReflect 

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

func (*Destination_Lifecycle) Reset 

func (x *Destination_Lifecycle) Reset()

func (*Destination_Lifecycle) String 

func (x *Destination_Lifecycle) String() string

type Destination_Lifecycle_OnCreated 

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

func (*Destination_Lifecycle_OnCreated) Descriptor deprecated 

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

Deprecated: Use Destination_Lifecycle_OnCreated.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnCreated) ProtoMessage 

func (*Destination_Lifecycle_OnCreated) ProtoMessage()

func (*Destination_Lifecycle_OnCreated) ProtoReflect 

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

func (*Destination_Lifecycle_OnCreated) Reset 

func (x *Destination_Lifecycle_OnCreated) Reset()

func (*Destination_Lifecycle_OnCreated) String 

func (x *Destination_Lifecycle_OnCreated) String() string

type Destination_Lifecycle_OnCreated_Request 

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 

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

Deprecated: Use Destination_Lifecycle_OnCreated_Request.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnCreated_Request) GetConfig 

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

func (*Destination_Lifecycle_OnCreated_Request) ProtoMessage 

func (*Destination_Lifecycle_OnCreated_Request) ProtoMessage()

func (*Destination_Lifecycle_OnCreated_Request) ProtoReflect 

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

func (*Destination_Lifecycle_OnCreated_Request) Reset 

func (x *Destination_Lifecycle_OnCreated_Request) Reset()

func (*Destination_Lifecycle_OnCreated_Request) String 

func (x *Destination_Lifecycle_OnCreated_Request) String() string

type Destination_Lifecycle_OnCreated_Response 

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

func (*Destination_Lifecycle_OnCreated_Response) Descriptor deprecated 

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

Deprecated: Use Destination_Lifecycle_OnCreated_Response.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnCreated_Response) ProtoMessage 

func (*Destination_Lifecycle_OnCreated_Response) ProtoMessage()

func (*Destination_Lifecycle_OnCreated_Response) ProtoReflect 

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

func (*Destination_Lifecycle_OnCreated_Response) Reset 

func (x *Destination_Lifecycle_OnCreated_Response) Reset()

func (*Destination_Lifecycle_OnCreated_Response) String 

func (x *Destination_Lifecycle_OnCreated_Response) String() string

type Destination_Lifecycle_OnDeleted 

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

func (*Destination_Lifecycle_OnDeleted) Descriptor deprecated 

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

Deprecated: Use Destination_Lifecycle_OnDeleted.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnDeleted) ProtoMessage 

func (*Destination_Lifecycle_OnDeleted) ProtoMessage()

func (*Destination_Lifecycle_OnDeleted) ProtoReflect 

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

func (*Destination_Lifecycle_OnDeleted) Reset 

func (x *Destination_Lifecycle_OnDeleted) Reset()

func (*Destination_Lifecycle_OnDeleted) String 

func (x *Destination_Lifecycle_OnDeleted) String() string

type Destination_Lifecycle_OnDeleted_Request 

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 

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

Deprecated: Use Destination_Lifecycle_OnDeleted_Request.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnDeleted_Request) GetConfig 

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

func (*Destination_Lifecycle_OnDeleted_Request) ProtoMessage 

func (*Destination_Lifecycle_OnDeleted_Request) ProtoMessage()

func (*Destination_Lifecycle_OnDeleted_Request) ProtoReflect 

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

func (*Destination_Lifecycle_OnDeleted_Request) Reset 

func (x *Destination_Lifecycle_OnDeleted_Request) Reset()

func (*Destination_Lifecycle_OnDeleted_Request) String 

func (x *Destination_Lifecycle_OnDeleted_Request) String() string

type Destination_Lifecycle_OnDeleted_Response 

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

func (*Destination_Lifecycle_OnDeleted_Response) Descriptor deprecated 

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

Deprecated: Use Destination_Lifecycle_OnDeleted_Response.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnDeleted_Response) ProtoMessage 

func (*Destination_Lifecycle_OnDeleted_Response) ProtoMessage()

func (*Destination_Lifecycle_OnDeleted_Response) ProtoReflect 

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

func (*Destination_Lifecycle_OnDeleted_Response) Reset 

func (x *Destination_Lifecycle_OnDeleted_Response) Reset()

func (*Destination_Lifecycle_OnDeleted_Response) String 

func (x *Destination_Lifecycle_OnDeleted_Response) String() string

type Destination_Lifecycle_OnUpdated 

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

func (*Destination_Lifecycle_OnUpdated) Descriptor deprecated 

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

Deprecated: Use Destination_Lifecycle_OnUpdated.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnUpdated) ProtoMessage 

func (*Destination_Lifecycle_OnUpdated) ProtoMessage()

func (*Destination_Lifecycle_OnUpdated) ProtoReflect 

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

func (*Destination_Lifecycle_OnUpdated) Reset 

func (x *Destination_Lifecycle_OnUpdated) Reset()

func (*Destination_Lifecycle_OnUpdated) String 

func (x *Destination_Lifecycle_OnUpdated) String() string

type Destination_Lifecycle_OnUpdated_Request 

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 

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

Deprecated: Use Destination_Lifecycle_OnUpdated_Request.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnUpdated_Request) GetConfigAfter 

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

func (*Destination_Lifecycle_OnUpdated_Request) GetConfigBefore 

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

func (*Destination_Lifecycle_OnUpdated_Request) ProtoMessage 

func (*Destination_Lifecycle_OnUpdated_Request) ProtoMessage()

func (*Destination_Lifecycle_OnUpdated_Request) ProtoReflect 

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

func (*Destination_Lifecycle_OnUpdated_Request) Reset 

func (x *Destination_Lifecycle_OnUpdated_Request) Reset()

func (*Destination_Lifecycle_OnUpdated_Request) String 

func (x *Destination_Lifecycle_OnUpdated_Request) String() string

type Destination_Lifecycle_OnUpdated_Response 

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

func (*Destination_Lifecycle_OnUpdated_Response) Descriptor deprecated 

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

Deprecated: Use Destination_Lifecycle_OnUpdated_Response.ProtoReflect.Descriptor instead.

func (*Destination_Lifecycle_OnUpdated_Response) ProtoMessage 

func (*Destination_Lifecycle_OnUpdated_Response) ProtoMessage()

func (*Destination_Lifecycle_OnUpdated_Response) ProtoReflect 

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

func (*Destination_Lifecycle_OnUpdated_Response) Reset 

func (x *Destination_Lifecycle_OnUpdated_Response) Reset()

func (*Destination_Lifecycle_OnUpdated_Response) String 

func (x *Destination_Lifecycle_OnUpdated_Response) String() string

type Destination_Open 

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

func (*Destination_Open) Descriptor deprecated 

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

Deprecated: Use Destination_Open.ProtoReflect.Descriptor instead.

func (*Destination_Open) ProtoMessage 

func (*Destination_Open) ProtoMessage()

func (*Destination_Open) ProtoReflect 

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

func (*Destination_Open) Reset 

func (x *Destination_Open) Reset()

func (*Destination_Open) String 

func (x *Destination_Open) String() string

type Destination_Open_Request 

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

func (*Destination_Open_Request) Descriptor deprecated 

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

Deprecated: Use Destination_Open_Request.ProtoReflect.Descriptor instead.

func (*Destination_Open_Request) ProtoMessage 

func (*Destination_Open_Request) ProtoMessage()

func (*Destination_Open_Request) ProtoReflect 

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

func (*Destination_Open_Request) Reset 

func (x *Destination_Open_Request) Reset()

func (*Destination_Open_Request) String 

func (x *Destination_Open_Request) String() string

type Destination_Open_Response 

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

func (*Destination_Open_Response) Descriptor deprecated 

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

Deprecated: Use Destination_Open_Response.ProtoReflect.Descriptor instead.

func (*Destination_Open_Response) ProtoMessage 

func (*Destination_Open_Response) ProtoMessage()

func (*Destination_Open_Response) ProtoReflect 

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

func (*Destination_Open_Response) Reset 

func (x *Destination_Open_Response) Reset()

func (*Destination_Open_Response) String 

func (x *Destination_Open_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 {

	// Records contains a batch of OpenCDC records that should be written to
	// the 3rd party resource.
	Records []*v1.Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,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) GetRecords 

func (x *Destination_Run_Request) GetRecords() []*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 {

	// Ack contains the acknowledgments for the records that were processed.
	Acks []*Destination_Run_Response_Ack `protobuf:"bytes,1,rep,name=acks,proto3" json:"acks,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) GetAcks 

func (x *Destination_Run_Response) GetAcks() []*Destination_Run_Response_Ack

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_Run_Response_Ack 

type Destination_Run_Response_Ack struct {

	// These is the position of the record that was processed.
	Position []byte `protobuf:"bytes,1,opt,name=position,proto3" json:"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_Ack) Descriptor deprecated 

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

Deprecated: Use Destination_Run_Response_Ack.ProtoReflect.Descriptor instead.

func (*Destination_Run_Response_Ack) GetError 

func (x *Destination_Run_Response_Ack) GetError() string

func (*Destination_Run_Response_Ack) GetPosition 

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

func (*Destination_Run_Response_Ack) ProtoMessage 

func (*Destination_Run_Response_Ack) ProtoMessage()

func (*Destination_Run_Response_Ack) ProtoReflect 

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

func (*Destination_Run_Response_Ack) Reset 

func (x *Destination_Run_Response_Ack) Reset()

func (*Destination_Run_Response_Ack) String 

func (x *Destination_Run_Response_Ack) 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)
	// Open 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.
	Open(ctx context.Context, in *Source_Open_Request, opts ...grpc.CallOption) (*Source_Open_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 Open 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 Open 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)
	// Open 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.
	Open(context.Context, *Source_Open_Request) (*Source_Open_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 Open 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 Open 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 

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

func (*Source_Lifecycle) Descriptor deprecated 

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

Deprecated: Use Source_Lifecycle.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle) ProtoMessage 

func (*Source_Lifecycle) ProtoMessage()

func (*Source_Lifecycle) ProtoReflect 

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

func (*Source_Lifecycle) Reset 

func (x *Source_Lifecycle) Reset()

func (*Source_Lifecycle) String 

func (x *Source_Lifecycle) String() string

type Source_Lifecycle_OnCreated 

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

func (*Source_Lifecycle_OnCreated) Descriptor deprecated 

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

Deprecated: Use Source_Lifecycle_OnCreated.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnCreated) ProtoMessage 

func (*Source_Lifecycle_OnCreated) ProtoMessage()

func (*Source_Lifecycle_OnCreated) ProtoReflect 

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

func (*Source_Lifecycle_OnCreated) Reset 

func (x *Source_Lifecycle_OnCreated) Reset()

func (*Source_Lifecycle_OnCreated) String 

func (x *Source_Lifecycle_OnCreated) String() string

type Source_Lifecycle_OnCreated_Request 

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 

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

Deprecated: Use Source_Lifecycle_OnCreated_Request.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnCreated_Request) GetConfig 

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

func (*Source_Lifecycle_OnCreated_Request) ProtoMessage 

func (*Source_Lifecycle_OnCreated_Request) ProtoMessage()

func (*Source_Lifecycle_OnCreated_Request) ProtoReflect 

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

func (*Source_Lifecycle_OnCreated_Request) Reset 

func (x *Source_Lifecycle_OnCreated_Request) Reset()

func (*Source_Lifecycle_OnCreated_Request) String 

func (x *Source_Lifecycle_OnCreated_Request) String() string

type Source_Lifecycle_OnCreated_Response 

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

func (*Source_Lifecycle_OnCreated_Response) Descriptor deprecated 

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

Deprecated: Use Source_Lifecycle_OnCreated_Response.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnCreated_Response) ProtoMessage 

func (*Source_Lifecycle_OnCreated_Response) ProtoMessage()

func (*Source_Lifecycle_OnCreated_Response) ProtoReflect 

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

func (*Source_Lifecycle_OnCreated_Response) Reset 

func (x *Source_Lifecycle_OnCreated_Response) Reset()

func (*Source_Lifecycle_OnCreated_Response) String 

func (x *Source_Lifecycle_OnCreated_Response) String() string

type Source_Lifecycle_OnDeleted 

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

func (*Source_Lifecycle_OnDeleted) Descriptor deprecated 

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

Deprecated: Use Source_Lifecycle_OnDeleted.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnDeleted) ProtoMessage 

func (*Source_Lifecycle_OnDeleted) ProtoMessage()

func (*Source_Lifecycle_OnDeleted) ProtoReflect 

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

func (*Source_Lifecycle_OnDeleted) Reset 

func (x *Source_Lifecycle_OnDeleted) Reset()

func (*Source_Lifecycle_OnDeleted) String 

func (x *Source_Lifecycle_OnDeleted) String() string

type Source_Lifecycle_OnDeleted_Request 

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 

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

Deprecated: Use Source_Lifecycle_OnDeleted_Request.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnDeleted_Request) GetConfig 

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

func (*Source_Lifecycle_OnDeleted_Request) ProtoMessage 

func (*Source_Lifecycle_OnDeleted_Request) ProtoMessage()

func (*Source_Lifecycle_OnDeleted_Request) ProtoReflect 

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

func (*Source_Lifecycle_OnDeleted_Request) Reset 

func (x *Source_Lifecycle_OnDeleted_Request) Reset()

func (*Source_Lifecycle_OnDeleted_Request) String 

func (x *Source_Lifecycle_OnDeleted_Request) String() string

type Source_Lifecycle_OnDeleted_Response 

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

func (*Source_Lifecycle_OnDeleted_Response) Descriptor deprecated 

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

Deprecated: Use Source_Lifecycle_OnDeleted_Response.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnDeleted_Response) ProtoMessage 

func (*Source_Lifecycle_OnDeleted_Response) ProtoMessage()

func (*Source_Lifecycle_OnDeleted_Response) ProtoReflect 

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

func (*Source_Lifecycle_OnDeleted_Response) Reset 

func (x *Source_Lifecycle_OnDeleted_Response) Reset()

func (*Source_Lifecycle_OnDeleted_Response) String 

func (x *Source_Lifecycle_OnDeleted_Response) String() string

type Source_Lifecycle_OnUpdated 

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

func (*Source_Lifecycle_OnUpdated) Descriptor deprecated 

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

Deprecated: Use Source_Lifecycle_OnUpdated.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnUpdated) ProtoMessage 

func (*Source_Lifecycle_OnUpdated) ProtoMessage()

func (*Source_Lifecycle_OnUpdated) ProtoReflect 

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

func (*Source_Lifecycle_OnUpdated) Reset 

func (x *Source_Lifecycle_OnUpdated) Reset()

func (*Source_Lifecycle_OnUpdated) String 

func (x *Source_Lifecycle_OnUpdated) String() string

type Source_Lifecycle_OnUpdated_Request 

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 

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

Deprecated: Use Source_Lifecycle_OnUpdated_Request.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnUpdated_Request) GetConfigAfter 

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

func (*Source_Lifecycle_OnUpdated_Request) GetConfigBefore 

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

func (*Source_Lifecycle_OnUpdated_Request) ProtoMessage 

func (*Source_Lifecycle_OnUpdated_Request) ProtoMessage()

func (*Source_Lifecycle_OnUpdated_Request) ProtoReflect 

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

func (*Source_Lifecycle_OnUpdated_Request) Reset 

func (x *Source_Lifecycle_OnUpdated_Request) Reset()

func (*Source_Lifecycle_OnUpdated_Request) String 

func (x *Source_Lifecycle_OnUpdated_Request) String() string

type Source_Lifecycle_OnUpdated_Response 

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

func (*Source_Lifecycle_OnUpdated_Response) Descriptor deprecated 

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

Deprecated: Use Source_Lifecycle_OnUpdated_Response.ProtoReflect.Descriptor instead.

func (*Source_Lifecycle_OnUpdated_Response) ProtoMessage 

func (*Source_Lifecycle_OnUpdated_Response) ProtoMessage()

func (*Source_Lifecycle_OnUpdated_Response) ProtoReflect 

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

func (*Source_Lifecycle_OnUpdated_Response) Reset 

func (x *Source_Lifecycle_OnUpdated_Response) Reset()

func (*Source_Lifecycle_OnUpdated_Response) String 

func (x *Source_Lifecycle_OnUpdated_Response) String() string

type Source_Open 

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

func (*Source_Open) Descriptor deprecated 

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

Deprecated: Use Source_Open.ProtoReflect.Descriptor instead.

func (*Source_Open) ProtoMessage 

func (*Source_Open) ProtoMessage()

func (*Source_Open) ProtoReflect 

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

func (*Source_Open) Reset 

func (x *Source_Open) Reset()

func (*Source_Open) String 

func (x *Source_Open) String() string

type Source_Open_Request 

type Source_Open_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_Open_Request) Descriptor deprecated 

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

Deprecated: Use Source_Open_Request.ProtoReflect.Descriptor instead.

func (*Source_Open_Request) GetPosition 

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

func (*Source_Open_Request) ProtoMessage 

func (*Source_Open_Request) ProtoMessage()

func (*Source_Open_Request) ProtoReflect 

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

func (*Source_Open_Request) Reset 

func (x *Source_Open_Request) Reset()

func (*Source_Open_Request) String 

func (x *Source_Open_Request) String() string

type Source_Open_Response 

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

func (*Source_Open_Response) Descriptor deprecated 

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

Deprecated: Use Source_Open_Response.ProtoReflect.Descriptor instead.

func (*Source_Open_Response) ProtoMessage 

func (*Source_Open_Response) ProtoMessage()

func (*Source_Open_Response) ProtoReflect 

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

func (*Source_Open_Response) Reset 

func (x *Source_Open_Response) Reset()

func (*Source_Open_Response) String 

func (x *Source_Open_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 {

	// These are the positions of the records that were successfully
	// processed.
	AckPositions [][]byte `protobuf:"bytes,1,rep,name=ack_positions,json=ackPositions,proto3" json:"ack_positions,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) GetAckPositions 

func (x *Source_Run_Request) GetAckPositions() [][]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 {

	// Records contains the OpenCDC records read by the source from the 3rd
	// party resource.
	Records []*v1.Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,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) GetRecords 

func (x *Source_Run_Response) GetRecords() []*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_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 Specification 

type Specification struct {

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

func (*Specification) Descriptor deprecated 

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

Deprecated: Use Specification.ProtoReflect.Descriptor instead.

func (*Specification) GetAuthor 

func (x *Specification) GetAuthor() string

func (*Specification) GetDescription 

func (x *Specification) GetDescription() string

func (*Specification) GetDestinationParams 

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

func (*Specification) GetName 

func (x *Specification) GetName() string

func (*Specification) GetSourceParams 

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

func (*Specification) GetSummary 

func (x *Specification) GetSummary() string

func (*Specification) GetVersion 

func (x *Specification) GetVersion() string

func (*Specification) ProtoMessage 

func (*Specification) ProtoMessage()

func (*Specification) ProtoReflect 

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

func (*Specification) Reset 

func (x *Specification) Reset()

func (*Specification) String 

func (x *Specification) 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_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 {
	Specification *Specification `protobuf:"bytes,1,opt,name=specification,proto3" json:"specification,omitempty"`
	// 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) GetSpecification 

func (x *Specifier_Specify_Response) GetSpecification() *Specification

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 

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

func (UnimplementedDestinationPluginServer) LifecycleOnDeleted 

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

func (UnimplementedDestinationPluginServer) LifecycleOnUpdated 

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

func (UnimplementedDestinationPluginServer) Open 

func (UnimplementedDestinationPluginServer) Open(context.Context, *Destination_Open_Request) (*Destination_Open_Response, error)

func (UnimplementedDestinationPluginServer) Run 

func (UnimplementedDestinationPluginServer) Run(DestinationPlugin_RunServer) 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 

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

func (UnimplementedSourcePluginServer) LifecycleOnDeleted 

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

func (UnimplementedSourcePluginServer) LifecycleOnUpdated 

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

func (UnimplementedSourcePluginServer) Open 

func (UnimplementedSourcePluginServer) Open(context.Context, *Source_Open_Request) (*Source_Open_Response, error)

func (UnimplementedSourcePluginServer) Run 

func (UnimplementedSourcePluginServer) Run(SourcePlugin_RunServer) 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.