plugins

Documentation

Overview

Package plugins ...

Index

• type Handler
  • func (pl Handler) LoadAMQPPlugin(wg *sync.WaitGroup, scConfig *common.SCConfiguration, ...) (*v1amqp.AMQP, error)
  • func (pl Handler) LoadHTTPPlugin(wg *sync.WaitGroup, scConfig *common.SCConfiguration, ...) (*v1http.HTTP, error)
  • func (pl Handler) LoadMockPlugin(wg *sync.WaitGroup, scConfig *common.SCConfiguration, ...) error
  • func (pl Handler) LoadPTPPlugin(wg *sync.WaitGroup, scConfig *common.SCConfiguration, ...) error

Types

type Handler

type Handler struct {
	Path string
}

Handler handler for loading plugins

func (Handler) LoadAMQPPlugin

func (pl Handler) LoadAMQPPlugin(wg *sync.WaitGroup, scConfig *common.SCConfiguration, amqInitTimeout time.Duration) (*v1amqp.AMQP, error)

LoadAMQPPlugin loads amqp plugin

func (Handler) LoadHTTPPlugin

func (pl Handler) LoadHTTPPlugin(wg *sync.WaitGroup, scConfig *common.SCConfiguration,
	onStatusReceiveOverrideFn func(e cloudevents.Event, dataChan *channel.DataChan) error, fn func(e interface{}) error) (*v1http.HTTP, error)

LoadHTTPPlugin loads http test plugin

func (Handler) LoadMockPlugin

func (pl Handler) LoadMockPlugin(wg *sync.WaitGroup, scConfig *common.SCConfiguration, fn func(e interface{}) error) error

LoadMockPlugin loads mock test plugin

func (Handler) LoadPTPPlugin

func (pl Handler) LoadPTPPlugin(wg *sync.WaitGroup, scConfig *common.SCConfiguration, fn func(e interface{}) error) error

LoadPTPPlugin loads ptp plugin