server

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Nov 8, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDestinationPluginServer 

func NewDestinationPluginServer(impl pconnector.DestinationPlugin) connectorv2.DestinationPluginServer

func NewSourcePluginServer 

func NewSourcePluginServer(impl pconnector.SourcePlugin) connectorv2.SourcePluginServer

func NewSpecifierPluginServer 

func NewSpecifierPluginServer(impl pconnector.SpecifierPlugin) connectorv2.SpecifierPluginServer

Types

type DestinationPluginServer 

type DestinationPluginServer struct {
	connectorv2.UnimplementedDestinationPluginServer
	// contains filtered or unexported fields
}

func (*DestinationPluginServer) Configure 

func (s *DestinationPluginServer) Configure(ctx context.Context, protoReq *connectorv2.Destination_Configure_Request) (*connectorv2.Destination_Configure_Response, error)

func (*DestinationPluginServer) LifecycleOnCreated 

func (s *DestinationPluginServer) LifecycleOnCreated(ctx context.Context, protoReq *connectorv2.Destination_Lifecycle_OnCreated_Request) (*connectorv2.Destination_Lifecycle_OnCreated_Response, error)

func (*DestinationPluginServer) LifecycleOnDeleted 

func (s *DestinationPluginServer) LifecycleOnDeleted(ctx context.Context, protoReq *connectorv2.Destination_Lifecycle_OnDeleted_Request) (*connectorv2.Destination_Lifecycle_OnDeleted_Response, error)

func (*DestinationPluginServer) LifecycleOnUpdated 

func (s *DestinationPluginServer) LifecycleOnUpdated(ctx context.Context, protoReq *connectorv2.Destination_Lifecycle_OnUpdated_Request) (*connectorv2.Destination_Lifecycle_OnUpdated_Response, error)

func (*DestinationPluginServer) Open 

func (s *DestinationPluginServer) Open(ctx context.Context, protoReq *connectorv2.Destination_Open_Request) (*connectorv2.Destination_Open_Response, error)

func (*DestinationPluginServer) Run 

func (s *DestinationPluginServer) Run(stream connectorv2.DestinationPlugin_RunServer) error

func (*DestinationPluginServer) Stop 

func (s *DestinationPluginServer) Stop(ctx context.Context, protoReq *connectorv2.Destination_Stop_Request) (*connectorv2.Destination_Stop_Response, error)

func (*DestinationPluginServer) Teardown 

func (s *DestinationPluginServer) Teardown(ctx context.Context, protoReq *connectorv2.Destination_Teardown_Request) (*connectorv2.Destination_Teardown_Response, error)

type DestinationRunStream 

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

DestinationRunStream is the server-side implementation of the pconnector.DestinationRunStream interface.

func (*DestinationRunStream) Client 

func (s *DestinationRunStream) Client() pconnector.DestinationRunStreamClient

func (*DestinationRunStream) Recv 

func (s *DestinationRunStream) Recv() (pconnector.DestinationRunRequest, error)

func (*DestinationRunStream) Send 

func (s *DestinationRunStream) Send(in pconnector.DestinationRunResponse) error

func (*DestinationRunStream) Server 

func (s *DestinationRunStream) Server() pconnector.DestinationRunStreamServer

type SourcePluginServer 

type SourcePluginServer struct {
	connectorv2.UnimplementedSourcePluginServer
	// contains filtered or unexported fields
}

func (*SourcePluginServer) Configure 

func (s *SourcePluginServer) Configure(ctx context.Context, protoReq *connectorv2.Source_Configure_Request) (*connectorv2.Source_Configure_Response, error)

func (*SourcePluginServer) LifecycleOnCreated 

func (s *SourcePluginServer) LifecycleOnCreated(ctx context.Context, protoReq *connectorv2.Source_Lifecycle_OnCreated_Request) (*connectorv2.Source_Lifecycle_OnCreated_Response, error)

func (*SourcePluginServer) LifecycleOnDeleted 

func (s *SourcePluginServer) LifecycleOnDeleted(ctx context.Context, protoReq *connectorv2.Source_Lifecycle_OnDeleted_Request) (*connectorv2.Source_Lifecycle_OnDeleted_Response, error)

func (*SourcePluginServer) LifecycleOnUpdated 

func (s *SourcePluginServer) LifecycleOnUpdated(ctx context.Context, protoReq *connectorv2.Source_Lifecycle_OnUpdated_Request) (*connectorv2.Source_Lifecycle_OnUpdated_Response, error)

func (*SourcePluginServer) Open 

func (s *SourcePluginServer) Open(ctx context.Context, protoReq *connectorv2.Source_Open_Request) (*connectorv2.Source_Open_Response, error)

func (*SourcePluginServer) Run 

func (s *SourcePluginServer) Run(stream connectorv2.SourcePlugin_RunServer) error

func (*SourcePluginServer) Stop 

func (s *SourcePluginServer) Stop(ctx context.Context, protoReq *connectorv2.Source_Stop_Request) (*connectorv2.Source_Stop_Response, error)

func (*SourcePluginServer) Teardown 

func (s *SourcePluginServer) Teardown(ctx context.Context, protoReq *connectorv2.Source_Teardown_Request) (*connectorv2.Source_Teardown_Response, error)

type SourceRunStream 

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

SourceRunStream is the server-side implementation of the pconnector.SourceRunStream interface.

func (*SourceRunStream) Client 

func (s *SourceRunStream) Client() pconnector.SourceRunStreamClient

func (*SourceRunStream) Recv 

func (s *SourceRunStream) Recv() (pconnector.SourceRunRequest, error)

func (*SourceRunStream) Send 

func (s *SourceRunStream) Send(in pconnector.SourceRunResponse) error

func (*SourceRunStream) Server 

func (s *SourceRunStream) Server() pconnector.SourceRunStreamServer

type SpecifierPluginServer 

type SpecifierPluginServer struct {
	connectorv2.UnimplementedSpecifierPluginServer
	// contains filtered or unexported fields
}

func (SpecifierPluginServer) Specify 

func (s SpecifierPluginServer) Specify(ctx context.Context, protoReq *connectorv2.Specifier_Specify_Request) (*connectorv2.Specifier_Specify_Response, error)

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.