alertwebhook

Documentation

Index

• Constants
• type BufferPool
  • func NewBufferPool(s int) *BufferPool
  • func (bp *BufferPool) Get() *bytes.Buffer
  • func (bp *BufferPool) Put(b *bytes.Buffer)
• type Config
• type Listener
  • func (l *Listener) Config() interface{}
  • func (l *Listener) Init(context api.Context) error
  • func (l *Listener) Name() string
  • func (l *Listener) Start() error
  • func (l *Listener) Stop()
  • func (l *Listener) Subscribe(event eventbus.Event)
• 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 = "alertWebhook"
)

Types

type BufferPool

type BufferPool struct {
	sync.Pool
}

func NewBufferPool

func NewBufferPool(s int) *BufferPool

func (*BufferPool) Get

func (bp *BufferPool) Get() *bytes.Buffer

func (*BufferPool) Put

func (bp *BufferPool) Put(b *bytes.Buffer)

type Config

type Config struct {
	Addr                 string `yaml:"addr,omitempty"`
	logalert.AlertConfig `yaml:",inline"`
}

type Listener

type Listener struct {
	SendNoDataAlertAtOnce bool
	SendLoggieError       bool
	SendLoggieErrorAtOnce bool
	// contains filtered or unexported fields
}

func (*Listener) Config

func (l *Listener) Config() interface{}

func (*Listener) Init

func (l *Listener) Init(context api.Context) error

func (*Listener) Name

func (l *Listener) Name() string

func (*Listener) Start

func (l *Listener) Start() error

func (*Listener) Stop

func (l *Listener) Stop()

func (*Listener) Subscribe

func (l *Listener) Subscribe(event eventbus.Event)

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