pluginutil

Jan 29, 2023

Changes in this version

type RunnerUtil

+ VaultVersion func(ctx context.Context) (string, error)

Nov 8, 2022

Changes in this version

+ var ErrNoMultiplexingIDFound = errors.New("no multiplexing ID found")

Oct 11, 2022

Changes in this version

+ const PluginAutoMTLSEnv

+ const PluginMultiplexingOptOut

+ func GetMultiplexIDFromContext(ctx context.Context) (string, error)

type Looker

+ LookupPluginVersion func(ctx context.Context, pluginName string, pluginType consts.PluginType, ...) (*PluginRunner, error)

type PluginClient

+ Reload func() error

type PluginClientConfig

+ Version string

+ Wrapper RunnerUtil

type PluginRunner

+ Version string

+ type VersionedPlugin struct

+ Builtin bool

+ DeprecationStatus string

+ Name string

+ SHA256 string

+ SemanticVersion *version.Version

+ Type string

+ Version string

Jul 18, 2022

Changes in this version

+ const MultiplexingCtxKey

+ var File_sdk_helper_pluginutil_multiplexing_proto protoreflect.FileDescriptor

+ var PluginCACertPEMEnv = "VAULT_TESTING_PLUGIN_CA_PEM"

+ var PluginMetadataModeEnv = "VAULT_PLUGIN_METADATA_MODE"

+ var PluginMlockEnabled = "VAULT_PLUGIN_MLOCK_ENABLED"

+ var PluginMultiplexing_ServiceDesc = grpc.ServiceDesc

+ var PluginUnwrapTokenEnv = "VAULT_UNWRAP_TOKEN"

+ var PluginVaultVersionEnv = "VAULT_VERSION"

+ func CtxCancelIfCanceled(f context.CancelFunc, ctxCanceler context.Context) chan struct

+ func GRPCSupport() bool

+ func InMetadataMode() bool

+ func MultiplexingSupported(ctx context.Context, cc grpc.ClientConnInterface) (bool, error)

+ func OptionallyEnableMlock() error

+ func RegisterPluginMultiplexingServer(s grpc.ServiceRegistrar, srv PluginMultiplexingServer)

+ type LookRunnerUtil interface

+ type Looker interface

+ LookupPlugin func(context.Context, string, consts.PluginType) (*PluginRunner, error)

+ type MultiplexingSupportRequest struct

+ func (*MultiplexingSupportRequest) Descriptor() ([]byte, []int)

+ func (*MultiplexingSupportRequest) ProtoMessage()

+ func (x *MultiplexingSupportRequest) ProtoReflect() protoreflect.Message

+ func (x *MultiplexingSupportRequest) Reset()

+ func (x *MultiplexingSupportRequest) String() string

+ type MultiplexingSupportResponse struct

+ Supported bool

+ func (*MultiplexingSupportResponse) Descriptor() ([]byte, []int)

+ func (*MultiplexingSupportResponse) ProtoMessage()

+ func (x *MultiplexingSupportResponse) GetSupported() bool

+ func (x *MultiplexingSupportResponse) ProtoReflect() protoreflect.Message

+ func (x *MultiplexingSupportResponse) Reset()

+ func (x *MultiplexingSupportResponse) String() string

+ type PluginClient interface

+ Conn func() grpc.ClientConnInterface

+ type PluginClientConfig struct

+ AutoMTLS bool

+ HandshakeConfig plugin.HandshakeConfig

+ IsMetadataMode bool

+ Logger log.Logger

+ MLock bool

+ Name string

+ PluginSets map[int]plugin.PluginSet

+ PluginType consts.PluginType

+ type PluginMultiplexingClient interface

+ MultiplexingSupport func(ctx context.Context, in *MultiplexingSupportRequest, opts ...grpc.CallOption) (*MultiplexingSupportResponse, error)

+ func NewPluginMultiplexingClient(cc grpc.ClientConnInterface) PluginMultiplexingClient

+ type PluginMultiplexingServer interface

+ MultiplexingSupport func(context.Context, *MultiplexingSupportRequest) (*MultiplexingSupportResponse, error)

+ type PluginMultiplexingServerImpl struct

+ Supported bool

+ func (pm PluginMultiplexingServerImpl) MultiplexingSupport(ctx context.Context, req *MultiplexingSupportRequest) (*MultiplexingSupportResponse, error)

+ type PluginRunner struct

+ Args []string

+ Builtin bool

+ BuiltinFactory func() (interface{}, error)

+ Command string

+ Env []string

+ Name string

+ Sha256 []byte

+ Type consts.PluginType

+ func (r *PluginRunner) Run(ctx context.Context, wrapper RunnerUtil, pluginSets map[int]plugin.PluginSet, ...) (*plugin.Client, error)

+ func (r *PluginRunner) RunConfig(ctx context.Context, opts ...RunOpt) (*plugin.Client, error)

+ func (r *PluginRunner) RunMetadataMode(ctx context.Context, wrapper RunnerUtil, pluginSets map[int]plugin.PluginSet, ...) (*plugin.Client, error)

+ type RunOpt func(*runConfig)

+ func AutoMTLS(autoMTLS bool) RunOpt

+ func Env(env ...string) RunOpt

+ func HandshakeConfig(hs plugin.HandshakeConfig) RunOpt

+ func Logger(logger log.Logger) RunOpt

+ func MLock(mlock bool) RunOpt

+ func MetadataMode(isMetadataMode bool) RunOpt

+ func PluginSets(pluginSets map[int]plugin.PluginSet) RunOpt

+ func Runner(wrapper RunnerUtil) RunOpt

+ type RunnerUtil interface

+ MlockEnabled func() bool

+ NewPluginClient func(ctx context.Context, config PluginClientConfig) (PluginClient, error)

+ ResponseWrapData func(ctx context.Context, data map[string]interface{}, ttl time.Duration, jwt bool) (*wrapping.ResponseWrapInfo, error)

+ type UnimplementedPluginMultiplexingServer struct

+ func (UnimplementedPluginMultiplexingServer) MultiplexingSupport(context.Context, *MultiplexingSupportRequest) (*MultiplexingSupportResponse, error)

+ type UnsafePluginMultiplexingServer interface