Decoder implements the watch.Decoder interface for io.ReadClosers that have contents which consist of a series of watchEvent objects encoded with the given streaming decoder. The internal objects will be then decoded by the embedded decoder.
type Decoder struct {
// contains filtered or unexported fields
}
func NewDecoder(decoder streaming.Decoder, embeddedDecoder runtime.Decoder) *Decoder
NewDecoder creates an Decoder for the given writer and codec.
func (d *Decoder) Close()
Close closes the underlying r.
func (d *Decoder) Decode() (watch.EventType, runtime.Object, error)
Decode blocks until it can return the next object in the reader. Returns an error if the reader is closed or an object can't be decoded.
Encoder serializes watch.Events into io.Writer. The internal objects are encoded using embedded encoder, and the outer Event is serialized using encoder. TODO: this type is only used by tests
type Encoder struct {
// contains filtered or unexported fields
}
func NewEncoder(encoder streaming.Encoder, embeddedEncoder runtime.Encoder) *Encoder
func (e *Encoder) Encode(event *watch.Event) error
Encode writes an event to the writer. Returns an error if the writer is closed or an object can't be encoded.