@@ -957,28 +957,18 @@ func (ewm *EventWritersMap) Remove(agentName string) {
957957
958958type ContainerLogRequest struct {
959959 // UUID for request/response correlation
960- UUID string `json:"uuid"`
961-
962- // Pod identification
963- Namespace string `json:"namespace"`
964- PodName string `json:"podName"`
965-
966- // Container specification
967- Container string `json:"container,omitempty"` // Optional, defaults to first container
968-
969- // Log streaming parameters
970- Follow bool `json:"follow,omitempty"` // Stream continuously
971- TailLines * int64 `json:"tailLines,omitempty"` // Number of lines from end
972- SinceSeconds * int64 `json:"sinceSeconds,omitempty"` // Relative time
973- SinceTime string `json:"sinceTime,omitempty"` // Absolute timestamp (RFC3339)
974- Timestamps bool `json:"timestamps,omitempty"` // Include timestamps
975- Previous bool `json:"previous,omitempty"` // Previous container logs
976-
977- // Additional parameters from K8s logs API
978- InsecureSkipTLSVerifyBackend bool `json:"insecureSkipTLSVerifyBackend,omitempty"` // Skip TLS verification
979- LimitBytes * int64 `json:"limitBytes,omitempty"` // Limit output bytes
980- Pretty bool `json:"pretty,omitempty"` // Pretty print output
981- Stream string `json:"stream,omitempty"` // "All", "Stdout", or "Stderr"
960+ UUID string `json:"uuid"`
961+ Namespace string `json:"namespace"`
962+ PodName string `json:"podName"`
963+ Container string `json:"container,omitempty"`
964+ Follow bool `json:"follow,omitempty"`
965+ TailLines * int64 `json:"tailLines,omitempty"`
966+ SinceSeconds * int64 `json:"sinceSeconds,omitempty"`
967+ SinceTime string `json:"sinceTime,omitempty"`
968+ Timestamps bool `json:"timestamps,omitempty"`
969+ Previous bool `json:"previous,omitempty"`
970+ InsecureSkipTLSVerifyBackend bool `json:"insecureSkipTLSVerifyBackend,omitempty"`
971+ LimitBytes * int64 `json:"limitBytes,omitempty"`
982972}
983973
984974// NewLogRequestEvent creates a cloud event for requesting logs
@@ -1035,18 +1025,6 @@ func (evs EventSource) NewLogRequestEvent(namespace, podName, method string, par
10351025 logReq .LimitBytes = & bytes
10361026 }
10371027 }
1038-
1039- if pretty := params ["pretty" ]; pretty == "true" {
1040- logReq .Pretty = true
1041- }
1042-
1043- if stream := params ["stream" ]; stream != "" {
1044- // Validate stream parameter - must be "All", "Stdout", or "Stderr"
1045- if stream == "All" || stream == "Stdout" || stream == "Stderr" {
1046- logReq .Stream = stream
1047- }
1048- }
1049-
10501028 cev := cloudevents .NewEvent ()
10511029 cev .SetSource (evs .source )
10521030 cev .SetSpecVersion (cloudEventSpecVersion )
0 commit comments