iloader

Documentation

Index

• type Integration
  • func NewIntegration(opts IntegrationOpts) (*Integration, error)
  • func (s *Integration) Close() error
  • func (s *Integration) CloseAndDetectPanic() (panicOut string, rerr error)
  • func (s *Integration) LogFile() string
  • func (s *Integration) RPCClient() rpcdef.Integration
• type IntegrationOpts
• type Loader
  • func New(opts Opts) *Loader
  • func (s *Loader) Load(exports []expin.Export) (res map[expin.Export]*Integration, _ error)
• type Opts

Types

type Integration

type Integration struct {
	Export expin.Export
	// contains filtered or unexported fields
}

func NewIntegration

func NewIntegration(opts IntegrationOpts) (*Integration, error)

func (*Integration) Close

func (s *Integration) Close() error

func (*Integration) CloseAndDetectPanic

func (s *Integration) CloseAndDetectPanic() (panicOut string, rerr error)

func (*Integration) LogFile

func (s *Integration) LogFile() string

func (*Integration) RPCClient

func (s *Integration) RPCClient() rpcdef.Integration

type IntegrationOpts

type IntegrationOpts struct {
	Logger                     hclog.Logger
	Agent                      rpcdef.Agent
	Export                     expin.Export
	Locs                       fsconf.Locs
	IntegrationsDir            string
	DevUseCompiledIntegrations bool
}

type Loader

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

func New

func New(opts Opts) *Loader

func (*Loader) Load

func (s *Loader) Load(exports []expin.Export) (res map[expin.Export]*Integration, _ error)

type Opts

type Opts struct {
	Logger         hclog.Logger
	Locs           fsconf.Locs
	AgentDelegates func(ind expin.Export) rpcdef.Agent

	// IntegrationsDir is a custom location of the integrations binaries
	IntegrationsDir string
	// DevUseCompiledIntegrations set to true to use compiled integrations in dev build. They are used by default in prod builds.
	DevUseCompiledIntegrations bool
}