kfserver1

package

v0.0.0-...-e5ebed8 Latest Latest Go to latest Published: May 12, 2024 License: Apache-2.0, BSD-3-Clause Imports: 10 Imported by: 1

Details

This section is empty.

This section is empty.

func New(name string, serve kfprotov1.ProviderServer, opts ...ServeOpt) kfplugin1.ProviderServer

New converts a kfprotov1.ProviderServer into a server capable of handling kform protocol requests and issuing responses using the gRPC types.

func Serve(name string, serverFactory func() kfprotov1.ProviderServer, opts ...ServeOpt) error

type GRPCProviderPlugin struct {
	GRPCProvider func() kfprotov1.ProviderServer
	Opts         []ServeOpt
	Name         string
}

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

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

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

type ServeOpt interface {
	ApplyServeOpt(*ServeConfig) error
}

func WithGoPluginLogger(logger *slog.Logger) ServeOpt

WithGoPluginLogger returns a ServeOpt that will set the logger that go-plugin should use to log messages.