plugin

Documentation

Index

• Variables
• type Factory
  • func (Factory) New(m *plugins.Manager, config interface{}) plugins.Plugin
  • func (Factory) Validate(m *plugins.Manager, config []byte) (interface{}, error)
• type PostgresPlugin
  • func (p *PostgresPlugin) Reconfigure(ctx context.Context, config interface{})
  • func (p *PostgresPlugin) Start(ctx context.Context) error
  • func (p *PostgresPlugin) Stop(ctx context.Context)

Variables

var PgxPoolConnect = pgxpool.New

var PluginName = cfg.PluginName

Types

type Factory

type Factory struct{}

func (Factory) New

func (Factory) New(m *plugins.Manager, config interface{}) plugins.Plugin

func (Factory) Validate

func (Factory) Validate(m *plugins.Manager, config []byte) (interface{}, error)

type PostgresPlugin

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

func (*PostgresPlugin) Reconfigure

func (p *PostgresPlugin) Reconfigure(ctx context.Context, config interface{})

func (*PostgresPlugin) Start

func (p *PostgresPlugin) Start(ctx context.Context) error

func (*PostgresPlugin) Stop

func (p *PostgresPlugin) Stop(ctx context.Context)