parser.go

func (statsd *StatsdProvider) ParsePacket(packet []byte) (*Depth, error) {
	var depth Depth

	parser := PacketParser{
		buffer: packet,
		index:  0,
	}

	word, err := parser.TakeUntilDelimiter(".")
	if err != nil {
		return nil, err
	}

	if word != "queue_depth" {
		return nil, fmt.Errorf("Not a queue depth packet")
	}

	depth.Name, err = parser.TakeUntilDelimiter(".")
	if err != nil {
		return nil, fmt.Errorf("Error while taking name: %s", err)
	}

	depth.Sector, err = parser.TakeUntilDelimiter(".")
	if err != nil {
		return nil, fmt.Errorf("Error while taking sector: %s", err)
	}

	depth.Ident, err = parser.TakeUntilDelimiter(".")
	if err != nil {
		return nil, fmt.Errorf("Error while taking ident: %s", err)
	}

	depth.Address, err = parser.TakeUntilDelimiter(":")
	if err != nil {
		return nil, fmt.Errorf("Error while taking address: %s", err)
	}

	queueDepth, err := parser.TakeUntilDelimiter("|")
	if err != nil {
		return nil, fmt.Errorf("Error while taking queue depth: %s", err)
	}

	depth.Depth, err = strconv.Atoi(queueDepth)
	if err != nil {
		return nil, fmt.Errorf("Failed to convert depth (%s) to integer: %s", queueDepth, err)
	}

	err = parser.Verify("g")
	if err != nil {
		return nil, fmt.Errorf("Could not fully verify packet: %s", err)
	}

	return &depth, nil
}