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 { … }