output

Documentation

Index

• type ElasticsearchRetrier
  • func NewElasticsearchRetrier(retry int) *ElasticsearchRetrier
  • func (r *ElasticsearchRetrier) Retry(ctx context.Context, retry int, req *http.Request, resp *http.Response, ...) (time.Duration, bool, error)
• type Output
  • func NewOutput(parameter Parameter) (*Output, error)
  • func (c *Output) AddBuffer(data interface{})
  • func (c *Output) BufferLimit() int
  • func (c *Output) BufferSize() int
  • func (c *Output) Close()
  • func (c *Output) GenerateTimeIndex() string
  • func (c *Output) IsClose() bool
  • func (c *Output) Send() error
• type Parameter

Types

type ElasticsearchRetrier

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

func NewElasticsearchRetrier

func NewElasticsearchRetrier(retry int) *ElasticsearchRetrier

func (*ElasticsearchRetrier) Retry

func (r *ElasticsearchRetrier) Retry(ctx context.Context, retry int, req *http.Request, resp *http.Response, err error) (time.Duration, bool, error)

type Output

type Output struct {
	*elastic.Client
	Bulk      *elastic.BulkService
	Parameter Parameter
	// contains filtered or unexported fields
}

func NewOutput

func NewOutput(parameter Parameter) (*Output, error)

func (*Output) AddBuffer

func (c *Output) AddBuffer(data interface{})

func (*Output) BufferLimit

func (c *Output) BufferLimit() int

func (*Output) BufferSize

func (c *Output) BufferSize() int

func (*Output) Close

func (c *Output) Close()

func (*Output) GenerateTimeIndex

func (c *Output) GenerateTimeIndex() string

func (*Output) IsClose

func (c *Output) IsClose() bool

func (*Output) Send

func (c *Output) Send() error

type Parameter

type Parameter struct {
	Addr        []string
	BulkLimit   int
	Retry       int
	IndexPrefix string
}