Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

natsrpc

package module

Go to main page

Versions in this module

v0

v0.18.1

Jul 16, 2024

v0.18.0

Jun 29, 2024

v0.17.0

Jun 24, 2024

Changes in this version

+ const SupportVersion_0_7_0

+ const Version

+ var DefaultClientOptions = ClientOptions

+ var DefaultServerOptions = ServerOptions

+ var DefaultServiceOptions = ServiceOptions

+ var E_Publish = &file_natsrpc_proto_extTypes[0]

+ var ErrDuplicateService = errors.New("natsrpc: duplicate service")

+ var ErrEmptyReply = errors.New("natsrpc: reply is empty")

+ var ErrHeaderFormat = errors.New("natsrpc: header format error")

+ var ErrNoMeta = errors.New("natsrpc: no meta data")

+ var ErrNoMethod = errors.New("natsrpc: no method")

+ var ErrReplyLater = errors.New("natsrpc: reply later")

+ var File_natsrpc_proto protoreflect.FileDescriptor

+ func CallHeader(ctx context.Context) map[string]string

+ func MakeReplyFunc[T any](ctx context.Context) (replay func(T, error) error)

+ func Reply(ctx context.Context, rep interface{}, repErr error) error

+ type CallOption func(options *CallOptions)

+ func WithCallHeader(hd map[string]string) CallOption

+ type CallOptions struct

+ type Client struct

+ func NewClient(conn *nats.Conn, opts ...ClientOption) *Client

+ func (c *Client) Publish(service, method string, req interface{}, opt ...CallOption) error

+ func (c *Client) Request(ctx context.Context, service, method string, req interface{}, rep interface{}, ...) error

+ type ClientInterface interface

+ Publish func(service, method string, req interface{}, opt ...CallOption) error

+ Request func(ctx context.Context, service, method string, req interface{}, rep interface{}, ...) error

+ type ClientOption func(options *ClientOptions)

+ func WithClientEncoder(encoder Encoder) ClientOption

+ func WithClientID(id string) ClientOption

+ func WithClientNamespace(namespace string) ClientOption

+ type ClientOptions struct

+ type Encoder interface

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

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

+ type Handler func(svc interface{}, ctx context.Context, req interface{}) (interface{}, error)

+ type Interceptor func(ctx context.Context, method string, req interface{}, invoker Invoker) (interface{}, error)

+ type Invoker func(ctx context.Context, req interface{}) (interface{}, error)

+ type MethodDesc struct

+ Handler Handler

+ IsPublish bool

+ MethodName string

+ RequestType reflect.Type

+ func (md MethodDesc) NewRequest() any

+ type Server struct

+ func NewServer(conn *nats.Conn, option ...ServerOption) (*Server, error)

+ func (s *Server) Close(ctx context.Context) (err error)

+ func (s *Server) Register(sd ServiceDesc, val interface{}, opts ...ServiceOption) (ServiceInterface, error)

+ func (s *Server) Remove(name string) bool

+ func (s *Server) UnSubscribeAll() error

+ type ServerInterface interface

+ Remove func(string) bool

+ type ServerOption func(options *ServerOptions)

+ func WithErrorHandler(h func(interface{})) ServerOption

+ func WithServerEncoder(encoder Encoder) ServerOption

+ func WithServerRecovery(h func(interface{})) ServerOption

+ type ServerOptions struct

+ type Service struct

+ func NewService(server ServerInterface, sd ServiceDesc, i interface{}, options ServiceOptions) (*Service, error)

+ func (s *Service) Call(ctx context.Context, methodName string, b []byte, interceptor Interceptor) ([]byte, error)

+ func (s *Service) Close() bool

+ func (s *Service) Name() string

+ type ServiceDesc struct

+ Metadata string

+ Methods []MethodDesc

+ ServiceName string

+ type ServiceInterface interface

+ Close func() bool

+ Name func() string

+ type ServiceOption func(options *ServiceOptions)

+ func WithServiceID(id string) ServiceOption

+ func WithServiceInterceptor(i Interceptor) ServiceOption

+ func WithServiceNamespace(namespace string) ServiceOption

+ func WithServiceSingleGoroutine() ServiceOption

+ func WithServiceTimeout(timeout time.Duration) ServiceOption

+ type ServiceOptions struct

+ type ServiceRegistrar interface

+ Register func(sd ServiceDesc, svc any, opt ...ServiceOption) (ServiceInterface, error)