toplugin

package

v0.9.0-nightly.20231202 Latest Latest Go to latest Published: Dec 1, 2023 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/conduitio/conduit

Documentation ¶

Index ¶

func Change(in record.Change) (cpluginv1.Change, error)
func Data(in record.Data) (cpluginv1.Data, error)
func DestinationConfigureRequest(in map[string]string) cpluginv1.DestinationConfigureRequest
func DestinationLifecycleOnCreatedRequest(cfg map[string]string) cpluginv1.DestinationLifecycleOnCreatedRequest
func DestinationLifecycleOnDeletedRequest(cfg map[string]string) cpluginv1.DestinationLifecycleOnDeletedRequest
func DestinationLifecycleOnUpdatedRequest(cfgBefore, cfgAfter map[string]string) cpluginv1.DestinationLifecycleOnUpdatedRequest
func DestinationRunRequest(in record.Record) (cpluginv1.DestinationRunRequest, error)
func DestinationStartRequest() cpluginv1.DestinationStartRequest
func DestinationStopRequest(in record.Position) cpluginv1.DestinationStopRequest
func DestinationTeardownRequest() cpluginv1.DestinationTeardownRequest
func Record(in record.Record) (cpluginv1.Record, error)
func SourceConfigureRequest(in map[string]string) cpluginv1.SourceConfigureRequest
func SourceLifecycleOnCreatedRequest(cfg map[string]string) cpluginv1.SourceLifecycleOnCreatedRequest
func SourceLifecycleOnDeletedRequest(cfg map[string]string) cpluginv1.SourceLifecycleOnDeletedRequest
func SourceLifecycleOnUpdatedRequest(cfgBefore, cfgAfter map[string]string) cpluginv1.SourceLifecycleOnUpdatedRequest
func SourceRunRequest(in record.Position) cpluginv1.SourceRunRequest
func SourceStartRequest(in record.Position) cpluginv1.SourceStartRequest
func SourceStopRequest() cpluginv1.SourceStopRequest
func SourceTeardownRequest() cpluginv1.SourceTeardownRequest
func SpecifierSpecifyRequest() cpluginv1.SpecifierSpecifyRequest

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Change ¶ added in v0.3.0

func Change(in record.Change) (cpluginv1.Change, error)

func Data ¶

func Data(in record.Data) (cpluginv1.Data, error)

func DestinationConfigureRequest ¶

func DestinationConfigureRequest(in map[string]string) cpluginv1.DestinationConfigureRequest

func DestinationLifecycleOnCreatedRequest ¶ added in v0.6.0

func DestinationLifecycleOnCreatedRequest(cfg map[string]string) cpluginv1.DestinationLifecycleOnCreatedRequest

func DestinationLifecycleOnDeletedRequest ¶ added in v0.6.0

func DestinationLifecycleOnDeletedRequest(cfg map[string]string) cpluginv1.DestinationLifecycleOnDeletedRequest

func DestinationLifecycleOnUpdatedRequest ¶ added in v0.6.0

func DestinationLifecycleOnUpdatedRequest(cfgBefore, cfgAfter map[string]string) cpluginv1.DestinationLifecycleOnUpdatedRequest

func DestinationRunRequest ¶

func DestinationRunRequest(in record.Record) (cpluginv1.DestinationRunRequest, error)

func DestinationStartRequest ¶

func DestinationStartRequest() cpluginv1.DestinationStartRequest

func DestinationStopRequest ¶

func DestinationStopRequest(in record.Position) cpluginv1.DestinationStopRequest

func DestinationTeardownRequest ¶

func DestinationTeardownRequest() cpluginv1.DestinationTeardownRequest

func Record ¶

func Record(in record.Record) (cpluginv1.Record, error)

func SourceConfigureRequest ¶

func SourceConfigureRequest(in map[string]string) cpluginv1.SourceConfigureRequest

func SourceLifecycleOnCreatedRequest ¶ added in v0.6.0

func SourceLifecycleOnCreatedRequest(cfg map[string]string) cpluginv1.SourceLifecycleOnCreatedRequest

func SourceLifecycleOnDeletedRequest ¶ added in v0.6.0

func SourceLifecycleOnDeletedRequest(cfg map[string]string) cpluginv1.SourceLifecycleOnDeletedRequest

func SourceLifecycleOnUpdatedRequest ¶ added in v0.6.0

func SourceLifecycleOnUpdatedRequest(cfgBefore, cfgAfter map[string]string) cpluginv1.SourceLifecycleOnUpdatedRequest

func SourceRunRequest ¶

func SourceRunRequest(in record.Position) cpluginv1.SourceRunRequest

func SourceStartRequest ¶

func SourceStartRequest(in record.Position) cpluginv1.SourceStartRequest

func SourceStopRequest ¶

func SourceStopRequest() cpluginv1.SourceStopRequest

func SourceTeardownRequest ¶

func SourceTeardownRequest() cpluginv1.SourceTeardownRequest

func SpecifierSpecifyRequest ¶

func SpecifierSpecifyRequest() cpluginv1.SpecifierSpecifyRequest

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL