Versions in this module Expand all Collapse all v0 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()
Go to main page