dnstap

package module

Go to main page

Versions in this module

v0

v0.6.1

Sep 19, 2023

Changes in this version

type Dnstap

+ BrandId []byte

+ GroupId []byte

+ SegmentId []byte

+ SubscriptionId []byte

+ func (x *Dnstap) GetBrandId() []byte

+ func (x *Dnstap) GetGroupId() []byte

+ func (x *Dnstap) GetSegmentId() []byte

+ func (x *Dnstap) GetSubscriptionId() []byte

v0.6.0

Sep 15, 2023

Changes in this version

type Dnstap

+ Region []byte

+ func (x *Dnstap) GetRegion() []byte

v0.5.0

Sep 16, 2022

Changes in this version

type Dnstap

+ Address []byte

+ func (x *Dnstap) GetAddress() []byte

v0.4.9

Sep 16, 2022

Changes in this version

type Dnstap

+ Rcode *uint32

+ func (x *Dnstap) GetRcode() uint32

v0.4.8

Sep 16, 2022

v0.4.7

Apr 1, 2022

v0.4.6

Jan 20, 2022

Changes in this version

type Dnstap

+ ResAction []byte

+ func (x *Dnstap) GetResAction() []byte

v0.4.5

Jan 20, 2022

v0.4.4

Oct 19, 2021

v0.4.3

Oct 19, 2021

Changes in this version

+ var File_dnstap_pb_dnstap_proto protoreflect.FileDescriptor

type Dnstap

+ ClientId []byte

+ DeviceId []byte

+ func (x *Dnstap) GetClientId() []byte

+ func (x *Dnstap) GetDeviceId() []byte

v0.4.2

Oct 19, 2021

Changes in this version

+ var File_dnstap_proto protoreflect.FileDescriptor

+ type Decoder struct

+ func NewDecoder(r Reader, maxSize int) *Decoder

+ func (d *Decoder) Decode(m *Dnstap) error

type Dnstap

+ func (*Dnstap) Descriptor() ([]byte, []int)

+ func (x *Dnstap) ProtoReflect() protoreflect.Message

type Dnstap_Type

+ func (Dnstap_Type) Descriptor() protoreflect.EnumDescriptor

+ func (Dnstap_Type) EnumDescriptor() ([]byte, []int)

+ func (Dnstap_Type) Type() protoreflect.EnumType

+ func (x Dnstap_Type) Number() protoreflect.EnumNumber

+ type Encoder struct

+ func NewEncoder(w Writer) *Encoder

+ func (e *Encoder) Encode(m *Dnstap) error

type FrameStreamInput

+ func (input *FrameStreamInput) SetLogger(logger Logger)

type FrameStreamOutput

+ func (o *FrameStreamOutput) SetLogger(logger Logger)

type FrameStreamSockInput

+ func (input *FrameStreamSockInput) SetLogger(logger Logger)

type FrameStreamSockOutput

+ func (o *FrameStreamSockOutput) SetLogger(logger Logger)

+ type Logger interface

+ Printf func(format string, v ...interface{})

type Message

+ func (*Message) Descriptor() ([]byte, []int)

+ func (x *Message) ProtoReflect() protoreflect.Message

type Message_Type

+ const Message_UPDATE_QUERY

+ const Message_UPDATE_RESPONSE

+ func (Message_Type) Descriptor() protoreflect.EnumDescriptor

+ func (Message_Type) EnumDescriptor() ([]byte, []int)

+ func (Message_Type) Type() protoreflect.EnumType

+ func (x Message_Type) Number() protoreflect.EnumNumber

+ type Reader interface

+ ReadFrame func([]byte) (int, error)

+ func NewReader(r io.Reader, opt *ReaderOptions) (Reader, error)

+ type ReaderOptions struct

+ Bidirectional bool

+ Timeout time.Duration

type SocketFamily

+ func (SocketFamily) Descriptor() protoreflect.EnumDescriptor

+ func (SocketFamily) EnumDescriptor() ([]byte, []int)

+ func (SocketFamily) Type() protoreflect.EnumType

+ func (x SocketFamily) Number() protoreflect.EnumNumber

type SocketProtocol

+ const SocketProtocol_DOH

+ const SocketProtocol_DOT

+ func (SocketProtocol) Descriptor() protoreflect.EnumDescriptor

+ func (SocketProtocol) EnumDescriptor() ([]byte, []int)

+ func (SocketProtocol) Type() protoreflect.EnumType

+ func (x SocketProtocol) Number() protoreflect.EnumNumber

+ type SocketWriterOptions struct

+ Dialer *net.Dialer

+ FlushTimeout time.Duration

+ Logger Logger

+ RetryInterval time.Duration

+ Timeout time.Duration

type TextOutput

+ func (o *TextOutput) SetLogger(logger Logger)

+ type Writer interface

+ Close func() error

+ WriteFrame func([]byte) (int, error)

+ func NewSocketWriter(addr net.Addr, opt *SocketWriterOptions) Writer

+ func NewWriter(w io.Writer, opt *WriterOptions) (Writer, error)

+ type WriterOptions struct

+ Bidirectional bool

+ Timeout time.Duration

v0.4.1

Oct 6, 2021

v0.2.0

Jun 1, 2019

Changes in this version

+ var MaxPayloadSize uint32 = 96 * 1024

+ func JSONFormat(dt *Dnstap) (out []byte, ok bool)

type FrameStreamInput

+ func NewFrameStreamInputTimeout(r io.ReadWriter, bi bool, timeout time.Duration) (input *FrameStreamInput, err error)

type FrameStreamSockInput

+ func (input *FrameStreamSockInput) SetTimeout(timeout time.Duration)

+ type FrameStreamSockOutput struct

+ func NewFrameStreamSockOutput(address net.Addr) (*FrameStreamSockOutput, error)

+ func (o *FrameStreamSockOutput) Close()

+ func (o *FrameStreamSockOutput) GetOutputChannel() chan []byte

+ func (o *FrameStreamSockOutput) RunOutputLoop()

+ func (o *FrameStreamSockOutput) SetDialer(dialer *net.Dialer)

+ func (o *FrameStreamSockOutput) SetFlushTimeout(timeout time.Duration)

+ func (o *FrameStreamSockOutput) SetRetryInterval(retry time.Duration)

+ func (o *FrameStreamSockOutput) SetTimeout(timeout time.Duration)

v0.1.0

Nov 1, 2018

Changes in this version

+ var Dnstap_Type_name = map[int32]string

+ var Dnstap_Type_value = map[string]int32

+ var FSContentType = []byte("protobuf:dnstap.Dnstap")

+ var Message_Type_name = map[int32]string

+ var Message_Type_value = map[string]int32

+ var SocketFamily_name = map[int32]string

+ var SocketFamily_value = map[string]int32

+ var SocketProtocol_name = map[int32]string

+ var SocketProtocol_value = map[string]int32

+ func TextFormat(dt *Dnstap) (out []byte, ok bool)

+ func YamlFormat(dt *Dnstap) (out []byte, ok bool)

+ type Dnstap struct

+ Extra []byte

+ Identity []byte

+ Message *Message

+ Type *Dnstap_Type

+ Version []byte

+ XXX_unrecognized []byte

+ func (*Dnstap) ProtoMessage()

+ func (m *Dnstap) GetExtra() []byte

+ func (m *Dnstap) GetIdentity() []byte

+ func (m *Dnstap) GetMessage() *Message

+ func (m *Dnstap) GetType() Dnstap_Type

+ func (m *Dnstap) GetVersion() []byte

+ func (m *Dnstap) Reset()

+ func (m *Dnstap) String() string

+ type Dnstap_Type int32

+ const Dnstap_MESSAGE

+ func (x *Dnstap_Type) UnmarshalJSON(data []byte) error

+ func (x Dnstap_Type) Enum() *Dnstap_Type

+ func (x Dnstap_Type) String() string

+ type FrameStreamInput struct

+ func NewFrameStreamInput(r io.ReadWriter, bi bool) (input *FrameStreamInput, err error)

+ func NewFrameStreamInputFromFilename(fname string) (input *FrameStreamInput, err error)

+ func (input *FrameStreamInput) ReadInto(output chan []byte)

+ func (input *FrameStreamInput) Wait()

+ type FrameStreamOutput struct

+ func NewFrameStreamOutput(w io.Writer) (o *FrameStreamOutput, err error)

+ func NewFrameStreamOutputFromFilename(fname string) (o *FrameStreamOutput, err error)

+ func (o *FrameStreamOutput) Close()

+ func (o *FrameStreamOutput) GetOutputChannel() chan []byte

+ func (o *FrameStreamOutput) RunOutputLoop()

+ type FrameStreamSockInput struct

+ func NewFrameStreamSockInput(listener net.Listener) (input *FrameStreamSockInput)

+ func NewFrameStreamSockInputFromPath(socketPath string) (input *FrameStreamSockInput, err error)

+ func (input *FrameStreamSockInput) ReadInto(output chan []byte)

+ func (input *FrameStreamSockInput) Wait()

+ type Input interface

+ ReadInto func(chan []byte)

+ Wait func()

+ type Message struct

+ QueryAddress []byte

+ QueryMessage []byte

+ QueryPort *uint32

+ QueryTimeNsec *uint32

+ QueryTimeSec *uint64

+ QueryZone []byte

+ ResponseAddress []byte

+ ResponseMessage []byte

+ ResponsePort *uint32

+ ResponseTimeNsec *uint32

+ ResponseTimeSec *uint64

+ SocketFamily *SocketFamily

+ SocketProtocol *SocketProtocol

+ Type *Message_Type

+ XXX_unrecognized []byte

+ func (*Message) ProtoMessage()

+ func (m *Message) GetQueryAddress() []byte

+ func (m *Message) GetQueryMessage() []byte

+ func (m *Message) GetQueryPort() uint32

+ func (m *Message) GetQueryTimeNsec() uint32

+ func (m *Message) GetQueryTimeSec() uint64

+ func (m *Message) GetQueryZone() []byte

+ func (m *Message) GetResponseAddress() []byte

+ func (m *Message) GetResponseMessage() []byte

+ func (m *Message) GetResponsePort() uint32

+ func (m *Message) GetResponseTimeNsec() uint32

+ func (m *Message) GetResponseTimeSec() uint64

+ func (m *Message) GetSocketFamily() SocketFamily

+ func (m *Message) GetSocketProtocol() SocketProtocol

+ func (m *Message) GetType() Message_Type

+ func (m *Message) Reset()

+ func (m *Message) String() string

+ type Message_Type int32

+ const Message_AUTH_QUERY

+ const Message_AUTH_RESPONSE

+ const Message_CLIENT_QUERY

+ const Message_CLIENT_RESPONSE

+ const Message_FORWARDER_QUERY

+ const Message_FORWARDER_RESPONSE

+ const Message_RESOLVER_QUERY

+ const Message_RESOLVER_RESPONSE

+ const Message_STUB_QUERY

+ const Message_STUB_RESPONSE

+ const Message_TOOL_QUERY

+ const Message_TOOL_RESPONSE

+ func (x *Message_Type) UnmarshalJSON(data []byte) error

+ func (x Message_Type) Enum() *Message_Type

+ func (x Message_Type) String() string

+ type Output interface

+ Close func()

+ GetOutputChannel func() chan []byte

+ RunOutputLoop func()

+ type SocketFamily int32

+ const SocketFamily_INET

+ const SocketFamily_INET6

+ func (x *SocketFamily) UnmarshalJSON(data []byte) error

+ func (x SocketFamily) Enum() *SocketFamily

+ func (x SocketFamily) String() string

+ type SocketProtocol int32

+ const SocketProtocol_TCP

+ const SocketProtocol_UDP

+ func (x *SocketProtocol) UnmarshalJSON(data []byte) error

+ func (x SocketProtocol) Enum() *SocketProtocol

+ func (x SocketProtocol) String() string

+ type TextFormatFunc func(*Dnstap) ([]byte, bool)

+ type TextOutput struct

+ func NewTextOutput(writer io.Writer, format TextFormatFunc) (o *TextOutput)

+ func NewTextOutputFromFilename(fname string, format TextFormatFunc) (o *TextOutput, err error)

+ func (o *TextOutput) Close()

+ func (o *TextOutput) GetOutputChannel() chan []byte

+ func (o *TextOutput) RunOutputLoop()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL