shared

package
v0.9.4 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Handshake = plugin.HandshakeConfig{

	ProtocolVersion:  1,
	MagicCookieKey:   "TAILPIPE_PLUGIN",
	MagicCookieValue: "tailpipe plugin",
}

Handshake is a common handshake that is shared by plugin and host.

Functions

This section is empty.

Types

type TailpipeGRPCPlugin 

type TailpipeGRPCPlugin struct {
	// GRPCPlugin must still implement the Plugin interface
	plugin.Plugin
	// Concrete implementation, written in Go. This is only used for plugins
	// that are written in Go.
	Impl TailpipePluginServer
}

TailpipeGRPCPlugin is the implementation of plugin.GRPCPlugin so we can serve/consume this.

func (*TailpipeGRPCPlugin) GRPCClient 

func (p *TailpipeGRPCPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (*TailpipeGRPCPlugin) GRPCServer 

func (p *TailpipeGRPCPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

type TailpipePluginClient 

type TailpipePluginClient interface {
	AddObserver() (proto.TailpipePlugin_AddObserverClient, error)
	Collect(context.Context, *proto.CollectRequest) (*proto.CollectResponse, error)
	Describe(context.Context, *proto.DescribeRequest) (*proto.DescribeResponse, error)
	UpdateCollectionState(context.Context, *proto.UpdateCollectionStateRequest) (*proto.Empty, error)
	InitSource(context.Context, *proto.InitSourceRequest) (*proto.InitSourceResponse, error)
	SaveCollectionState(context.Context, *proto.Empty) (*proto.Empty, error)
	CloseSource(context.Context, *proto.Empty) (*proto.Empty, error)
	SourceCollect(context.Context, *proto.SourceCollectRequest) (*proto.Empty, error)
	SourcePause(context.Context, *proto.Empty) (*proto.Empty, error)
	SourceResume(context.Context, *proto.Empty) (*proto.Empty, error)
	SourceCollectionComplete(context.Context, *proto.Empty) (*proto.Empty, error)
	GetSupportedOperations(context.Context, *proto.Empty) (*proto.GetSupportedOperationsResponse, error)
}

TailpipePluginClient is the client interface that we're exposing as a plugin.

type TailpipePluginClientWrapper 

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

TailpipePluginClientWrapper is an implementation of TailpipePluginClient that talks over GRPC.

func (TailpipePluginClientWrapper) AddObserver 

func (c TailpipePluginClientWrapper) AddObserver() (proto.TailpipePlugin_AddObserverClient, error)

func (TailpipePluginClientWrapper) CloseSource 

func (c TailpipePluginClientWrapper) CloseSource() (*proto.Empty, error)

func (TailpipePluginClientWrapper) Collect 

func (c TailpipePluginClientWrapper) Collect(req *proto.CollectRequest) (*proto.CollectResponse, error)

func (TailpipePluginClientWrapper) Describe 

func (c TailpipePluginClientWrapper) Describe(req *proto.DescribeRequest) (*proto.DescribeResponse, error)

func (TailpipePluginClientWrapper) GetSupportedOperations added in v0.9.0 

func (c TailpipePluginClientWrapper) GetSupportedOperations() (*proto.GetSupportedOperationsResponse, error)

func (TailpipePluginClientWrapper) InitSource 

func (c TailpipePluginClientWrapper) InitSource(req *proto.InitSourceRequest) (*proto.InitSourceResponse, error)

func (TailpipePluginClientWrapper) SaveCollectionState 

func (c TailpipePluginClientWrapper) SaveCollectionState() (*proto.Empty, error)

func (TailpipePluginClientWrapper) SourceCollect 

func (c TailpipePluginClientWrapper) SourceCollect(req *proto.SourceCollectRequest) (*proto.Empty, error)

func (TailpipePluginClientWrapper) SourceCollectionComplete added in v0.7.0 

func (c TailpipePluginClientWrapper) SourceCollectionComplete() (*proto.Empty, error)

func (TailpipePluginClientWrapper) SourcePause added in v0.5.0 

func (c TailpipePluginClientWrapper) SourcePause() (*proto.Empty, error)

func (TailpipePluginClientWrapper) SourceResume added in v0.5.0 

func (c TailpipePluginClientWrapper) SourceResume() (*proto.Empty, error)

func (TailpipePluginClientWrapper) UpdateCollectionState 

func (c TailpipePluginClientWrapper) UpdateCollectionState(req *proto.UpdateCollectionStateRequest) (*proto.Empty, error)

type TailpipePluginServer 

type TailpipePluginServer interface {
	AddObserver(proto.TailpipePlugin_AddObserverServer) error
	Collect(context.Context, *proto.CollectRequest) (*proto.CollectResponse, error)
	Describe(context.Context, *proto.DescribeRequest) (*proto.DescribeResponse, error)
	UpdateCollectionState(context.Context, *proto.UpdateCollectionStateRequest) (*proto.Empty, error)
	InitSource(context.Context, *proto.InitSourceRequest) (*proto.InitSourceResponse, error)
	SaveCollectionState(context.Context, *proto.Empty) (*proto.Empty, error)
	CloseSource(context.Context, *proto.Empty) (*proto.Empty, error)
	SourceCollect(context.Context, *proto.SourceCollectRequest) (*proto.Empty, error)
	SourcePause(context.Context, *proto.Empty) (*proto.Empty, error)
	SourceResume(context.Context, *proto.Empty) (*proto.Empty, error)
	SourceCollectionComplete(context.Context, *proto.Empty) (*proto.Empty, error)
	GetSupportedOperations(context.Context, *proto.Empty) (*proto.GetSupportedOperationsResponse, error)
}

TailpipePluginServer is the service interface that we're exposing as a plugin.

type TailpipePluginServerWrapper 

type TailpipePluginServerWrapper struct {
	proto.UnimplementedTailpipePluginServer
	// This is the real implementation
	Impl TailpipePluginServer
}

TailpipePluginServerWrapper is the gRPC server that TailpipePluginClient talks to.

func (TailpipePluginServerWrapper) AddObserver 

func (s TailpipePluginServerWrapper) AddObserver(_ *proto.Empty, server proto.TailpipePlugin_AddObserverServer) error

func (TailpipePluginServerWrapper) CloseSource 

func (s TailpipePluginServerWrapper) CloseSource(_ context.Context, req *proto.Empty) (*proto.Empty, error)

func (TailpipePluginServerWrapper) Collect 

func (s TailpipePluginServerWrapper) Collect(_ context.Context, req *proto.CollectRequest) (*proto.CollectResponse, error)

func (TailpipePluginServerWrapper) Describe 

func (s TailpipePluginServerWrapper) Describe(ctx context.Context, req *proto.DescribeRequest) (*proto.DescribeResponse, error)

func (TailpipePluginServerWrapper) GetSupportedOperations added in v0.9.0 

func (s TailpipePluginServerWrapper) GetSupportedOperations(_ context.Context, req *proto.Empty) (*proto.GetSupportedOperationsResponse, error)

func (TailpipePluginServerWrapper) InitSource 

func (s TailpipePluginServerWrapper) InitSource(_ context.Context, req *proto.InitSourceRequest) (*proto.InitSourceResponse, error)

func (TailpipePluginServerWrapper) SaveCollectionState 

func (s TailpipePluginServerWrapper) SaveCollectionState(_ context.Context, req *proto.Empty) (*proto.Empty, error)

func (TailpipePluginServerWrapper) SourceCollect 

func (s TailpipePluginServerWrapper) SourceCollect(_ context.Context, req *proto.SourceCollectRequest) (*proto.Empty, error)

func (TailpipePluginServerWrapper) SourceCollectionComplete added in v0.7.0 

func (s TailpipePluginServerWrapper) SourceCollectionComplete(_ context.Context, req *proto.Empty) (*proto.Empty, error)

func (TailpipePluginServerWrapper) SourcePause added in v0.5.0 

func (s TailpipePluginServerWrapper) SourcePause(_ context.Context, req *proto.Empty) (*proto.Empty, error)

func (TailpipePluginServerWrapper) SourceResume added in v0.5.0 

func (s TailpipePluginServerWrapper) SourceResume(_ context.Context, req *proto.Empty) (*proto.Empty, error)

func (TailpipePluginServerWrapper) UpdateCollectionState 

func (s TailpipePluginServerWrapper) UpdateCollectionState(_ context.Context, req *proto.UpdateCollectionStateRequest) (*proto.Empty, 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.