source

Documentation

Index

• Variables
• type AbstractInvoker
  • func NewFakeInvoker() *AbstractInvoker
  • func (ai *AbstractInvoker) Invoke(invocation Invocation) api.Result
• type Config
  • func (c *Config) Validate() error
• type Info
• type Interceptor
• type Invocation
• type Invoker
• type PublishInvoker
  • func (i *PublishInvoker) Invoke(invocation Invocation) api.Result
• type SortableInterceptor
  • func (si SortableInterceptor) Len() int
  • func (si SortableInterceptor) Less(i, j int) bool
  • func (si SortableInterceptor) Sort()
  • func (si SortableInterceptor) Swap(i, j int)

Variables

var (
	ErrSourceNameRequired = errors.New("pipelines[n].source.name is required")
	ErrSourceTypeRequired = errors.New("pipelines[n].source.type is required")
)

Types

type AbstractInvoker

type AbstractInvoker struct {
	DoInvoke func(invocation Invocation) api.Result
}

func NewFakeInvoker

func NewFakeInvoker() *AbstractInvoker

NewFakeInvoker usually used by unit test or benchmark

func (*AbstractInvoker) Invoke

func (ai *AbstractInvoker) Invoke(invocation Invocation) api.Result

type Config

type Config struct {
	cfg.ComponentBaseConfig `yaml:",inline"`
	FieldsUnderRoot         bool                   `yaml:"fieldsUnderRoot,omitempty" default:"false"`
	FieldsUnderKey          string                 `yaml:"fieldsUnderKey,omitempty" default:"fields"`
	Fields                  map[string]interface{} `yaml:"fields,omitempty"`
	FieldsFromEnv           map[string]string      `yaml:"fieldsFromEnv,omitempty"`
	Codec                   *codec.Config          `yaml:"codec,omitempty"`
}

func (*Config) Validate

func (c *Config) Validate() error

type Info

type Info struct {
	Source       api.Source
	Queue        api.Queue
	Interceptors []Interceptor
}

type Interceptor

type Interceptor interface {
	api.Interceptor
	Intercept(invoker Invoker, invocation Invocation) api.Result
}

type Invocation

type Invocation struct {
	Event api.Event
	Queue api.Queue
}

type Invoker

type Invoker interface {
	Invoke(invocation Invocation) api.Result
}

type PublishInvoker

type PublishInvoker struct {
}

publish event to queue

func (*PublishInvoker) Invoke

func (i *PublishInvoker) Invoke(invocation Invocation) api.Result

type SortableInterceptor

type SortableInterceptor []Interceptor

func (SortableInterceptor) Len

func (si SortableInterceptor) Len() int

func (SortableInterceptor) Less

func (si SortableInterceptor) Less(i, j int) bool

func (SortableInterceptor) Sort

func (si SortableInterceptor) Sort()

func (SortableInterceptor) Swap

func (si SortableInterceptor) Swap(i, j int)