Documentation
¶
Index ¶
- Constants
- Variables
- func EntrypointExporter(ctor integration.ExporterFn, args []string)
- func EntrypointImporter(ctor integration.ImporterFn, args []string)
- func EntrypointInventory(constructor InventoryFn, args []string)
- func EntrypointSecretProvider(constructor SecretProviderFn, args []string)
- func EntrypointStorage(ctor integration.StoreFn, args []string)
- func RunExporter(constructor integration.ExporterFn) error
- func RunExporterOn(constructor integration.ExporterFn, listener net.Listener) error
- func RunImporter(constructor integration.ImporterFn) error
- func RunImporterOn(constructor integration.ImporterFn, listener net.Listener) error
- func RunInventory(constructor InventoryFn) error
- func RunInventoryOn(constructor InventoryFn, listener net.Listener) error
- func RunSecretProvider(constructor SecretProviderFn) error
- func RunSecretProviderOn(constructor SecretProviderFn, listener net.Listener) error
- func RunStorage(constructor integration.StoreFn) error
- func RunStorageOn(constructor integration.StoreFn, listener net.Listener) error
- type InventoryFn
- type SecretProviderFn
Constants ¶
View Source
const ListenEnv = "PLAKAR_PLUGIN_LISTEN"
When running over a container plakar sets this to the path of the socket we should be listening on. Empty when running on a default runner.
Variables ¶
View Source
var ( ErrNotInitialized = status.Error(codes.FailedPrecondition, "not initialized") ErrAlreadyInitialized = status.Error(codes.FailedPrecondition, "already initialized") )
View Source
var ErrDuplicatePayload = errors.New("duplicate payload id")
ErrDuplicatePayload means the client sent the same payload twice on the same stream, which it must not do.
View Source
var (
ErrExporterClosed = errors.New("the exporter is closed")
)
Functions ¶
func EntrypointExporter ¶
func EntrypointExporter(ctor integration.ExporterFn, args []string)
func EntrypointImporter ¶
func EntrypointImporter(ctor integration.ImporterFn, args []string)
func EntrypointInventory ¶
func EntrypointInventory(constructor InventoryFn, args []string)
func EntrypointSecretProvider ¶
func EntrypointSecretProvider(constructor SecretProviderFn, args []string)
func EntrypointStorage ¶
func EntrypointStorage(ctor integration.StoreFn, args []string)
func RunExporter ¶
func RunExporter(constructor integration.ExporterFn) error
RunExporter launches the gRPC server for an exporter plugin.
The given constructor will be used to initialize the exporter instance.
func RunExporterOn ¶
func RunExporterOn(constructor integration.ExporterFn, listener net.Listener) error
func RunImporter ¶
func RunImporter(constructor integration.ImporterFn) error
RunImporter starts the gRPC server for the importer plugin.
func RunImporterOn ¶
func RunImporterOn(constructor integration.ImporterFn, listener net.Listener) error
func RunInventory ¶
func RunInventory(constructor InventoryFn) error
func RunInventoryOn ¶
func RunInventoryOn(constructor InventoryFn, listener net.Listener) error
func RunSecretProvider ¶
func RunSecretProvider(constructor SecretProviderFn) error
func RunSecretProviderOn ¶
func RunSecretProviderOn(constructor SecretProviderFn, listener net.Listener) error
func RunStorage ¶
func RunStorage(constructor integration.StoreFn) error
RunStorage starts the gRPC server for the storage plugin.
func RunStorageOn ¶
func RunStorageOn(constructor integration.StoreFn, listener net.Listener) error
Types ¶
type InventoryFn ¶
type SecretProviderFn ¶
type SecretProviderFn func(context.Context, map[string]string) (integration.SecretProvider, error)
Source Files
Click to show internal directories.
Click to hide internal directories.