schema

Documentation

Index

• Constants
• type AddMetaConfig
• type Config
• type Interceptor
  • func (icp *Interceptor) BelongTo() (componentTypes []string)
  • func (icp *Interceptor) Category() api.Category
  • func (icp *Interceptor) Config() interface{}
  • func (icp *Interceptor) IgnoreRetry() bool
  • func (icp *Interceptor) Init(context api.Context) error
  • func (icp *Interceptor) Intercept(invoker source.Invoker, invocation source.Invocation) api.Result
  • func (icp *Interceptor) Order() int
  • func (icp *Interceptor) Start() error
  • func (icp *Interceptor) Stop()
  • func (icp *Interceptor) String() string
  • func (icp *Interceptor) Type() api.Type
• type Remap
• type TimestampRemap

Constants

const (
	Type = "schema"
)

Types

type AddMetaConfig

type AddMetaConfig struct {
	Timestamp    TimestampRemap `yaml:"timestamp,omitempty"`
	PipelineName Remap          `yaml:"pipelineName,omitempty"`
	SourceName   Remap          `yaml:"sourceName,omitempty"`
}

type Config

type Config struct {
	interceptor.ExtensionConfig `yaml:",inline"`

	// AddMeta add system metadata to the event
	AddMeta *AddMetaConfig `yaml:"addMeta,omitempty"`

	Remap map[string]Remap `yaml:"remap,omitempty"`
}

type Interceptor

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

func (*Interceptor) BelongTo

func (icp *Interceptor) BelongTo() (componentTypes []string)

func (*Interceptor) Category

func (icp *Interceptor) Category() api.Category

func (*Interceptor) Config

func (icp *Interceptor) Config() interface{}

func (*Interceptor) IgnoreRetry

func (icp *Interceptor) IgnoreRetry() bool

func (*Interceptor) Init

func (icp *Interceptor) Init(context api.Context) error

func (*Interceptor) Intercept

func (icp *Interceptor) Intercept(invoker source.Invoker, invocation source.Invocation) api.Result

func (*Interceptor) Order

func (icp *Interceptor) Order() int

func (*Interceptor) Start

func (icp *Interceptor) Start() error

func (*Interceptor) Stop

func (icp *Interceptor) Stop()

func (*Interceptor) String

func (icp *Interceptor) String() string

func (*Interceptor) Type

func (icp *Interceptor) Type() api.Type

type Remap

type Remap struct {
	Key string `yaml:"key,omitempty"`
}

type TimestampRemap

type TimestampRemap struct {
	Key      string `yaml:"key,omitempty"`
	Location string `yaml:"location,omitempty"`
	Layout   string `yaml:"layout,omitempty"`
}