output

Sep 19, 2023

Changes in this version

+ const MaxRetryDuration

+ type DnstapFstrmSocketOutput struct

+ func NewDnstapFstrmSocketOutput(handler SocketOutput, flushTimeout time.Duration, ...) *DnstapFstrmSocketOutput

+ func (o *DnstapFstrmSocketOutput) Close()

+ func (o *DnstapFstrmSocketOutput) Open() error

+ func (o *DnstapFstrmSocketOutput) SetOutputContext(oc *types.OutputContext)

+ func (o *DnstapFstrmSocketOutput) Write(dm *types.DnstapMessage) error

+ type DnstapOutput struct

+ func NewDnstapOutput(handler OutputHandler, maxRetry uint) *DnstapOutput

+ func (o *DnstapOutput) Run(ctx context.Context, r types.Reader) error

+ func (o *DnstapOutput) Start(ctx context.Context, oc *types.OutputContext) error

+ type OutputHandler interface

+ Close func()

+ Open func() error

+ SetOutputContext func(oc *types.OutputContext)

+ Write func(*types.DnstapMessage) error

+ type SocketOutput interface

+ Close func()

+ NewConnect func() (io.Writer, error)

+ SetOutputContext func(*types.OutputContext)