adapters

Documentation

Index

• type AdapterDispatcher
  • func NewAdapterDispatcher(adapterInstances *[]domain.Adapter, logger *zap.Logger) (*AdapterDispatcher, error)
  • func (ad AdapterDispatcher) Close(rules []domain.Rule) (map[string]string, error)
  • func (ad AdapterDispatcher) Open(rules []domain.Rule) (map[string]string, error)
• type AdapterFactory
  • func NewAdapterFactory(config *viper.Viper) (*AdapterFactory, error)
  • func (c AdapterFactory) GetAdapters() (adapterCollection *[]domain.Adapter)

Types

type AdapterDispatcher

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

AdapterDispatcher will coordinate calling all configured adapters in a WaitGroup

func NewAdapterDispatcher

func NewAdapterDispatcher(adapterInstances *[]domain.Adapter, logger *zap.Logger) (*AdapterDispatcher, error)

NewAdapterDispatcher is a constructor method for AdapterDispatcher

func (AdapterDispatcher) Close

func (ad AdapterDispatcher) Close(rules []domain.Rule) (map[string]string, error)

Close will call CreateRules on all configured adapters in the AdapterDispatcher

func (AdapterDispatcher) Open

func (ad AdapterDispatcher) Open(rules []domain.Rule) (map[string]string, error)

Open will call CreateRules on all configured adapters in the AdapterDispatcher

type AdapterFactory

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

AdapterFactory will act as the owner of all adapter instances

func NewAdapterFactory

func NewAdapterFactory(config *viper.Viper) (*AdapterFactory, error)

NewAdapterFactory is a constructor method for AdapterFactory

func (AdapterFactory) GetAdapters

func (c AdapterFactory) GetAdapters() (adapterCollection *[]domain.Adapter)

GetAdapters exposes the internal collection of build adapter instances