kafka

type ArcBuffer struct {
	// contains filtered or unexported fields
}

type Client struct {
	// contains filtered or unexported fields
}

type Handler interface {
	Start(context.Context)
	Write(uint64, *protocols.Frame) error
	Stop()
}

type MessageData struct {
	Ts       int64   `json:"ts"`
	SensorID string  `json:"sensorID"` // sensor
	ArcData  float64 `json:"arcData"`  // arc
}

type Option func(opts *Server)

type Server struct {
	// contains filtered or unexported fields
}