77069e63e5
This includes updates to CI config, vendor files, etc. I've hard-coded the k8s depedency at 1.13.4 to keep it inline with what we currently have and to make sure a another run of `go mod tidy` doesn't accidentally update it to an unexpected version. Thanks to hectorj2f for carrying this along.
49 lines
1.5 KiB
Go
49 lines
1.5 KiB
Go
package runtime
|
|
|
|
import (
|
|
"io"
|
|
)
|
|
|
|
// Marshaler defines a conversion between byte sequence and gRPC payloads / fields.
|
|
type Marshaler interface {
|
|
// Marshal marshals "v" into byte sequence.
|
|
Marshal(v interface{}) ([]byte, error)
|
|
// Unmarshal unmarshals "data" into "v".
|
|
// "v" must be a pointer value.
|
|
Unmarshal(data []byte, v interface{}) error
|
|
// NewDecoder returns a Decoder which reads byte sequence from "r".
|
|
NewDecoder(r io.Reader) Decoder
|
|
// NewEncoder returns an Encoder which writes bytes sequence into "w".
|
|
NewEncoder(w io.Writer) Encoder
|
|
// ContentType returns the Content-Type which this marshaler is responsible for.
|
|
ContentType() string
|
|
}
|
|
|
|
// Decoder decodes a byte sequence
|
|
type Decoder interface {
|
|
Decode(v interface{}) error
|
|
}
|
|
|
|
// Encoder encodes gRPC payloads / fields into byte sequence.
|
|
type Encoder interface {
|
|
Encode(v interface{}) error
|
|
}
|
|
|
|
// DecoderFunc adapts an decoder function into Decoder.
|
|
type DecoderFunc func(v interface{}) error
|
|
|
|
// Decode delegates invocations to the underlying function itself.
|
|
func (f DecoderFunc) Decode(v interface{}) error { return f(v) }
|
|
|
|
// EncoderFunc adapts an encoder function into Encoder
|
|
type EncoderFunc func(v interface{}) error
|
|
|
|
// Encode delegates invocations to the underlying function itself.
|
|
func (f EncoderFunc) Encode(v interface{}) error { return f(v) }
|
|
|
|
// Delimited defines the streaming delimiter.
|
|
type Delimited interface {
|
|
// Delimiter returns the record seperator for the stream.
|
|
Delimiter() []byte
|
|
}
|