logs_handler

Documentation

Index

• func RegisterHandlers(server *server.Server, grp *huma.Group)
• type GetLogInput
• type HandlerGroup
  • func (self *HandlerGroup) GetLogsfunc(ctx context.Context, input *GetLogInput, send sse.Sender)
  • func (self *HandlerGroup) QueryLogs(ctx context.Context, input *QueryLogsInput) (*QueryLogsResponse, error)
• type LogEvent
• type QueryLogsInput
• type QueryLogsResponse

Functions

func RegisterHandlers

func RegisterHandlers(server *server.Server, grp *huma.Group)

Types

type GetLogInput

type GetLogInput struct {
	server.BaseAuthInput
	models.LogStreamInput
}

Parameters for querying logs

type HandlerGroup

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

func (*HandlerGroup) GetLogsfunc

func (self *HandlerGroup) GetLogsfunc(ctx context.Context, input *GetLogInput, send sse.Sender)

func (*HandlerGroup) QueryLogs

func (self *HandlerGroup) QueryLogs(ctx context.Context, input *QueryLogsInput) (*QueryLogsResponse, error)

type LogEvent

type LogEvent struct {
	PodName   string    `json:"podName"`
	Timestamp time.Time `json:"timestamp,omitempty"`
	Message   string    `json:"message"`
}

LogEvent represents a log line event sent via SSE

type QueryLogsInput

type QueryLogsInput struct {
	server.BaseAuthInput
	models.LogQueryInput
}

type QueryLogsResponse

type QueryLogsResponse struct {
	Body struct {
		Data []loki.LogEvent `json:"data" nullable:"false"`
	}
}