@@ -957,28 +957,18 @@ func (ewm *EventWritersMap) Remove(agentName string) {
957
957
958
958
type ContainerLogRequest struct {
959
959
// 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"`
982
972
}
983
973
984
974
// NewLogRequestEvent creates a cloud event for requesting logs
@@ -1035,18 +1025,6 @@ func (evs EventSource) NewLogRequestEvent(namespace, podName, method string, par
1035
1025
logReq .LimitBytes = & bytes
1036
1026
}
1037
1027
}
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
-
1050
1028
cev := cloudevents .NewEvent ()
1051
1029
cev .SetSource (evs .source )
1052
1030
cev .SetSpecVersion (cloudEventSpecVersion )
0 commit comments