types

type Buffer interface {
	Writer
	Reader
}

type Counter interface {
	Inc()
}

type DnstapMessage struct {

	// for dnstap.Extra
	Labels map[string]string
	// contains filtered or unexported fields
}

type DnstapMessageGetFunc func(*DnstapMessage) string

type DtapFrame struct {
	Dnstap *golang_dnstap.Dnstap `protobuf:"bytes,1,req,name=Dnstap" json:"Dnstap,omitempty"`
	Labels map[string]string     `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

type FilterPlugin interface {
	Plugin
	Filter(*DnstapMessage) *DnstapMessage
}

type InputContext struct {
	No     int
	Logger *zap.Logger
	Writer Writer
}

type InputPlugin interface {
	Plugin
	Start(context.Context, *InputContext) error
}

type Net struct {
	IP           net.IP
	PrefixLength int
}

type OutputContext struct {
	OutputGroup string
	No          int
	Logger      *zap.Logger
	Reader      Reader
}

type OutputPlugin interface {
	Plugin
	Start(context.Context, *OutputContext) error
}

type Plugin interface {
	GetName() string
	GetID() string
}

type Reader interface {
	Read() <-chan *DnstapMessage
}

type Writer interface {
	Write(*DnstapMessage)
}