logservice

type Log struct {
	Time      time.Time
	Type      LogType `faker:"oneof: platform.start, platform.report, platform.fault, platform.logsDropped, function"`
	RequestID string
	Content   []byte
}

type LogAPIClient interface {
	SubscribeLogs(ctx context.Context, types []extension.LogType, params extension.SubscribeLogsParams) (res extension.SubscribeResponse, err error)
}

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

type LogType string

type Message struct {
	Time   time.Time       `json:"time"`
	Type   string          `json:"type"`
	Record json.RawMessage `json:"record"`
}

type ReportRecord struct {
	RequestID string          `json:"requestId"`
	Metrics   json.RawMessage `json:"metrics"`
}

type ServiceParams struct {
	LogAPIClient         LogAPIClient
	LogTypes             []extension.LogType
	LogsQueue            chan []Log
	ListenPort           int
	MaxItems             int
	MaxBytes             int
	TimeoutMS            int
	EnablePlatformReport bool
}

type StartRecord struct {
	RequestID string `json:"requestId"`
}