input

Documentation

Index

• Constants
• Variables
• func RegisterFormat(f Format, newFunc NewFormatFunc)
• type Format
• type FstrmUnmarshaler
• type InputServer
  • func NewDnstapInputServer(options *framestream.DecoderOptions, ic *types.InputContext) *InputServer
  • func NewDtapFrameInputServer(options *framestream.DecoderOptions, ic *types.InputContext) *InputServer
  • func NewInputServer(f Format, options *framestream.DecoderOptions, ic *types.InputContext) *InputServer
  • func (i *InputServer) Read(r io.Reader, buf types.Writer) error
  • func (i *InputServer) Serve(ln net.Listener, buf types.Writer) error
• type NewFormatFunc

Constants

const DefaultFormat = "DNSTAP"

Variables

var (
	TotalDecordError = promauto.NewCounter(prometheus.CounterOpts{
		Name: "dtap_input_error_frame_total",
		Help: "The total number of input error frames",
	})
)

Functions

func RegisterFormat

func RegisterFormat(f Format, newFunc NewFormatFunc)

Types

type Format

type Format string

const FormatDNSTAP Format = "DNSTAP"

const FormatDtapFrame Format = "DtapFrame"

type FstrmUnmarshaler

type FstrmUnmarshaler func([]byte) (*types.DnstapMessage, error)

type InputServer

type InputServer struct {
	DecoderOptions *framestream.DecoderOptions
	// contains filtered or unexported fields
}

func NewDnstapInputServer

func NewDnstapInputServer(options *framestream.DecoderOptions, ic *types.InputContext) *InputServer

func NewDtapFrameInputServer

func NewDtapFrameInputServer(options *framestream.DecoderOptions, ic *types.InputContext) *InputServer

func NewInputServer

func NewInputServer(f Format, options *framestream.DecoderOptions, ic *types.InputContext) *InputServer

func (*InputServer) Read

func (i *InputServer) Read(r io.Reader, buf types.Writer) error

func (*InputServer) Serve

func (i *InputServer) Serve(ln net.Listener, buf types.Writer) error

type NewFormatFunc

type NewFormatFunc func(options *framestream.DecoderOptions, ic *types.InputContext) *InputServer