dev

Documentation

Index

• Constants
• type Config
• type Sink
  • func NewSink(pipelineName string) *Sink
  • func (s *Sink) Category() api.Category
  • func (s *Sink) Config() interface{}
  • func (s *Sink) Consume(batch api.Batch) api.Result
  • func (s *Sink) Init(context api.Context) error
  • func (s *Sink) SetCodec(c codec.Codec)
  • func (s *Sink) Start() error
  • func (s *Sink) Stop()
  • func (s *Sink) String() string
  • func (s *Sink) Type() api.Type

Constants

const Type = "dev"

Types

type Config

type Config struct {
	// in general, we use codec.PrintEvents instead.
	PrintEvents bool `yaml:"printEvents,omitempty" default:"false"`
	// Within this period, only one log event is printed for troubleshooting.
	PrintEventsInterval time.Duration `yaml:"printEventsInterval,omitempty"`

	PrintMetrics    bool          `yaml:"printMetrics,omitempty"`
	MetricsInterval time.Duration `yaml:"printMetricsInterval,omitempty" default:"1s"`

	// resultStatus can be used to simulate failure, drop
	ResultStatus string `yaml:"resultStatus,omitempty" default:"success"`
}

type Sink

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

func NewSink

func NewSink(pipelineName string) *Sink

func (*Sink) Category

func (s *Sink) Category() api.Category

func (*Sink) Config

func (s *Sink) Config() interface{}

func (*Sink) Consume

func (s *Sink) Consume(batch api.Batch) api.Result

func (*Sink) Init

func (s *Sink) Init(context api.Context) error

func (*Sink) SetCodec

func (s *Sink) SetCodec(c codec.Codec)

func (*Sink) Start

func (s *Sink) Start() error

func (*Sink) Stop

func (s *Sink) Stop()

func (*Sink) String

func (s *Sink) String() string

func (*Sink) Type

func (s *Sink) Type() api.Type