Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

rpc

package module

Go to main page

Versions in this module

v1

v1.0.2

Mar 31, 2026

v1.0.1

Mar 31, 2026

Changes in this version

+ const DefaultTransport

+ const TransportGRPC

+ const TransportJSON

+ const TransportZAP

+ var ErrZAPClosed = errors.New("zap: connection closed")

+ var ErrZAPInvalidResp = errors.New("zap: invalid response")

+ var ErrZAPTimeout = errors.New("zap: request timeout")

+ func AvailableTransports() []string

+ func CleanlyCloseBody(body io.ReadCloser) error

+ func HasTransport(name string) bool

+ func SendJSONRequest(ctx context.Context, uri *url.URL, method string, params interface{}, ...) error

+ type BinaryCodec struct

+ func (BinaryCodec) Decode(data []byte, v interface{}) error

+ func (BinaryCodec) Encode(v interface{}) ([]byte, error)

+ type Client interface

+ Call func(ctx context.Context, method string, args, reply interface{}) error

+ CallRaw func(ctx context.Context, method string, payload []byte) ([]byte, error)

+ Close func() error

+ Notify func(ctx context.Context, method string, args interface{}) error

+ func Dial(ctx context.Context, addr string, opts ...DialOption) (Client, error)

+ type Codec interface

+ Decode func(data []byte, v interface{}) error

+ Encode func(v interface{}) ([]byte, error)

+ var Binary Codec = BinaryCodec{}

+ type DialOption func(*dialOptions)

+ func WithCodec(c Codec) DialOption

+ func WithTransport(t string) DialOption

+ type EndpointRequester interface

+ SendRequest func(ctx context.Context, method string, params interface{}, reply interface{}, ...) error

+ func NewEndpointRequester(uri string) EndpointRequester

+ type JSONCodec struct

+ func (JSONCodec) Decode(data []byte, v interface{}) error

+ func (JSONCodec) Encode(v interface{}) ([]byte, error)

+ type MessageType uint8

+ const MsgError

+ const MsgNotify

+ const MsgRequest

+ const MsgResponse

+ type Option func(*Options)

+ func WithHeader(key, val string) Option

+ func WithQueryParam(key, val string) Option

+ type Options struct

+ func NewOptions(ops []Option) *Options

+ func (o *Options) Headers() http.Header

+ func (o *Options) QueryParams() url.Values

+ type RawHandler func(ctx context.Context, payload []byte) ([]byte, error)

+ type Server interface

+ Addr func() string

+ Close func() error

+ Register func(name string, handler interface{}) error

+ RegisterRaw func(method string, handler RawHandler) error

+ Serve func(ctx context.Context) error

+ func Listen(addr string, opts ...ServerOption) (Server, error)

+ type ServerOption func(*serverOptions)

+ func WithServerCodec(c Codec) ServerOption

+ func WithServerTransport(t string) ServerOption

+ type Transport interface

+ Recv func(ctx context.Context) ([]byte, error)

+ Send func(ctx context.Context, data []byte) error

+ type ZAPConn struct

+ func ZAPDial(ctx context.Context, addr string) (*ZAPConn, error)

+ func (z *ZAPConn) Call(ctx context.Context, method string, payload []byte) ([]byte, error)

+ func (z *ZAPConn) Close() error

+ func (z *ZAPConn) Notify(ctx context.Context, method string, payload []byte) error

+ type ZAPHandler interface

+ HandleZAP func(ctx context.Context, method string, payload []byte) ([]byte, error)

+ type ZAPHandlerFunc func(ctx context.Context, method string, payload []byte) ([]byte, error)

+ func (f ZAPHandlerFunc) HandleZAP(ctx context.Context, method string, payload []byte) ([]byte, error)

+ type ZAPResponse struct

+ Data []byte

+ Err error

+ type ZAPServer struct

+ func NewZAPServer(listener net.Listener, handler ZAPHandler) *ZAPServer

+ func (s *ZAPServer) Addr() net.Addr

+ func (s *ZAPServer) Close() error

+ func (s *ZAPServer) Serve(ctx context.Context) error

v1.0.0

Jan 9, 2026