grpcplugin

Documentation

Index

• func NewBackendPlugin(pluginID, executablePath string, skipHostEnvVars bool, ...) backendplugin.PluginFactoryFunc
• func NewRendererPlugin(pluginID, executablePath string, startFn StartRendererFunc) backendplugin.PluginFactoryFunc
• func NewSecretsManagerPlugin(pluginID, executablePath string, startFn StartSecretsManagerFunc) backendplugin.PluginFactoryFunc
• func NewUnmanagedBackendPlugin(pluginID, executablePath string, skipHostEnvVars bool, ...) backendplugin.PluginFactoryFunc
• type ClientV2
  • func (c *ClientV2) CallResource(ctx context.Context, req *backend.CallResourceRequest, ...) error
  • func (c *ClientV2) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
  • func (c *ClientV2) CollectMetrics(ctx context.Context, req *backend.CollectMetricsRequest) (*backend.CollectMetricsResult, error)
  • func (c *ClientV2) ConvertObject(ctx context.Context, req *backend.ConversionRequest) (*backend.ConversionResponse, error)
  • func (c *ClientV2) MutateAdmission(ctx context.Context, req *backend.AdmissionRequest) (*backend.MutationResponse, error)
  • func (c *ClientV2) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
  • func (c *ClientV2) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
  • func (c *ClientV2) RunStream(ctx context.Context, req *backend.RunStreamRequest, ...) error
  • func (c *ClientV2) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)
  • func (c *ClientV2) ValidateAdmission(ctx context.Context, req *backend.AdmissionRequest) (*backend.ValidationResponse, error)
• type PluginDescriptor
• type ProtoClient
  • func NewProtoClient(opts ProtoClientOpts) (ProtoClient, error)
• type ProtoClientOpts
• type StartRendererFunc
• type StartSecretsManagerFunc

Functions

func NewBackendPlugin

func NewBackendPlugin(pluginID, executablePath string, skipHostEnvVars bool, executableArgs ...string) backendplugin.PluginFactoryFunc

NewBackendPlugin creates a new backend plugin factory used for registering a backend plugin.

func NewRendererPlugin

func NewRendererPlugin(pluginID, executablePath string, startFn StartRendererFunc) backendplugin.PluginFactoryFunc

NewRendererPlugin creates a new renderer plugin factory used for registering a backend renderer plugin.

func NewSecretsManagerPlugin

func NewSecretsManagerPlugin(pluginID, executablePath string, startFn StartSecretsManagerFunc) backendplugin.PluginFactoryFunc

NewSecretsManagerPlugin creates a new secrets manager plugin factory used for registering a backend secrets manager plugin.

func NewUnmanagedBackendPlugin

func NewUnmanagedBackendPlugin(pluginID, executablePath string, skipHostEnvVars bool, executableArgs ...string) backendplugin.PluginFactoryFunc

NewUnmanagedBackendPlugin creates a new backend plugin factory used for registering an unmanaged backend plugin.

Types

type ClientV2

type ClientV2 struct {
	grpcplugin.DiagnosticsClient
	grpcplugin.ResourceClient
	grpcplugin.DataClient
	grpcplugin.StreamClient
	grpcplugin.AdmissionClient
	pluginextensionv2.RendererPlugin
	secretsmanagerplugin.SecretsManagerPlugin
}

func (*ClientV2) CallResource

func (c *ClientV2) CallResource(ctx context.Context, req *backend.CallResourceRequest, sender backend.CallResourceResponseSender) error

func (*ClientV2) CheckHealth

func (c *ClientV2) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)

func (*ClientV2) CollectMetrics

func (c *ClientV2) CollectMetrics(ctx context.Context, req *backend.CollectMetricsRequest) (*backend.CollectMetricsResult, error)

func (*ClientV2) ConvertObject

func (c *ClientV2) ConvertObject(ctx context.Context, req *backend.ConversionRequest) (*backend.ConversionResponse, error)

func (*ClientV2) MutateAdmission

func (c *ClientV2) MutateAdmission(ctx context.Context, req *backend.AdmissionRequest) (*backend.MutationResponse, error)

func (*ClientV2) PublishStream

func (c *ClientV2) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)

func (*ClientV2) QueryData

func (c *ClientV2) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)

func (*ClientV2) RunStream

func (c *ClientV2) RunStream(ctx context.Context, req *backend.RunStreamRequest, sender *backend.StreamSender) error

func (*ClientV2) SubscribeStream

func (c *ClientV2) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)

func (*ClientV2) ValidateAdmission

func (c *ClientV2) ValidateAdmission(ctx context.Context, req *backend.AdmissionRequest) (*backend.ValidationResponse, error)

type PluginDescriptor

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

PluginDescriptor is a descriptor used for registering backend plugins.

type ProtoClient

type ProtoClient interface {
	pluginv2.DataClient
	pluginv2.ResourceClient
	pluginv2.DiagnosticsClient
	pluginv2.StreamClient

	PID(context.Context) (string, error)
	PluginID() string
	PluginVersion() string
	PluginJSON() plugins.JSONData
	Backend() backendplugin.Plugin
	Logger() log.Logger
	Start(context.Context) error
	Stop(context.Context) error
	Running(context.Context) bool
}

func NewProtoClient

func NewProtoClient(opts ProtoClientOpts) (ProtoClient, error)

type ProtoClientOpts

type ProtoClientOpts struct {
	PluginJSON     plugins.JSONData
	ExecutablePath string
	ExecutableArgs []string
	Env            []string
	Logger         log.Logger
}

type StartRendererFunc

type StartRendererFunc func(pluginID string, renderer pluginextensionv2.RendererPlugin, logger log.Logger) error

StartRendererFunc callback function called when a renderer plugin is started.

type StartSecretsManagerFunc

type StartSecretsManagerFunc func(pluginID string, secretsmanager secretsmanagerplugin.SecretsManagerPlugin, logger log.Logger) error

StartSecretsManagerFunc callback function called when a secrets manager plugin is started.