v2

type Agent struct {
	Hostname    string `json:"hostname,omitempty"`
	ID          string `json:"id,omitempty"`
	EphemeralID string `json:"ephemeral_id,omitempty"`
	Type        string `json:"type,omitempty"`
	Version     string `json:"version,omitempty"`
}

type Alert struct {
	Labels       map[string]string `json:"labels"`
	Annotations  map[string]string `json:"annotations"`
	StartsAt     time.Time         `json:"startsAt"`
	EndsAt       time.Time         `json:"endsAt"`
	GeneratorURL string            `json:"generatorURL"`
}

type AppStatus struct {
	ApiVersion  string         `json:"apiVersion"`
	Description string         `json:"description"`
	Links       AppStatusLinks `json:"links"`
	Status      string         `json:"status"`
}

type AppStatusLinks struct {
	About string `json:"about"`
}

type Cacher interface {
	Read(io.Reader, interface{}) error
	Write(io.Writer, interface{}) error
}

type Client http.Client

type Concatenate interface {
	Concat() (io.Reader, error) // Join all configs in given Dir.
}

type Counter interface {
	Create() error
	Incr() error
	Destroy() error
}

type CounterVector interface {
	Create([]string) error        // Labels.
	Incr(map[string]string) error // map[Label]Value
}

type Decoder interface {
	Decode(io.Reader) error
}

type Document struct {
	ApiVersion string   `json:"apiVersion,omitempty"`
	Kind       string   `json:"kind,omitempty"`
	Receipts   Receipts `json:"receipts,omitempty"`
}

type Ecs struct {
	Version string `json:"version,omitempty"`
}

type Encoder interface {
	Encode(io.Writer) error
}

type Error string

type Filebeat struct {
	Agent     Agent              `json:"agent,omitempty"`
	Ecs       Ecs                `json:"ecs,omitempty"`
	Input     PostableEventInput `json:"input,omitempty"`
	Host      Host               `json:"host,omitempty"`
	Log       Log                `json:"log,omitempty"`
	Message   string             `json:"message,omitempty"`
	Version   string             `json:"@version,omitempty"`
	Timestamp string             `json:"@timestamp,omitempty"`
}

type Graceful interface {
	Start() error
	Stop() error
}

type HTTPConfig struct {
	ListenAddress string
	ReadTimeout   time.Duration
	WriteTimeout  time.Duration
}

type Handler interface {
	ServeHTTP(ResponseWriter, Request)
}

type HealthChecker interface {
	Start() error
	Stop() error
	AddURL(name string, urlTarget string, timeout time.Duration) error
	State(urlTarget string) error
}

type HistogramVector interface {
	Create([]string) error            // Labels.
	Observed([]string, float64) error // []LabelValues, seconds
}

type Host struct {
	Name string `json:"name,omitempty"`
}

type Log struct {
	Offset int32   `json:"offset,omitempty"`
	File   LogFile `json:"file,omitempty"`
}

type LogFile struct {
	Path string `json:"path,omitempty"`
}

type Logger interface {
	Fatalf(message string, args ...interface{})
	Panicf(message string, args ...interface{})
	Debugf(message string, args ...interface{})
	Errorf(message string, args ...interface{})
	Infof(message string, args ...interface{})
	LogLevel() string
	SetLevel(string)
	Tracef(message string, args ...interface{})
	Warningf(message string, args ...interface{})

	WithError(error) Logger
	WithField(string, interface{}) Logger
	WithFields(map[string]interface{}) Logger

	SetOutput(io.Writer)
}

type Logstash struct {
	Tags []string `json:"tags,omitempty"`
}

type MIB struct {
	Name        string
	Description string
	Units       string
}

type MIBRegistry interface {
	// Return MIB for given OID.
	MIB(string) *MIB

	// Return MIB for given OID.
	// Translate each node in OID to its corresponding name, if MIB has its definition, else use the number.
	// Ex : 1.3.6.1.2.1.11.19 -> iso.org.dod.internet.mgmt.mib-2.snmp.snmpInTraps.
	//      1.3.6.1.2.1.11.19.54334 -> iso.org.dod.internet.mgmt.mib-2.snmp.snmpInTraps.54334.
	String(string) string

	// Translate the last node to its name. Ex: 1.3.6.1.2.1.11.19 -> snmpInTraps.
	ShortString(string) string

	// Load given map[oid]MIB into registry.
	Load(map[string]MIB) error
}

type Measurer interface {
	Measure(ResponseWriter, Request, func(ResponseWriter, Request))
}

type Notifier interface {
	Notify(*[]Alert) error
}

type PostAlertsParams struct {
	Alerts []Alert

	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

type PostableEvent struct {
	Agent      Agent              `json:"agent,omitempty"`
	ApiVersion string             `json:"apiVersion,omitempty"`
	Document   Document           `json:"document,omitempty"`
	Ecs        Ecs                `json:"ecs,omitempty"`
	Input      PostableEventInput `json:"input,omitempty"`
	Host       Host               `json:"host,omitempty"`
	Log        Log                `json:"log,omitempty"`
	Message    string             `json:"message,omitempty"`
	Version    string             `json:"@version,omitempty"`
	Tags       []string           `json:"tags,omitempty"`
	Timestamp  string             `json:"@timestamp,omitempty"`
}

type PostableEventInput struct {
	Type string `json:"type,omitempty"`
}

type Receipts struct {
	Filebeat  Filebeat  `json:"filebeat,omitempty"`
	Logstash  Logstash  `json:"logstash,omitempty"`
	Snmptrapd Snmptrapd `json:"snmptrapd,omitempty"`
}

type Request *http.Request

type ResponseWriter interface {
	Header() http.Header
	Write([]byte) (int, error)
	WriteHeader(int)
	StatusCode() int
}

type SNMPConfig struct {
	Application    string
	AMAddress      string
	AMTimeout      time.Duration
	SNMPMibsDir    string
	CacheFile      string
	ListenAddress  string
	ConfigDir      string
	Version        string
	Throttle       bool
	PostTime       int
	SleepTime      int
	SendTime       int
	DryRun         bool
	LogUnknown     bool
	ForwardUnknown bool
}

type SchemaLoader interface {
	Load([]byte) error
}

type SchemaValidator interface {
	ValidateYAML([]byte) error
	ValidateJSON([]byte) error
}

type Serve interface {
	ListenAndServe() error
	Shutdown() error
	Handle(string, Handler)
	HandleFunc(string, func(ResponseWriter, Request))
}

type Server struct {
	Srv *http.Server
	Mux *http.ServeMux
	G   Graceful
	M   Measurer
}

type Snmptrapd struct {
	Timestamp   string     `json:"timestamp,omitempty"`
	Source      TrapSource `json:"source,omitempty"`
	Vars        []TrapVar  `json:"vars,omitempty"`
	PduSecurity string     `json:"pduSecurity,omitempty"`
}

type TrapSource struct {
	Address                string `json:"address"`
	Hostname               string `json:"hostname"`
	InternetLayerProtocol  string `json:"internetLayerProtocol"`
	Port                   string `json:"port"`
	TransportLayerProtocol string `json:"transportLayerProtocol"`
}

type TrapVar struct {
	Value string `json:"value"`
	Type  string `json:"type"`
	Oid   string `json:"oid"`
}

type UUIDGen interface {
	UUID() string
}

type Watcher interface {
	Watch() error
	Unwatch() error
}

type Writer interface {
	// Write a response object to the ResponseWriter with status code 200.
	Write(w ResponseWriter, r Request, e interface{})

	// WriteCode writes a response object to the ResponseWriter and sets a response code.
	WriteCode(w ResponseWriter, r Request, code int, e interface{})

	// WriteCreated writes a response object to the ResponseWriter with status code 201 and
	// the Location header set to location.
	WriteCreated(w ResponseWriter, r Request, location string, e interface{})

	// WriteError writes an error to ResponseWriter and tries to extract the error's status code by
	// asserting statusCodeCarrier. If the error does not implement statusCodeCarrier, the status code
	// is set to 500.
	WriteError(w ResponseWriter, r Request, err interface{})

	// WriteErrorCode writes an error to ResponseWriter and forces an error code.
	WriteErrorCode(w ResponseWriter, r Request, code int, err interface{})
}