kubernetes/staging/src/k8s.io/client-go/rest/watch/encoder.go

type Encoder …

func NewEncoder(encoder streaming.Encoder, embeddedEncoder runtime.Encoder) *Encoder { … }

// Encode writes an event to the writer. Returns an error
// if the writer is closed or an object can't be encoded.
func (e *Encoder) Encode(event *watch.Event) error { … }