server

Documentation

Overview

Deprecated: v1 is deprecated. Use v2 instead.

Index

• func NewDestinationPluginServer(impl pconnector.DestinationPlugin) connectorv1.DestinationPluginServer
• func NewSourcePluginServer(impl pconnector.SourcePlugin) connectorv1.SourcePluginServer
• func NewSpecifierPluginServer(impl pconnector.SpecifierPlugin) connectorv1.SpecifierPluginServer
• type DestinationRunStream
  • func (s *DestinationRunStream) Client() pconnector.DestinationRunStreamClient
  • func (s *DestinationRunStream) Recv() (pconnector.DestinationRunRequest, error)
  • func (s *DestinationRunStream) Send(in pconnector.DestinationRunResponse) error
  • func (s *DestinationRunStream) Server() pconnector.DestinationRunStreamServer
• type SourceRunStream
  • func (s *SourceRunStream) Client() pconnector.SourceRunStreamClient
  • func (s *SourceRunStream) Recv() (pconnector.SourceRunRequest, error)
  • func (s *SourceRunStream) Send(in pconnector.SourceRunResponse) error
  • func (s *SourceRunStream) Server() pconnector.SourceRunStreamServer

Functions

func NewDestinationPluginServer

func NewDestinationPluginServer(impl pconnector.DestinationPlugin) connectorv1.DestinationPluginServer

func NewSourcePluginServer

func NewSourcePluginServer(impl pconnector.SourcePlugin) connectorv1.SourcePluginServer

func NewSpecifierPluginServer

func NewSpecifierPluginServer(impl pconnector.SpecifierPlugin) connectorv1.SpecifierPluginServer

Types

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 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