Documentation
¶
Index ¶
- Variables
- type HTTPBodyMarshaler
- type PipeListener
- func (l *PipeListener) Accept() (c net.Conn, e error)
- func (l *PipeListener) Addr() net.Addr
- func (l *PipeListener) Close() (e error)
- func (l *PipeListener) Dial(network, addr string) (net.Conn, error)
- func (l *PipeListener) DialContext(ctx context.Context, network, addr string) (conn net.Conn, e error)
Constants ¶
This section is empty.
Variables ¶
var ErrPipeListenerClosed = errors.New(`pipe listener already closed`)
Functions ¶
This section is empty.
Types ¶
type HTTPBodyMarshaler ¶
HTTPBodyMarshaler is a Marshaler which supports marshaling of a google.api.HttpBody message as the full response body if it is the actual message used as the response. If not, then this will simply fallback to the Marshaler specified as its default Marshaler.
func (*HTTPBodyMarshaler) ContentType ¶
func (h *HTTPBodyMarshaler) ContentType(v interface{}) string
ContentType returns its specified content type in case v is a google.api.HttpBody message, otherwise it will fall back to the default Marshalers content type.
func (*HTTPBodyMarshaler) Delimiter ¶
func (h *HTTPBodyMarshaler) Delimiter() []byte
Delimiter returns the record separator for the stream.
func (*HTTPBodyMarshaler) Marshal ¶
func (h *HTTPBodyMarshaler) Marshal(v interface{}) ([]byte, error)
Marshal marshals "v" by returning the body bytes if v is a google.api.HttpBody message, otherwise it falls back to the default Marshaler.
type PipeListener ¶
type PipeListener struct {
// contains filtered or unexported fields
}
func ListenPipe ¶
func ListenPipe() *PipeListener
func (*PipeListener) Accept ¶
func (l *PipeListener) Accept() (c net.Conn, e error)
Accept waits for and returns the next connection to the listener.
func (*PipeListener) Addr ¶
func (l *PipeListener) Addr() net.Addr
Addr returns the listener's network address.
func (*PipeListener) Close ¶
func (l *PipeListener) Close() (e error)
Close closes the listener. Any blocked Accept operations will be unblocked and return errors.
Source Files