forked from openshift/origin
-
Notifications
You must be signed in to change notification settings - Fork 0
/
streamer.go
32 lines (25 loc) · 887 Bytes
/
streamer.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
package rest
import (
"context"
"io"
"k8s.io/apimachinery/pkg/runtime"
"k8s.io/apimachinery/pkg/runtime/schema"
"k8s.io/apiserver/pkg/registry/rest"
)
type PassThroughStreamer struct {
In io.ReadCloser
Flush bool
ContentType string
}
// a PipeStreamer must implement a rest.ResourceStreamer
var _ rest.ResourceStreamer = &PassThroughStreamer{}
func (obj *PassThroughStreamer) GetObjectKind() schema.ObjectKind {
return schema.EmptyObjectKind
}
func (obj *PassThroughStreamer) DeepCopyObject() runtime.Object {
panic("passThroughStreamer does not implement DeepCopyObject")
}
// InputStream returns a stream with the contents of the embedded pipe.
func (s *PassThroughStreamer) InputStream(ctx context.Context, apiVersion, acceptHeader string) (stream io.ReadCloser, flush bool, contentType string, err error) {
return s.In, s.Flush, s.ContentType, nil
}