Documentation
¶
Index ¶
- func ConvertProtoProcessPayload(pb *proto.ProcessPayload) model.ProcessPayload
- func ConvertToModelLogPayload(pbPayload *proto.LogPayload) model.LogPayload
- func ConvertToModelPayload(pbPayload *proto.MetricPayload) model.MetricPayload
- func MergeDimensionsWithMeta(base map[string]string, meta *model.Meta) map[string]string
- func SafeHandlePayload(handler func())
- type LogsHandler
- type StreamHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConvertProtoProcessPayload ¶
func ConvertProtoProcessPayload(pb *proto.ProcessPayload) model.ProcessPayload
ConvertProtoProcessPayload converts a protobuf ProcessPayload to a model.ProcessPayload.
func ConvertToModelLogPayload ¶
func ConvertToModelLogPayload(pbPayload *proto.LogPayload) model.LogPayload
ConvertToModelLogPayload converts a protobuf LogPayload to a model.LogPayload.
func ConvertToModelPayload ¶
func ConvertToModelPayload(pbPayload *proto.MetricPayload) model.MetricPayload
ConvertToModelPayload converts a protobuf MetricPayload to a model.MetricPayload.
func MergeDimensionsWithMeta ¶
TODO - do this better.
func SafeHandlePayload ¶
func SafeHandlePayload(handler func())
SafeHandlePayload wraps a handler function to recover from any panics that occur during its execution.
Types ¶
type LogsHandler ¶
type LogsHandler struct {
Sys *sys.SystemContext
pb.UnimplementedLogServiceServer
}
func NewLogsHandler ¶
func NewLogsHandler(sys *sys.SystemContext) *LogsHandler
func (*LogsHandler) EvaluateSeverityLevel ¶
func (h *LogsHandler) EvaluateSeverityLevel(logPayload *model.LogPayload)
EvaluateSeverityLevel evaluates the severity level of logs based on thresholds defined in the system. Based on that severity, different actions can be taken such as generating events that can trigger alerts.
func (*LogsHandler) SubmitStream ¶
func (h *LogsHandler) SubmitStream(stream pb.LogService_SubmitStreamServer) error
type StreamHandler ¶
type StreamHandler struct {
Sys *sys.SystemContext
pb.UnimplementedStreamServiceServer
}
StreamHandler implements pb.MetricsServiceServer StreamHandler implements MetricsServiceServer
func NewStreamHandler ¶
func NewStreamHandler(sys *sys.SystemContext) *StreamHandler
func (*StreamHandler) EnqueueCommandToAgent ¶
func (*StreamHandler) Stream ¶
func (h *StreamHandler) Stream(stream pb.StreamService_StreamServer) error
Source Files
Click to show internal directories.
Click to hide internal directories.