kafka

Documentation

Overview

Licensed to Elasticsearch B.V. under one or more agreements. Elasticsearch B.V. licenses this file to you under the Apache 2.0 License. See the LICENSE file in the project root for more information.

Index

• func New(opts *output.Options) (output.Output, error)
• type Output
  • func (o *Output) Close() error
  • func (o *Output) DialContext(_ context.Context) error
  • func (o *Output) Write(b []byte) (int, error)

Functions

func New

func New(opts *output.Options) (output.Output, error)

Types

type Output

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

func (*Output) Close

func (o *Output) Close() error

func (*Output) DialContext

func (o *Output) DialContext(_ context.Context) error

func (*Output) Write

func (o *Output) Write(b []byte) (int, error)