module

May 10, 2022

Changes in this version

+ func GetProviderModule(ctx context.Context, pm *plugin.Manager, opts *GetModuleOptions) (*cqproto.GetModuleResponse, error)

type ExecuteRequest

+ Schemas []*core.ProviderSchema

+ type ExecutionOptions struct

+ Module string

+ Params RunParams

+ ProfileConfig hcl.Body

+ Providers registry.Providers

+ type GetModuleOptions struct

+ Provider registry.Provider

+ Request cqproto.GetModuleRequest

type Manager

+ Execute func(ctx context.Context, execReq *ExecuteRequest) (*ExecutionResult, error)

+ Register func(mod Module)

type ManagerImpl

+ func (m *ManagerImpl) Execute(ctx context.Context, req *ExecutionOptions) (*ExecutionResult, error)

+ func (m *ManagerImpl) Register(mod Module)

+ type ModExecutionRequest struct

+ Conn execution.QueryExecer

+ type RunParams interface

Feb 28, 2022

Changes in this version

+ func GetCombinedHCL(mi cqproto.ModuleInfo) (hcl.Body, hcl.Diagnostics)

type ExecuteRequest

+ Module string

+ ProfileConfig hcl.Body

+ type Info struct

+ ProtocolVersion uint32

+ ProviderData map[string]cqproto.ModuleInfo

+ UserConfig hcl.Body

+ type LowLevelQueryExecer interface

type Module

+ ProtocolVersions func() []uint32

Nov 12, 2021

Changes in this version

+ type ExitCoder interface

+ ExitCode func() int

type Manager

+ ExampleConfigs func() []string

type ManagerImpl

+ func (m *ManagerImpl) ExampleConfigs() []string

type Module

+ ExampleConfig func() string

+ type ModuleRunParams interface

Nov 4, 2021

Changes in this version

+ type ExecuteRequest struct

+ Conn *pgxpool.Conn

+ Params interface{}

+ Providers []*cqproto.GetProviderSchemaResponse

+ type ExecutionResult struct

+ Error error

+ ErrorMsg string

+ Result interface{}

+ type Manager interface

+ ExecuteModule func(ctx context.Context, modName, modConfigPath string, execReq *ExecuteRequest) (*ExecutionResult, error)

+ ReadConfig func(modName string) ([]byte, error)

+ RegisterModule func(mod Module)

+ type ManagerImpl struct

+ func NewManager(pool *pgxpool.Pool, logger hclog.Logger) *ManagerImpl

+ func (m *ManagerImpl) ExecuteModule(ctx context.Context, modName, modConfigPath string, execReq *ExecuteRequest) (*ExecutionResult, error)

+ func (m *ManagerImpl) ReadConfig(modName string) ([]byte, error)

+ func (m *ManagerImpl) RegisterModule(mod Module)

+ type Module interface

+ Configure func(context.Context, hcl.Body) error

+ Execute func(context.Context, *ExecuteRequest) *ExecutionResult

+ ID func() string