factory

Documentation

Index

• Constants
• Variables
• func GetVaultHost() string
• func GetVaultPort() string
• func Init(processFlowConfig trcvutils.ProcessFlowConfig, ...)
• func ProcessPluginEnvConfig(processFlowConfig trcvutils.ProcessFlowConfig, ...) error
• func PushEnv(envMap map[string]interface{})
• func PushPluginSha(driverConfig *config.DriverConfig, pluginConfig map[string]interface{}, ...)
• func StartPluginSettingEater()
• func TrcCreate(ctx context.Context, req *logical.Request, data *framework.FieldData) (*logical.Response, error)
• func TrcFactory(ctx context.Context, conf *logical.BackendConfig) (logical.Backend, error)
• func TrcInitialize(ctx context.Context, req *logical.InitializationRequest) error
• func TrcRead(ctx context.Context, req *logical.Request, data *framework.FieldData) (*logical.Response, error)
• func TrcUpdate(ctx context.Context, req *logical.Request, data *framework.FieldData) (*logical.Response, error)
• type EnvConfig

Constants

const CONFIG_PATH = "config"

Variables

var KvCreate framework.OperationFunc

var KvInitialize func(context.Context, *logical.InitializationRequest) error

var KvRead framework.OperationFunc

var KvUpdate framework.OperationFunc

Functions

func GetVaultHost

func GetVaultHost() string

func GetVaultPort

func GetVaultPort() string

func Init

func Init(processFlowConfig trcvutils.ProcessFlowConfig, processFlows trcvutils.ProcessFlowFunc, headless bool, l *log.Logger)

func ProcessPluginEnvConfig

func ProcessPluginEnvConfig(processFlowConfig trcvutils.ProcessFlowConfig,

	processFlowInit trcvutils.ProcessFlowFunc,
	pluginEnvConfig map[string]interface{},
	configCompleteChan chan bool) error

func PushEnv

func PushEnv(envMap map[string]interface{})

func PushPluginSha

func PushPluginSha(driverConfig *config.DriverConfig, pluginConfig map[string]interface{}, vaultPluginSignature map[string]interface{})

Only push to sha256 chan if one is present. Non blocking otherwise.

func StartPluginSettingEater

func StartPluginSettingEater()

This is to flush pluginSettingsChan on an interval to prevent deadlocks.

func TrcCreate

func TrcCreate(ctx context.Context, req *logical.Request, data *framework.FieldData) (*logical.Response, error)

func TrcFactory

func TrcFactory(ctx context.Context, conf *logical.BackendConfig) (logical.Backend, error)

TrcFactory configures and returns Mock backends

func TrcInitialize

func TrcInitialize(ctx context.Context, req *logical.InitializationRequest) error

func TrcRead

func TrcRead(ctx context.Context, req *logical.Request, data *framework.FieldData) (*logical.Response, error)

func TrcUpdate

func TrcUpdate(ctx context.Context, req *logical.Request, data *framework.FieldData) (*logical.Response, error)

Types

type EnvConfig

type EnvConfig struct {
	Env string `yaml:"-"`
	// Mysql access.
	MysqlDburl    string `yaml:"mysqldburl,omitempty"`
	MysqlDbuser   string `yaml:"mysqldbuser,omitempty"`
	MysqlDbpasswd string `yaml:"mysqldbpassword,omitempty"`
	// Local db access.
	Dbuser   string `yaml:"dbuser,omitempty"`
	Dbpasswd string `yaml:"dbpassword,omitempty"`
	Maxconn  string `yaml:"maxconn,omitempty"` // Maximum allowed db connections
}