Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pconnector

package

Go to main page

Versions in this module

v0

v0.9.4

May 26, 2025

Changes in this version

+ const EnvConduitConnectorMaxReceiveRecordSize

+ type GRPCConfig struct

+ ConnectorUtilitiesTarget string

+ MaxReceiveRecordSize int

type PluginConfig

+ Grpc GRPCConfig

v0.9.3

May 16, 2025

v0.9.2

Mar 19, 2025

v0.9.1

Feb 4, 2025

v0.9.0

Nov 8, 2024

v0.8.0

Oct 9, 2024

v0.7.0

Aug 7, 2024

Changes in this version

+ const EnvConduitConnectorID

+ const EnvConduitConnectorLogLevel

+ var ErrUnimplemented = errors.New("method not implemented")

+ var HandshakeConfig = plugin.HandshakeConfig

+ type DestinationConfigureRequest struct

+ Config config.Config

+ func (r DestinationConfigureRequest) Clone() DestinationConfigureRequest

+ type DestinationConfigureResponse struct

+ func (r DestinationConfigureResponse) Clone() DestinationConfigureResponse

+ type DestinationLifecycleOnCreatedRequest struct

+ Config config.Config

+ func (r DestinationLifecycleOnCreatedRequest) Clone() DestinationLifecycleOnCreatedRequest

+ type DestinationLifecycleOnCreatedResponse struct

+ func (r DestinationLifecycleOnCreatedResponse) Clone() DestinationLifecycleOnCreatedResponse

+ type DestinationLifecycleOnDeletedRequest struct

+ Config config.Config

+ func (r DestinationLifecycleOnDeletedRequest) Clone() DestinationLifecycleOnDeletedRequest

+ type DestinationLifecycleOnDeletedResponse struct

+ func (r DestinationLifecycleOnDeletedResponse) Clone() DestinationLifecycleOnDeletedResponse

+ type DestinationLifecycleOnUpdatedRequest struct

+ ConfigAfter config.Config

+ ConfigBefore config.Config

+ func (r DestinationLifecycleOnUpdatedRequest) Clone() DestinationLifecycleOnUpdatedRequest

+ type DestinationLifecycleOnUpdatedResponse struct

+ func (r DestinationLifecycleOnUpdatedResponse) Clone() DestinationLifecycleOnUpdatedResponse

+ type DestinationOpenRequest struct

+ func (r DestinationOpenRequest) Clone() DestinationOpenRequest

+ type DestinationOpenResponse struct

+ func (r DestinationOpenResponse) Clone() DestinationOpenResponse

+ type DestinationPlugin interface

+ Configure func(context.Context, DestinationConfigureRequest) (DestinationConfigureResponse, error)

+ LifecycleOnCreated func(context.Context, DestinationLifecycleOnCreatedRequest) (DestinationLifecycleOnCreatedResponse, error)

+ LifecycleOnDeleted func(context.Context, DestinationLifecycleOnDeletedRequest) (DestinationLifecycleOnDeletedResponse, error)

+ LifecycleOnUpdated func(context.Context, DestinationLifecycleOnUpdatedRequest) (DestinationLifecycleOnUpdatedResponse, error)

+ Open func(context.Context, DestinationOpenRequest) (DestinationOpenResponse, error)

+ Run func(context.Context, DestinationRunStream) error

+ Stop func(context.Context, DestinationStopRequest) (DestinationStopResponse, error)

+ Teardown func(context.Context, DestinationTeardownRequest) (DestinationTeardownResponse, error)

+ type DestinationRunRequest struct

+ Records []opencdc.Record

+ func (r DestinationRunRequest) Clone() DestinationRunRequest

+ type DestinationRunResponse struct

+ Acks []DestinationRunResponseAck

+ func (r DestinationRunResponse) Clone() DestinationRunResponse

+ type DestinationRunResponseAck struct

+ Error string

+ Position opencdc.Position

+ func (r DestinationRunResponseAck) Clone() DestinationRunResponseAck

+ type DestinationRunStream interface

+ Client func() DestinationRunStreamClient

+ Server func() DestinationRunStreamServer

+ type DestinationRunStreamClient interface

+ Recv func() (DestinationRunResponse, error)

+ Send func(DestinationRunRequest) error

+ type DestinationRunStreamServer interface

+ Recv func() (DestinationRunRequest, error)

+ Send func(DestinationRunResponse) error

+ type DestinationStopRequest struct

+ LastPosition opencdc.Position

+ func (r DestinationStopRequest) Clone() DestinationStopRequest

+ type DestinationStopResponse struct

+ func (r DestinationStopResponse) Clone() DestinationStopResponse

+ type DestinationTeardownRequest struct

+ func (r DestinationTeardownRequest) Clone() DestinationTeardownRequest

+ type DestinationTeardownResponse struct

+ func (r DestinationTeardownResponse) Clone() DestinationTeardownResponse

+ type PluginConfig struct

+ ConnectorID string

+ LogLevel string

+ Token string

+ type SourceConfigureRequest struct

+ Config config.Config

+ func (r SourceConfigureRequest) Clone() SourceConfigureRequest

+ type SourceConfigureResponse struct

+ func (r SourceConfigureResponse) Clone() SourceConfigureResponse

+ type SourceLifecycleOnCreatedRequest struct

+ Config config.Config

+ func (r SourceLifecycleOnCreatedRequest) Clone() SourceLifecycleOnCreatedRequest

+ type SourceLifecycleOnCreatedResponse struct

+ func (r SourceLifecycleOnCreatedResponse) Clone() SourceLifecycleOnCreatedResponse

+ type SourceLifecycleOnDeletedRequest struct

+ Config config.Config

+ func (r SourceLifecycleOnDeletedRequest) Clone() SourceLifecycleOnDeletedRequest

+ type SourceLifecycleOnDeletedResponse struct

+ func (r SourceLifecycleOnDeletedResponse) Clone() SourceLifecycleOnDeletedResponse

+ type SourceLifecycleOnUpdatedRequest struct

+ ConfigAfter config.Config

+ ConfigBefore config.Config

+ func (r SourceLifecycleOnUpdatedRequest) Clone() SourceLifecycleOnUpdatedRequest

+ type SourceLifecycleOnUpdatedResponse struct

+ func (r SourceLifecycleOnUpdatedResponse) Clone() SourceLifecycleOnUpdatedResponse

+ type SourceOpenRequest struct

+ Position opencdc.Position

+ func (r SourceOpenRequest) Clone() SourceOpenRequest

+ type SourceOpenResponse struct

+ func (r SourceOpenResponse) Clone() SourceOpenResponse

+ type SourcePlugin interface

+ Configure func(context.Context, SourceConfigureRequest) (SourceConfigureResponse, error)

+ LifecycleOnCreated func(context.Context, SourceLifecycleOnCreatedRequest) (SourceLifecycleOnCreatedResponse, error)

+ LifecycleOnDeleted func(context.Context, SourceLifecycleOnDeletedRequest) (SourceLifecycleOnDeletedResponse, error)

+ LifecycleOnUpdated func(context.Context, SourceLifecycleOnUpdatedRequest) (SourceLifecycleOnUpdatedResponse, error)

+ Open func(context.Context, SourceOpenRequest) (SourceOpenResponse, error)

+ Run func(context.Context, SourceRunStream) error

+ Stop func(context.Context, SourceStopRequest) (SourceStopResponse, error)

+ Teardown func(context.Context, SourceTeardownRequest) (SourceTeardownResponse, error)

+ type SourceRunRequest struct

+ AckPositions []opencdc.Position

+ func (r SourceRunRequest) Clone() SourceRunRequest

+ type SourceRunResponse struct

+ Records []opencdc.Record

+ func (r SourceRunResponse) Clone() SourceRunResponse

+ type SourceRunStream interface

+ Client func() SourceRunStreamClient

+ Server func() SourceRunStreamServer

+ type SourceRunStreamClient interface

+ Recv func() (SourceRunResponse, error)

+ Send func(SourceRunRequest) error

+ type SourceRunStreamServer interface

+ Recv func() (SourceRunRequest, error)

+ Send func(SourceRunResponse) error

+ type SourceStopRequest struct

+ func (r SourceStopRequest) Clone() SourceStopRequest

+ type SourceStopResponse struct

+ LastPosition opencdc.Position

+ func (r SourceStopResponse) Clone() SourceStopResponse

+ type SourceTeardownRequest struct

+ func (r SourceTeardownRequest) Clone() SourceTeardownRequest

+ type SourceTeardownResponse struct

+ func (r SourceTeardownResponse) Clone() SourceTeardownResponse

+ type Specification struct

+ Author string

+ Description string

+ DestinationParams config.Parameters

+ Name string

+ SourceParams config.Parameters

+ Summary string

+ Version string

+ type SpecifierPlugin interface

+ Specify func(context.Context, SpecifierSpecifyRequest) (SpecifierSpecifyResponse, error)

+ type SpecifierSpecifyRequest struct

+ type SpecifierSpecifyResponse struct

+ Specification Specification