Documentation
¶
Index ¶
- Variables
- func AddBinary(ctx context.Context, db gorp.SqlExecutor, storage objectstore.Driver, ...) error
- func Delete(ctx context.Context, db gorp.SqlExecutor, storageDriver objectstore.Driver, ...) error
- func DeleteBinary(ctx context.Context, db gorp.SqlExecutor, storageDriver objectstore.Driver, ...) error
- func Insert(db gorp.SqlExecutor, p *sdk.GRPCPlugin) error
- func LoadAll(ctx context.Context, db gorp.SqlExecutor) ([]sdk.GRPCPlugin, error)
- func LoadAllByIntegrationModelID(ctx context.Context, db gorp.SqlExecutor, integrationModelID int64) ([]sdk.GRPCPlugin, error)
- func LoadAllByType(ctx context.Context, db gorp.SqlExecutor, pluginType string) ([]sdk.GRPCPlugin, error)
- func LoadByIntegrationModelIDAndType(ctx context.Context, db gorp.SqlExecutor, integrationModelID int64, ...) (*sdk.GRPCPlugin, error)
- func LoadByName(ctx context.Context, db gorp.SqlExecutor, name string) (*sdk.GRPCPlugin, error)
- func Update(db gorp.SqlExecutor, p *sdk.GRPCPlugin) error
- func UpdateBinary(ctx context.Context, db gorp.SqlExecutor, storageDriver objectstore.Driver, ...) error
- type LoadOptionFunc
Constants ¶
This section is empty.
Variables ¶
View Source
var LoadOptions = struct { WithIntegrationModelName LoadOptionFunc }{ WithIntegrationModelName: loadIntegrationModelName, }
LoadOptions provides all options on plugin loads functions.
Functions ¶
func AddBinary ¶
func AddBinary(ctx context.Context, db gorp.SqlExecutor, storage objectstore.Driver, p *sdk.GRPCPlugin, b *sdk.GRPCPluginBinary, r io.ReadCloser) error
AddBinary add binary to the plugin, uploading it to objectsore and updates databases
func Delete ¶
func Delete(ctx context.Context, db gorp.SqlExecutor, storageDriver objectstore.Driver, p *sdk.GRPCPlugin) error
Delete deletes a plugin
func DeleteBinary ¶
func DeleteBinary(ctx context.Context, db gorp.SqlExecutor, storageDriver objectstore.Driver, p *sdk.GRPCPlugin, os, arch string) error
DeleteBinary remove a binary for the plugin from objectsore and updates databases.
func LoadAll ¶
func LoadAll(ctx context.Context, db gorp.SqlExecutor) ([]sdk.GRPCPlugin, error)
LoadAll GRPC plugins.
func LoadAllByIntegrationModelID ¶
func LoadAllByIntegrationModelID(ctx context.Context, db gorp.SqlExecutor, integrationModelID int64) ([]sdk.GRPCPlugin, error)
LoadAllByIntegrationModelID load all GRPC plugins for given integration model id.
func LoadAllByType ¶ added in v0.53.0
func LoadAllByType(ctx context.Context, db gorp.SqlExecutor, pluginType string) ([]sdk.GRPCPlugin, error)
func LoadByIntegrationModelIDAndType ¶
func LoadByIntegrationModelIDAndType(ctx context.Context, db gorp.SqlExecutor, integrationModelID int64, typePlugin string) (*sdk.GRPCPlugin, error)
LoadByIntegrationModelIDAndType retrieves in database a single plugin associated to a integration model id with a specified type.
func LoadByName ¶
func LoadByName(ctx context.Context, db gorp.SqlExecutor, name string) (*sdk.GRPCPlugin, error)
LoadByName retrieves in database the plugin with given name.
func UpdateBinary ¶
func UpdateBinary(ctx context.Context, db gorp.SqlExecutor, storageDriver objectstore.Driver, p *sdk.GRPCPlugin, b *sdk.GRPCPluginBinary, r io.ReadCloser) error
UpdateBinary updates binary for the plugin, uploading it to objectsore and updates databases
Types ¶
type LoadOptionFunc ¶
type LoadOptionFunc func(context.Context, gorp.SqlExecutor, ...*sdk.GRPCPlugin) error
LoadOptionFunc for plugin.
Click to show internal directories.
Click to hide internal directories.