tapir

package module
v0.0.0-...-c7b98f0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 14, 2024 License: BSD-2-Clause Imports: 33 Imported by: 0

README

tapir

Library of data structures and utilities used by various DNS TAPIR components

Documentation

Overview

* Copyright 2024 Johan Stenstam, johan.stenstam@internetstiftelsen.se

* Copyright (c) 2024 Johan Stenstam, johan.stenstam@internetstiftelsen.se

* Copyright 2024 Johan Stenstam, johan.stenstam@internetstiftelsen.se

* Copyright (c) 2024 Johan Stenstam, johan.stenstam@internetstiftelsen.se

* Copyright (c) 2024 Johan Stenstam, johan.stenstam@internetstiftelsen.se

* Copyright (c) 2024 Johan Stenstam, johan.stenstam@internetstiftelsen.se

* Copyright (c) 2024 Johan Stenstam, johan.stenstam@internetstiftelsen.se

Index

Constants

View Source 
const (
	DefaultPopCfgFile = "/etc/dnstapir/tapir-pop.yaml"
	PopSourcesCfgFile = "/etc/dnstapir/pop-sources.yaml"
	PopOutputsCfgFile = "/etc/dnstapir/pop-outputs.yaml"
	PopPolicyCfgFile  = "/etc/dnstapir/pop-policy.yaml"
)
View Source 
const (
	TapirPub uint8 = 1 << iota
	TapirSub
)
View Source 
const DefaultSloggerCfgFile = "/etc/dnstapir/slogger.yaml"
View Source 
const DefaultTapirCliCfgFile = "/etc/dnstapir/tapir-cli.yaml"
View Source 
const (
	TimeLayout = "2006-01-02 15:04:05"
)

Variables

View Source 
var ActionToCNAMETarget = map[Action]string{
	NXDOMAIN:  ".",
	NODATA:    "*.",
	DROP:      "rpz-drop.",
	WHITELIST: "rpz-passthru.",
	REDIRECT:  "what-to-do-about-this",
}
View Source 
var ActionToString = map[Action]string{
	NXDOMAIN:  "NXDOMAIN",
	NODATA:    "NODATA",
	DROP:      "DROP",
	WHITELIST: "WHITELIST",
	REDIRECT:  "WHAT-TO-DO-ABOUT-REDIRECTS",
}
View Source 
var DefinedTags = []string{
	"newname", "highvolume", "badip", "cdntracker", "likelymalware", "likelybotnetcc",

	"foo", "bar", "baz", "gazonk", "frotz",
}
View Source 
var StatusToString = map[ComponentStatus]string{
	StatusOK:     "ok",
	StatusWarn:   "warn",
	StatusFail:   "fail",
	StatusReport: "report",
}
View Source 
var StringToStatus = map[string]ComponentStatus{
	"ok":     StatusOK,
	"warn":   StatusWarn,
	"fail":   StatusFail,
	"report": StatusReport,
}
View Source 
var ZoneTypeToString = map[ZoneType]string{
	XfrZone:   "xfr",
	MapZone:   "map",
	SliceZone: "slice",
	RpzZone:   "rpz",
}

Functions

func APIping 

func APIping(appName string, boottime time.Time) func(w http.ResponseWriter, r *http.Request)

func Chomp 

func Chomp(s string) string

func CreateDawg 

func CreateDawg(sortedDomains []string, outfile string) error

func DropDNSSECZONEMDp 

func DropDNSSECZONEMDp(rrtype uint16) bool

func DropDNSSECp 

func DropDNSSECp(rrtype uint16) bool

func FetchMqttSigningKey 

func FetchMqttSigningKey(topic, filename string) (*ecdsa.PrivateKey, error)

func FetchMqttValidatorKey 

func FetchMqttValidatorKey(topic, filename string) (*ecdsa.PublicKey, error)

func FetchTapirClientCert 

func FetchTapirClientCert(lg *log.Logger, statusch chan<- ComponentStatusUpdate) (string, *x509.CertPool, *tls.Certificate, error)

func HasTag 

func HasTag(b, tag TagMask) bool

func InBailiwick 

func InBailiwick(zone string, ns *dns.NS) bool

func ListDawg 

func ListDawg(df dawg.Finder) (int, []string)

XXX: This is a slow and costly operation. Do not use unnecessarily.

func MqttTopic 

func MqttTopic(commonName string, viperkey string) (string, error)

MqttTopic returns the MQTT topic for a given common name and viper key. The raw topic is something like "status/up/{EdgeId}/tapir-pop" and is specified in the tapir-pop.yaml config file. The common name is the common name of the TAPIR Edge cert.

func NewClientConfig 

func NewClientConfig(caFile, keyFile, certFile string) (*tls.Config, error)

func NewServerConfig 

func NewServerConfig(caFile string, clientAuth tls.ClientAuthType) (*tls.Config, error)

Create a tls.Config for a server. clientAuth: tls.NoClientCert => Accept any client. clientAuth: tls.RequireAndVerifyClientCert => Only accept client with valid cert.

func NewSimpleClientConfig 

func NewSimpleClientConfig(caFile string) (*tls.Config, error)

NewSimpleClientConfig creates a TLS config with a common CA cert, specified in caFile, but without a client certificate.

func ParseCSV 

func ParseCSV(srcfile string, dstmap map[string]TapirName, dontsort bool) ([]string, error)

func ParseDNSTime 

func ParseDNSTime(t uint32) time.Time

func ParseText 

func ParseText(srcfile string, dstmap map[string]TapirName, dontsort bool) ([]string, error)

Two modes of operation: either return a (potentially large) []string with sorted output *or* update the dstmap of TapirNames directly and don't return the result

func PrintRR 

func PrintRR(rr dns.RR)

func PrintRRs 

func PrintRRs(rrs []dns.RR)

func PrintTapirMqttPkg 

func PrintTapirMqttPkg(pkg MqttPkgIn, lg *log.Logger)

XXX: Only used for debugging

func PrintTapirMsg 

func PrintTapirMsg(tm TapirMsg, lg *log.Logger)

func SetupLogging 

func SetupLogging(logfile string) error

func SetupTapirMqttSubPrinter 

func SetupTapirMqttSubPrinter(inbox chan MqttPkgIn)

XXX: Only used for debugging

func TtyIntQuestion 

func TtyIntQuestion(query string, oldval int, force bool) int

func TtyQuestion 

func TtyQuestion(query, oldval string, force bool) string

func TtyRadioButtonQ 

func TtyRadioButtonQ(query, defval string, choices []string) string

func TtyYesNo 

func TtyYesNo(query, defval string) string

Types

type Action 

type Action uint8
const (
	NXDOMAIN Action = 1 << iota
	NODATA
	DROP
	REDIRECT
	WHITELIST
	PASSTHRU
	UnknownAction
)

func StringToAction 

func StringToAction(s string) (Action, error)

type Api 

type Api struct {
	Name       string
	Client     *http.Client
	BaseUrl    string
	ApiKey     string
	Authmethod string
	Verbose    bool
	Debug      bool
}

type ApiClient 

type ApiClient struct {
	BaseUrl    string
	AuthMethod string
	ApiKey     string
	Timeout    int
	ClientName string // ClientName is used to figure out which client cert to use for TLS setup.
	UseTLS     bool
	Verbose    bool
	Debug      bool
	HttpClient *http.Client
}

func (*ApiClient) AddAuthHeader 

func (api *ApiClient) AddAuthHeader(req *http.Request)

this function will die when we kill the individual request functions.

func (*ApiClient) RequestNG 

func (api *ApiClient) RequestNG(method, endpoint string, data interface{}, dieOnError bool) (int, []byte, error)

func (*ApiClient) SendPing 

func (api *ApiClient) SendPing(pingcount int, dieOnError bool) (PingResponse, error)

func (*ApiClient) Setup 

func (api *ApiClient) Setup() error

func (*ApiClient) SetupTLS 

func (api *ApiClient) SetupTLS(tlsConfig *tls.Config) error

This is a version of the ApiClient constructor that should replace NewTlsApiClient()

func (*ApiClient) ShowApi 

func (api *ApiClient) ShowApi()

func (*ApiClient) UrlReport 

func (api *ApiClient) UrlReport(method, endpoint string, data []byte)

type BootstrapPost 

type BootstrapPost struct {
	Command  string
	ListName string
	Encoding string
}

type BootstrapResponse 

type BootstrapResponse struct {
	Time   time.Time
	Status string
	Msg    string
	// MsgCounters   map[string]uint32    // map[topic]counter
	// MsgTimeStamps map[string]time.Time // map[topic]timestamp
	TopicData map[string]TopicData
	Error     bool
	ErrorMsg  string
}

type CliFlags 

type CliFlags struct {
	ShowHdr   bool
	Verbose   bool
	Debug     bool
	UseTLS    bool
	Api       *ApiClient
	PingCount int
	Zone      string
	// TODO cleaner solution:
	// Moved "certname" from slogger.go here so it can know what cert to look
	// for. "certname" was previously declared globally in "root.go", but since
	// the move to the tapir lib, slogger.go no longer sees that variable.
	Certname string
}
var GlobalCF CliFlags

type CommandPost 

type CommandPost struct {
	Command   string
	Zone      string
	Name      string // Domain name to add/remove an RPZ action for
	ListType  string
	ListName  string // used in the export-greylist command
	Policy    string // RPZ policy
	Action    string // RPZ action (OBE)
	RpzSource string // corresponds with the sourceid in tem.yaml
}

type CommandResponse 

type CommandResponse struct {
	Time                time.Time
	Status              string
	Zone                string
	Serial              uint32
	Data                []byte
	Msg                 string
	TapirFunctionStatus TapirFunctionStatus
	Error               bool
	ErrorMsg            string
}

type ComponentStatus 

type ComponentStatus uint8

Status alternatives known to StatusUpdater() 

const (
	StatusFail ComponentStatus = iota
	StatusWarn
	StatusOK
	StatusReport // Not a component status, but a request for a status report
)

type ComponentStatusUpdate 

type ComponentStatusUpdate struct {
	Status    ComponentStatus
	Function  string // tapir-pop | tapir-edm | ...
	Component string // downstream | rpz | mqtt | config | ...
	Msg       string
	TimeStamp time.Time
	Response  chan StatusUpdaterResponse
}

ComponentStatusUpdate is used to send status updates for a single component of a "function" (tapir-pop, tapir-edm, etc)

type Config 

type Config struct {
	CAFile   string `validate:"existing-file-ro"`
	KeyFile  string `validate:"existing-file-ro"`
	CertFile string `validate:"existing-file-ro"`
}

type DebugPost 

type DebugPost struct {
	Command   string
	Zone      string
	Qname     string
	Qtype     uint16
	Component string
	Status    ComponentStatus
}

type DebugResponse 

type DebugResponse struct {
	Time   time.Time
	Status string
	Zone   string
	//	ZoneData   ZoneData
	OwnerIndex       map[string]int
	RRset            RRset
	Lists            map[string]map[string]*WBGlist
	Whitelists       map[string]*WBGlist
	Blacklists       map[string]*WBGlist
	Greylists        map[string]*WBGlist
	BlacklistedNames map[string]bool
	GreylistedNames  map[string]*TapirName
	RpzOutput        []RpzName
	MqttStats        MqttStats
	TopicData        map[string]TopicData
	ReaperStats      map[string]map[time.Time][]string
	Msg              string
	Error            bool
	ErrorMsg         string
}

type Domain 

type Domain struct {
	Name         string
	TimeAdded    time.Time
	TTL          int     // in seconds
	TagMask      TagMask // here is the bitfield
	ExtendedTags []string
}

type GlobalConfig 

type GlobalConfig struct {
	TapirConfigVersion string
	Rpz                struct {
		EnvelopeSize int // Number of dns.RRs per zone transfer envelope
	}
	Bootstrap struct {
		Servers  []string
		BaseUrl  string
		ApiToken string
	}
	ObservationTopics []GlobalConfigTopic
	StatusTopics      []GlobalConfigTopic
}

Things we need to have in the global config include: - dns-tapir bootstrap server details - number of RRs to send in a dns.Envelope{}

type GlobalConfigTopic 

type GlobalConfigTopic struct {
	Topic       string // Topic to subscribe (down) or publish (up) on
	PubKeyName  string // Set when sending a validation key, unset otherwise
	PrivKeyName string // Set when sending a signing key, unset otherwise
}

type MqttData 

type MqttData struct {
	Topic     string
	Payload   []byte
	Validated bool
}

OBE! MqttData is what is returned from the MQTT Engine for unparsed messages. The payload is left as []byte because it can be of arbitrary type, not just TapirMsg.

type MqttDetails 

type MqttDetails struct {
	ValidatorKeys map[string]*ecdsa.PublicKey // map[topic]*key
	Bootstrap     []string
	BootstrapUrl  string
	BootstrapKey  string
}

type MqttEngine 

type MqttEngine struct {
	Running           bool
	Creator           string
	ClientID          string
	Server            string
	QoS               int
	ConnectionManager *autopaho.ConnectionManager
	ClientCert        tls.Certificate
	CaCertPool        *x509.CertPool
	MsgChan           chan paho.PublishReceived
	CmdChan           chan MqttEngineCmd
	PublishChan       chan MqttPkgOut
	SubscribeChan     chan MqttPkgIn
	TopicData         map[string]TopicData // map[topic]TopicData
	PrefixTopics      map[string]bool      // eg. "pubkey/up/" is a prefix topic if we subscribe to pubkey/up/#
	CanPublish        bool                 // can publish to all topics
	CanSubscribe      bool                 // can subscribe to all topics
	Logger            *log.Logger
	Cancel            context.CancelFunc
}

func NewMqttEngine 

func NewMqttEngine(creator, clientid string, pubsub uint8, statusch chan ComponentStatusUpdate, lg *log.Logger) (*MqttEngine, error)

func (*MqttEngine) FetchTopicData 

func (me *MqttEngine) FetchTopicData(topic string) (TopicData, error)

func (*MqttEngine) PubToTopic 

func (me *MqttEngine) PubToTopic(topic string, signingkey *ecdsa.PrivateKey, mode string, sign bool) (map[string]TopicData, error)

func (*MqttEngine) RemoveTopic 

func (me *MqttEngine) RemoveTopic(topic string) (map[string]TopicData, error)

func (*MqttEngine) RestartEngine 

func (me *MqttEngine) RestartEngine() (chan MqttEngineCmd, error)

func (*MqttEngine) SetupInterruptHandler 

func (me *MqttEngine) SetupInterruptHandler()

Trivial interrupt handler to catch SIGTERM and stop the MQTT engine nicely

func (*MqttEngine) StartEngine 

func (me *MqttEngine) StartEngine() (chan MqttEngineCmd, chan MqttPkgOut, chan MqttPkgIn, error)

func (*MqttEngine) Stats 

func (me *MqttEngine) Stats() map[string]TopicData

func (*MqttEngine) StopEngine 

func (me *MqttEngine) StopEngine() (chan MqttEngineCmd, error)

func (*MqttEngine) SubToTopic 

func (me *MqttEngine) SubToTopic(topic string, validatorkey *ecdsa.PublicKey,
	subscriberCh chan MqttPkgIn, mode string, validate bool,
) (map[string]TopicData, error)

type MqttEngineCmd 

type MqttEngineCmd struct {
	Cmd  string
	Resp chan MqttEngineResponse
}

type MqttEngineResponse 

type MqttEngineResponse struct {
	Status   string
	Error    bool
	ErrorMsg string
}

type MqttPkgIn 

type MqttPkgIn struct {
	Type     string // text | data, only used on sender side
	Error    bool   // only used for sub.
	ErrorMsg string // only used for sub.
	Msg      string
	Topic    string // topic on which this message arrived
	Retain   bool
	//	Data      TapirMsg
	//	RawData   interface{} // outgoing data, an unparsed struct
	Payload   []byte // incoming data, as received from the network
	Validated bool
	TimeStamp time.Time // time mqtt packet was sent or received, mgmt by MQTT Engine
}

type MqttPkgOut 

type MqttPkgOut struct {
	Type      string // text | data, only used on sender side
	Error     bool   // only used for sub.
	ErrorMsg  string // only used for sub.
	Msg       string
	Topic     string // topic on which this message arrived
	Retain    bool
	Data      TapirMsg
	RawData   interface{} // outgoing data, an unparsed struct
	TimeStamp time.Time   // time mqtt packet was sent or received, mgmt by MQTT Engine
}

MqttPkg is what is sent to the MQTT Engine and returned when an incoming message is parsed.

type MqttStats 

type MqttStats struct {
	MsgCounters   map[string]uint32
	MsgTimeStamps map[string]time.Time
}

type OwnerData 

type OwnerData struct {
	Name    string
	RRtypes map[uint16]RRset
}

type Owners 

type Owners []OwnerData

type PingPost 

type PingPost struct {
	Msg   string
	Pings int
}

type PingResponse 

type PingResponse struct {
	Time       time.Time
	BootTime   time.Time
	Daemon     string
	ServerHost string
	Version    string
	Client     string
	Msg        string
	Pings      int
	Pongs      int
}

type PubKeyUpload 

type PubKeyUpload struct {
	JWSMessage    string
	Signature     string
	ClientCertPEM string
}

type RRArray 

type RRArray []dns.RR

RRArray represents an array of rrs It implements Swapper interface, and is sortable.

func (RRArray) Len 

func (array RRArray) Len() int

Len returns the length of an RRArray.

func (RRArray) Less 

func (array RRArray) Less(i, j int) bool

Less returns true if the element in the position i of RRArray is less than the element in position j of RRArray.

func (RRArray) String 

func (array RRArray) String() string

String returns a string representation of the RRArray, based on the name, class and Rrtype of the first element.

func (RRArray) Swap 

func (array RRArray) Swap(i, j int)

Swap swaps elements on positions i and j from RRArray

type RRset 

type RRset struct {
	RRs []dns.RR
}

type RpzName 

type RpzName struct {
	Name   string
	RR     *dns.RR
	Action Action
}

type ShowAPIresponse 

type ShowAPIresponse struct {
	Status int
	Msg    string
	Data   []string
}

type SimpleConfig 

type SimpleConfig struct {
	CAFile string `validate:"existing-file-ro"`
}

type SloggerCmdPost 

type SloggerCmdPost struct {
	Command string
}

type SloggerCmdResponse 

type SloggerCmdResponse struct {
	Time time.Time
	// TapirFunctionStatus TapirFunctionStatus
	PopStatus map[string]TapirFunctionStatus
	EdmStatus map[string]TapirFunctionStatus
	Msg       string
	Error     bool
	ErrorMsg  string
}

type StatusUpdaterResponse 

type StatusUpdaterResponse struct {
	FunctionStatus  TapirFunctionStatus
	KnownComponents []string
	Msg             string
	Error           bool
	ErrorMsg        string
}

type TagMask 

type TagMask uint32
const (
	NewName TagMask = 1 << iota
	HighVolume
	BadIP
	CdnTracker
	LikelyMalware
	LikelyBotnetCC
	Foo
	Bar
	Baz
	Gazonk
	Frotz
)

func ClearTag 

func ClearTag(b, tag TagMask) TagMask

func SetTag 

func SetTag(b, tag TagMask) TagMask

func StringsToTagMask 

func StringsToTagMask(ss []string) (TagMask, error)

func ToggleTag 

func ToggleTag(b, tag TagMask) TagMask

func (*TagMask) ClearTag 

func (tm *TagMask) ClearTag(tag TagMask)

func (*TagMask) HasTag 

func (tm *TagMask) HasTag(tag TagMask) bool

func (*TagMask) NumTags 

func (tm *TagMask) NumTags() int

func (*TagMask) SetTag 

func (tm *TagMask) SetTag(tag TagMask)

func (*TagMask) ToggleTag 

func (tm *TagMask) ToggleTag(tag TagMask)

type TapirComponentStatus 

type TapirComponentStatus struct {
	Component   string
	Status      ComponentStatus
	ErrorMsg    string
	WarningMsg  string
	Msg         string
	NumFails    int
	NumWarnings int
	LastFail    time.Time
	LastWarn    time.Time
	LastSuccess time.Time
}

TapirComponentStatus contains the status for a single component of a "function" (tapir-pop, tapir-edm, etc)

type TapirFunctionStatus 

type TapirFunctionStatus struct {
	Function        string // tapir-pop | tapir-edm | ...
	FunctionID      string
	ComponentStatus map[string]TapirComponentStatus // downstreamnotify | downstreamixfr | rpzupdate | mqttmsg | config | ...
	NumFailures     int
	LastFailure     time.Time
}

TapirFunctionStatus contains the status for all components of this "function" (tapir-pop, tapir-edm, etc)

type TapirMsg 

type TapirMsg struct {
	SrcName  string // must match a defined source
	Creator  string // "spark"	|| "tapir-cli"
	MsgType  string // "observation", "reset", "global-config"...
	ListType string // "{white|black|grey}list"
	Added    []Domain
	Removed  []Domain
	Msg      string
	//	GlobalConfig        GlobalConfig
	//	TapirFunctionStatus TapirFunctionStatus
	TimeStamp time.Time // time encoded in the payload by the sender, not touched by MQTT
	TimeStr   string    // time string encoded in the payload by the sender, not touched by MQTT
}

TapirMsg is what is recieved over the MQTT bus.

type TapirName 

type TapirName struct {
	//	SrcFormat string          // "tapir-feed-v1" | ...
	Name      string
	TimeAdded time.Time
	TTL       time.Duration
	// Tags    []string // XXX: extremely wasteful, a bitfield would be better,
	TagMask TagMask // bitfield
	NumTags uint8
	//      but don't know how many tags there can be
	Action Action // bitfield NXDOMAIN|NODATA|DROP|...
}

func (*TapirName) HasAction 

func (tn *TapirName) HasAction(action Action) bool

type TapirPubKey 

type TapirPubKey struct {
	Pubkey string
}

type TopicData 

type TopicData struct {
	Topic        string // topic must be in the TopicData, because sometimes we change it, and we need to keep the TopicData entry.
	SigningKey   *ecdsa.PrivateKey
	Sign         bool
	ValidatorKey *ecdsa.PublicKey
	Validate     bool   // should incoming messages be validated by the validator key?
	PubMode      string // "raw" indicates that the data should just be passed through untouched
	SubMode      string // "raw" indicates that the data should just be passed through untouched
	SubscriberCh chan MqttPkgIn
	PubMsgs      uint32
	SubMsgs      uint32
	LatestPub    time.Time
	LatestSub    time.Time
}

type WBGlist 

type WBGlist struct {
	Name        string
	Description string
	Type        string // whitelist | blacklist | greylist
	Immutable   bool   // true = won't be updated by globalconfig topic.
	SrcFormat   string // Format of external source: dawg | rpz | tapir-mqtt-v1 | ...
	Format      string // Format of internal storage: dawg | map | slice | trie | rbtree | ...
	Datasource  string // file | xfr | mqtt | https | api | ...
	Filename    string
	Upstream    string
	Dawgf       dawg.Finder
	MqttDetails *MqttDetails

	// greylist sources needs more complex stuff here:
	//	GreyNames   map[string]GreyName
	RpzZoneName string
	RpzUpstream string
	RpzSerial   int
	Names       map[string]TapirName // XXX: same data as in ZoneData.RpzData, should only keep one
	ReaperData  map[time.Time]map[string]bool
}

type ZoneData 

type ZoneData struct {
	ZoneName   string
	ZoneType   ZoneType // 1 = "xfr", 2 = "map", 3 = "slice". An xfr zone only supports xfr related ops
	Owners     Owners
	OwnerIndex map[string]int
	ApexLen    int // # RRs that are stored separately
	SOA        dns.SOA
	NSrrs      []dns.RR // apex NS RRs

	// Rest of zone
	BodyRRs RRArray
	RRs     RRArray // BodyRRs + ApexRRs

	// Data		map[string]map[uint16][]dns.RR	// map[owner]map[rrtype][]dns.RR
	Data   map[string]OwnerData // map[owner]map[rrtype][]dns.RR
	RpzMap map[string]*RpzName  // map[owner]map[rrtype][]dns.RR

	// Other stuff
	DroppedRRs     int
	KeptRRs        int
	XfrType        string // axfr | ixfr
	Logger         *log.Logger
	IncomingSerial uint32
	//	RRKeepFunc     func(uint16) bool
	RRParseFunc func(*dns.RR, *ZoneData) bool
	Verbose     bool
	Debug       bool
}

func (*ZoneData) ComputeIndices 

func (zd *ZoneData) ComputeIndices()

func (*ZoneData) DoTransfer 

func (zd *ZoneData) DoTransfer(upstream string) (bool, uint32, uint32, error)

func (*ZoneData) FetchFromUpstream 

func (zd *ZoneData) FetchFromUpstream(upstream string, current_serial uint32, verbose bool) error

func (*ZoneData) FindGlue 

func (zd *ZoneData) FindGlue(nsrrs RRset) *RRset

func (*ZoneData) PrintOwners 

func (zd *ZoneData) PrintOwners()

func (*ZoneData) PrintRRs 

func (zd *ZoneData) PrintRRs()

func (*ZoneData) RRSortFunc 

func (zd *ZoneData) RRSortFunc(rr dns.RR, first_soa *dns.SOA)

func (*ZoneData) ReadZone 

func (zd *ZoneData) ReadZone(r io.Reader) (uint32, error)

func (*ZoneData) ReadZoneFile 

func (zd *ZoneData) ReadZoneFile(filename string) (uint32, error)

func (*ZoneData) ReadZoneString 

func (zd *ZoneData) ReadZoneString(s string) (uint32, error)

func (*ZoneData) Refresh 

func (zd *ZoneData) Refresh(upstream string) (bool, error)

func (*ZoneData) Sync 

func (zd *ZoneData) Sync() error

func (*ZoneData) WriteFile 

func (zd *ZoneData) WriteFile(filename string, lg *log.Logger) (string, error)

func (*ZoneData) WriteTmpFile 

func (zd *ZoneData) WriteTmpFile(lg *log.Logger) (string, error)

func (*ZoneData) WriteZoneToFile 

func (zd *ZoneData) WriteZoneToFile(f *os.File) error

func (*ZoneData) ZoneTransferIn 

func (zd *ZoneData) ZoneTransferIn(upstream string, serial uint32, ttype string) (uint32, error)

type ZoneType 

type ZoneType uint8
const (
	XfrZone ZoneType = iota
	MapZone
	SliceZone
	RpzZone
)

Source Files

View all Source files

Directories

Path Synopsis
* Copyright (c) 2024 Johan Stenstam, johan.stenstam@internetstiftelsen.se
 * Copyright (c) 2024 Johan Stenstam, johan.stenstam@internetstiftelsen.se

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.