zabbix

Documentation

Index

• Constants
• Variables
• func Data2Packet(data []byte) []byte
• func Data2Stream(data []byte, conn io.Writer) (int, error)
• func FillDefaultPort(addr string, port int) string
• func Get(addr string, key string, timeout time.Duration) (value string, err error)
• func Packet2Data(packet []byte) (data []byte, err error)
• func RunAgent(addr string, callback func(string) (string, error)) error
• func RunTrapper(addr string, callback func(TrapperRequest) (TrapperResponse, error)) error
• func Stream2Data(conn io.Reader) (rdata []byte, err error)
• type TrapperData
• type TrapperRequest
  • func (r TrapperRequest) ToPacket() []byte
• type TrapperResponse
  • func Send(addr string, data TrapperData, timeout time.Duration) (TrapperResponse, error)
  • func SendBulk(addr string, req TrapperRequest, timeout time.Duration) (res TrapperResponse, err error)
  • func (r TrapperResponse) ToPacket() []byte

Constants

const (
	AgentDefaultPort  = 10050
	ServerDefaultPort = 10051
)

const (
	HeaderString     = "ZBXD"
	HeaderLength     = len(HeaderString)
	HeaderVersion    = uint8(1)
	DataLengthOffset = int64(HeaderLength + 1)
	DataLengthSize   = int64(8)
	DataOffset       = int64(DataLengthOffset + DataLengthSize)
	ErrorMessage     = "ZBX_NOTSUPPORTED"
)

const (
	TrapperResponseSuccess = "success"
	TrapperResponseInfoFmt = "processed: %d; failed: %d; total: %d; seconds spent: %f"
	TrapperRequestString   = "sender data"
)

Variables

var (
	ErrorMessageBytes = []byte(ErrorMessage)
	Terminator        = []byte("\n")
	HeaderBytes       = []byte(HeaderString)
)

Functions

func Data2Packet

func Data2Packet(data []byte) []byte

func Data2Stream

func Data2Stream(data []byte, conn io.Writer) (int, error)

func FillDefaultPort

func FillDefaultPort(addr string, port int) string

func Get

func Get(addr string, key string, timeout time.Duration) (value string, err error)

func Packet2Data

func Packet2Data(packet []byte) (data []byte, err error)

func RunAgent

func RunAgent(addr string, callback func(string) (string, error)) error

func RunTrapper

func RunTrapper(addr string, callback func(TrapperRequest) (TrapperResponse, error)) error

func Stream2Data

func Stream2Data(conn io.Reader) (rdata []byte, err error)

Types

type TrapperData

type TrapperData struct {
	Host  string `json:"host"`
	Key   string `json:"key"`
	Value string `json:"value"`
	Clock int64  `json:"clock"`
}

type TrapperRequest

type TrapperRequest struct {
	Request string        `json:"request"`
	Clock   int64         `json:"clock"`
	Data    []TrapperData `json:"data"`
}

func (TrapperRequest) ToPacket

func (r TrapperRequest) ToPacket() []byte

type TrapperResponse

type TrapperResponse struct {
	Response  string `json:"response"`
	Info      string `json:"info"`
	Proceeded int    `json:""`
	Failed    int    `json:""`
	Total     int    `json:""`
}

func Send

func Send(addr string, data TrapperData, timeout time.Duration) (TrapperResponse, error)

func SendBulk

func SendBulk(addr string, req TrapperRequest, timeout time.Duration) (res TrapperResponse, err error)

func (TrapperResponse) ToPacket

func (r TrapperResponse) ToPacket() []byte