custom

Documentation

Index

• Constants
• type Config
• type FilterStrmAccessLog
  • func NewFilterStrmAccessLog(lgr log.Logger) *FilterStrmAccessLog
  • func (f *FilterStrmAccessLog) Apply(input []abstract.ChangeItem) abstract.TransformerResult
  • func (f *FilterStrmAccessLog) Description() string
  • func (f *FilterStrmAccessLog) ResultSchema(original *abstract.TableSchema) (*abstract.TableSchema, error)
  • func (f *FilterStrmAccessLog) Suitable(_ abstract.TableID, _ *abstract.TableSchema) bool
  • func (f *FilterStrmAccessLog) Type() abstract.TransformerType

Constants

const FilterStrmAccessLogTransformerType = abstract.TransformerType("filter_strm_access_log")

Types

type Config

type Config struct {
}

type FilterStrmAccessLog

type FilterStrmAccessLog struct {
	Logger log.Logger
}

func NewFilterStrmAccessLog

func NewFilterStrmAccessLog(lgr log.Logger) *FilterStrmAccessLog

func (*FilterStrmAccessLog) Apply

func (f *FilterStrmAccessLog) Apply(input []abstract.ChangeItem) abstract.TransformerResult

func (*FilterStrmAccessLog) Description

func (f *FilterStrmAccessLog) Description() string

func (*FilterStrmAccessLog) ResultSchema

func (f *FilterStrmAccessLog) ResultSchema(original *abstract.TableSchema) (*abstract.TableSchema, error)

func (*FilterStrmAccessLog) Suitable

func (f *FilterStrmAccessLog) Suitable(_ abstract.TableID, _ *abstract.TableSchema) bool

func (*FilterStrmAccessLog) Type

func (f *FilterStrmAccessLog) Type() abstract.TransformerType