connect

package module

Go to main page

Versions in this module

v1

v1.10.0

Jul 26, 2023

Changes in this version

type HandlerOption

+ func WithConditionalHandlerOptions(conditional func(spec Spec) []HandlerOption) HandlerOption

v1.9.0

Jun 27, 2023

Changes in this version

type ClientOption

+ func WithHTTPGetMaxURLSize(bytes int, fallback bool) ClientOption

v1.8.0

May 31, 2023

Changes in this version

type AnyRequest

+ HTTPMethod func() string

type Request

+ func (r *Request[_]) HTTPMethod() string

type StreamType

+ func (s StreamType) String() string

v1.7.0

Apr 19, 2023

Changes in this version

+ const IsAtLeastVersion1_7_0

+ func IsNotModifiedError(err error) bool

type ClientOption

+ func WithHTTPGet() ClientOption

type Error

+ func NewNotModifiedError(headers http.Header) *Error

+ type IdempotencyLevel int

+ const IdempotencyIdempotent

+ const IdempotencyNoSideEffects

+ const IdempotencyUnknown

+ func (i IdempotencyLevel) String() string

type Option

+ func WithIdempotency(idempotencyLevel IdempotencyLevel) Option

type Peer

+ Query url.Values

type Spec

+ IdempotencyLevel IdempotencyLevel

v1.6.0

Apr 3, 2023

v1.5.2

Feb 15, 2023

v1.5.1

Feb 1, 2023

v1.5.0

Jan 26, 2023

Changes in this version

type Error

+ func NewWireError(c Code, underlying error) *Error

v1.4.1

Dec 20, 2022

v1.4.0

Dec 8, 2022

Changes in this version

type HandlerOption

+ func WithRequireConnectProtocolHeader() HandlerOption

v1.3.2

Dec 5, 2022

v1.3.1

Dec 1, 2022

v1.3.0

Nov 30, 2022

v1.2.0

Nov 18, 2022

Changes in this version

+ const ProtocolConnect

+ const ProtocolGRPC

+ const ProtocolGRPCWeb

type Peer

+ Protocol string

v1.1.0

Oct 18, 2022

Changes in this version

+ func IsWireError(err error) bool

v1.0.0

Oct 4, 2022

v0

v0.5.0

Sep 23, 2022

Changes in this version

type AnyRequest

+ Peer func() Peer

type BidiStream

+ func (b *BidiStream[_, _]) Peer() Peer

+ func (b *BidiStream[_, _]) Spec() Spec

type BidiStreamForClient

+ func (b *BidiStreamForClient[_, _]) Peer() Peer

+ func (b *BidiStreamForClient[_, _]) Spec() Spec

type ClientStream

+ func (c *ClientStream[_]) Peer() Peer

+ func (c *ClientStream[_]) Spec() Spec

type ClientStreamForClient

+ func (c *ClientStreamForClient[_, _]) Peer() Peer

+ func (c *ClientStreamForClient[_, _]) Spec() Spec

+ type ErrorWriter struct

+ func NewErrorWriter(opts ...HandlerOption) *ErrorWriter

+ func (w *ErrorWriter) IsSupported(request *http.Request) bool

+ func (w *ErrorWriter) Write(response http.ResponseWriter, request *http.Request, err error) error

+ type Peer struct

+ Addr string

type Request

+ func (r *Request[_]) Peer() Peer

type StreamingClientConn

+ Peer func() Peer

type StreamingHandlerConn

+ Peer func() Peer

v0.4.0

Aug 17, 2022

Changes in this version

type BidiStream

+ func (b *BidiStream[Req, Res]) Conn() StreamingHandlerConn

type BidiStreamForClient

+ func (b *BidiStreamForClient[Req, Res]) Conn() (StreamingClientConn, error)

type ClientStream

+ func (c *ClientStream[Req]) Conn() StreamingHandlerConn

type ClientStreamForClient

+ func (c *ClientStreamForClient[Req, Res]) Conn() (StreamingClientConn, error)

type Option

+ func WithSendMaxBytes(max int) Option

type ServerStream

+ func (s *ServerStream[Res]) Conn() StreamingHandlerConn

type ServerStreamForClient

+ func (s *ServerStreamForClient[Res]) Conn() (StreamingClientConn, error)

v0.3.0

Aug 1, 2022

Changes in this version

type ErrorDetail

+ func NewErrorDetail(msg proto.Message) (*ErrorDetail, error)

+ func (d *ErrorDetail) Bytes() []byte

+ func (d *ErrorDetail) Type() string

+ func (d *ErrorDetail) Value() (proto.Message, error)

v0.2.0

Jul 18, 2022

Changes in this version

type BidiStreamForClient

+ func (b *BidiStreamForClient[Req, Res]) CloseRequest() error

+ func (b *BidiStreamForClient[Req, Res]) CloseResponse() error

type HandlerOption

+ func WithRecover(handle func(context.Context, Spec, http.Header, any) error) HandlerOption

type Interceptor

+ WrapStreamingClient func(StreamingClientFunc) StreamingClientFunc

+ WrapStreamingHandler func(StreamingHandlerFunc) StreamingHandlerFunc

type Option

+ func WithReadMaxBytes(max int) Option

+ type StreamingClientConn interface

+ CloseRequest func() error

+ CloseResponse func() error

+ Receive func(any) error

+ RequestHeader func() http.Header

+ ResponseHeader func() http.Header

+ ResponseTrailer func() http.Header

+ Send func(any) error

+ Spec func() Spec

+ type StreamingClientFunc func(context.Context, Spec) StreamingClientConn

+ type StreamingHandlerConn interface

+ Receive func(any) error

+ RequestHeader func() http.Header

+ ResponseHeader func() http.Header

+ ResponseTrailer func() http.Header

+ Send func(any) error

+ Spec func() Spec

+ type StreamingHandlerFunc func(context.Context, StreamingHandlerConn) error

type UnaryInterceptorFunc

+ func (f UnaryInterceptorFunc) WrapStreamingClient(next StreamingClientFunc) StreamingClientFunc

+ func (f UnaryInterceptorFunc) WrapStreamingHandler(next StreamingHandlerFunc) StreamingHandlerFunc

v0.1.1

Jun 6, 2022

v0.1.0

Jun 1, 2022

Changes in this version

+ const IsAtLeastVersion0_0_1

+ const IsAtLeastVersion0_1_0

+ const StreamTypeBidi

+ const StreamTypeClient

+ const StreamTypeServer

+ const StreamTypeUnary

+ const Version

+ func DecodeBinaryHeader(data string) ([]byte, error)

+ func EncodeBinaryHeader(data []byte) string

+ type AnyRequest interface

+ Any func() any

+ Header func() http.Header

+ Spec func() Spec

+ type AnyResponse interface

+ Any func() any

+ Header func() http.Header

+ Trailer func() http.Header

+ type BidiStream struct

+ func (b *BidiStream[Req, Res]) Receive() (*Req, error)

+ func (b *BidiStream[Req, Res]) RequestHeader() http.Header

+ func (b *BidiStream[Req, Res]) ResponseHeader() http.Header

+ func (b *BidiStream[Req, Res]) ResponseTrailer() http.Header

+ func (b *BidiStream[Req, Res]) Send(msg *Res) error

+ type BidiStreamForClient struct

+ func (b *BidiStreamForClient[Req, Res]) CloseReceive() error

+ func (b *BidiStreamForClient[Req, Res]) CloseSend() error

+ func (b *BidiStreamForClient[Req, Res]) Receive() (*Res, error)

+ func (b *BidiStreamForClient[Req, Res]) RequestHeader() http.Header

+ func (b *BidiStreamForClient[Req, Res]) ResponseHeader() http.Header

+ func (b *BidiStreamForClient[Req, Res]) ResponseTrailer() http.Header

+ func (b *BidiStreamForClient[Req, Res]) Send(msg *Req) error

+ type Client struct

+ func NewClient(httpClient HTTPClient, url string, options ...ClientOption) *Client[Req, Res]

+ func (c *Client[Req, Res]) CallBidiStream(ctx context.Context) *BidiStreamForClient[Req, Res]

+ func (c *Client[Req, Res]) CallClientStream(ctx context.Context) *ClientStreamForClient[Req, Res]

+ func (c *Client[Req, Res]) CallServerStream(ctx context.Context, request *Request[Req]) (*ServerStreamForClient[Res], error)

+ func (c *Client[Req, Res]) CallUnary(ctx context.Context, request *Request[Req]) (*Response[Res], error)

+ type ClientOption interface

+ func WithAcceptCompression(name string, newDecompressor func() Decompressor, ...) ClientOption

+ func WithClientOptions(options ...ClientOption) ClientOption

+ func WithGRPC() ClientOption

+ func WithGRPCWeb() ClientOption

+ func WithProtoJSON() ClientOption

+ func WithSendCompression(name string) ClientOption

+ func WithSendGzip() ClientOption

+ type ClientStream struct

+ func (c *ClientStream[Req]) Err() error

+ func (c *ClientStream[Req]) Msg() *Req

+ func (c *ClientStream[Req]) Receive() bool

+ func (c *ClientStream[Req]) RequestHeader() http.Header

+ type ClientStreamForClient struct

+ func (c *ClientStreamForClient[Req, Res]) CloseAndReceive() (*Response[Res], error)

+ func (c *ClientStreamForClient[Req, Res]) RequestHeader() http.Header

+ func (c *ClientStreamForClient[Req, Res]) Send(request *Req) error

+ type Code uint32

+ const CodeAborted

+ const CodeAlreadyExists

+ const CodeCanceled

+ const CodeDataLoss

+ const CodeDeadlineExceeded

+ const CodeFailedPrecondition

+ const CodeInternal

+ const CodeInvalidArgument

+ const CodeNotFound

+ const CodeOutOfRange

+ const CodePermissionDenied

+ const CodeResourceExhausted

+ const CodeUnauthenticated

+ const CodeUnavailable

+ const CodeUnimplemented

+ const CodeUnknown

+ func CodeOf(err error) Code

+ func (c *Code) UnmarshalText(data []byte) error

+ func (c Code) MarshalText() ([]byte, error)

+ func (c Code) String() string

+ type Codec interface

+ Marshal func(any) ([]byte, error)

+ Name func() string

+ Unmarshal func([]byte, any) error

+ type Compressor interface

+ Close func() error

+ Reset func(io.Writer)

+ type Decompressor interface

+ Close func() error

+ Reset func(io.Reader) error

+ type Error struct

+ func NewError(c Code, underlying error) *Error

+ func (e *Error) AddDetail(d ErrorDetail)

+ func (e *Error) Code() Code

+ func (e *Error) Details() []ErrorDetail

+ func (e *Error) Error() string

+ func (e *Error) Message() string

+ func (e *Error) Meta() http.Header

+ func (e *Error) Unwrap() error

+ type ErrorDetail interface

+ MessageName func() protoreflect.FullName

+ UnmarshalTo func(proto.Message) error

+ type HTTPClient interface

+ Do func(*http.Request) (*http.Response, error)

+ type Handler struct

+ func NewBidiStreamHandler(procedure string, ...) *Handler

+ func NewClientStreamHandler(procedure string, ...) *Handler

+ func NewServerStreamHandler(procedure string, ...) *Handler

+ func NewUnaryHandler(procedure string, ...) *Handler

+ func (h *Handler) ServeHTTP(responseWriter http.ResponseWriter, request *http.Request)

+ type HandlerOption interface

+ func WithCompression(name string, newDecompressor func() Decompressor, ...) HandlerOption

+ func WithHandlerOptions(options ...HandlerOption) HandlerOption

+ type Interceptor interface

+ WrapStreamContext func(context.Context) context.Context

+ WrapStreamReceiver func(context.Context, Receiver) Receiver

+ WrapStreamSender func(context.Context, Sender) Sender

+ WrapUnary func(UnaryFunc) UnaryFunc

+ type Option interface

+ func WithCodec(codec Codec) Option

+ func WithCompressMinBytes(min int) Option

+ func WithInterceptors(interceptors ...Interceptor) Option

+ func WithOptions(options ...Option) Option

+ type Receiver interface

+ Close func() error

+ Header func() http.Header

+ Receive func(any) error

+ Spec func() Spec

+ Trailer func() (http.Header, bool)

+ type Request struct

+ Msg *T

+ func NewRequest(message *T) *Request[T]

+ func (r *Request[_]) Any() any

+ func (r *Request[_]) Header() http.Header

+ func (r *Request[_]) Spec() Spec

+ type Response struct

+ Msg *T

+ func NewResponse(message *T) *Response[T]

+ func (r *Response[_]) Any() any

+ func (r *Response[_]) Header() http.Header

+ func (r *Response[_]) Trailer() http.Header

+ type Sender interface

+ Close func(error) error

+ Header func() http.Header

+ Send func(any) error

+ Spec func() Spec

+ Trailer func() (http.Header, bool)

+ type ServerStream struct

+ func (s *ServerStream[Res]) ResponseHeader() http.Header

+ func (s *ServerStream[Res]) ResponseTrailer() http.Header

+ func (s *ServerStream[Res]) Send(msg *Res) error

+ type ServerStreamForClient struct

+ func (s *ServerStreamForClient[Res]) Close() error

+ func (s *ServerStreamForClient[Res]) Err() error

+ func (s *ServerStreamForClient[Res]) Msg() *Res

+ func (s *ServerStreamForClient[Res]) Receive() bool

+ func (s *ServerStreamForClient[Res]) ResponseHeader() http.Header

+ func (s *ServerStreamForClient[Res]) ResponseTrailer() http.Header

+ type Spec struct

+ IsClient bool

+ Procedure string

+ StreamType StreamType

+ type StreamType uint8

+ type UnaryFunc func(context.Context, AnyRequest) (AnyResponse, error)

+ type UnaryInterceptorFunc func(UnaryFunc) UnaryFunc

+ func (f UnaryInterceptorFunc) WrapStreamContext(ctx context.Context) context.Context

+ func (f UnaryInterceptorFunc) WrapStreamReceiver(_ context.Context, receiver Receiver) Receiver

+ func (f UnaryInterceptorFunc) WrapStreamSender(_ context.Context, sender Sender) Sender

+ func (f UnaryInterceptorFunc) WrapUnary(next UnaryFunc) UnaryFunc

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL