output

Documentation

Overview

* Copyright (c) 2022 Manabu Sonoda * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

Index

• Constants
• type DnstapFstrmSocketOutput
  • 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
  • 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
• type SocketOutput

Constants

const MaxRetryDuration = time.Minute * 1

Types

type DnstapFstrmSocketOutput

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

func NewDnstapFstrmSocketOutput

func NewDnstapFstrmSocketOutput(handler SocketOutput, flushTimeout time.Duration, encOpt *framestream.EncoderOptions) *DnstapFstrmSocketOutput

func (*DnstapFstrmSocketOutput) Close

func (o *DnstapFstrmSocketOutput) Close()

func (*DnstapFstrmSocketOutput) Open

func (o *DnstapFstrmSocketOutput) Open() error

func (*DnstapFstrmSocketOutput) SetOutputContext

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

func (*DnstapFstrmSocketOutput) Write

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

type DnstapOutput

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

func NewDnstapOutput

func NewDnstapOutput(handler OutputHandler, maxRetry uint) *DnstapOutput

func (*DnstapOutput) Run

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

func (*DnstapOutput) Start

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

type OutputHandler

type OutputHandler interface {
	SetOutputContext(oc *types.OutputContext)
	Open() error
	Write(*types.DnstapMessage) error
	Close()
}

type SocketOutput

type SocketOutput interface {
	SetOutputContext(*types.OutputContext)
	NewConnect() (io.Writer, error)
	Close()
}