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

stormrpc

package module

Go to main page

Versions in this module

v0

v0.4.2

Jun 24, 2024

v0.4.1

Apr 14, 2024

Changes in this version

+ type Option interface

+ func WithNatsConn(nc *nats.Conn) Option

v0.4.0

Dec 7, 2023

Changes in this version

+ type ServerConfig struct

+ Name string

+ NatsURL string

+ Version string

v0.3.1

Oct 10, 2022

v0.3.0

Oct 3, 2022

Changes in this version

type ErrorCode

+ const ErrorCodeDeadlineExceeded

v0.2.0

Aug 4, 2022

Changes in this version

+ func HeadersFromContext(ctx context.Context) nats.Header

+ type CallOption interface

+ func WithHeaders(h map[string]string) CallOption

type ErrorCode

+ const ErrorCodeAlreadyExists

+ const ErrorCodeInvalidArgument

+ const ErrorCodePermissionDenied

+ const ErrorCodeUnauthenticated

+ const ErrorCodeUnimplemented

+ type HeaderCallOption struct

+ Headers map[string]string

v0.1.0

Jul 1, 2022

Changes in this version

+ func MessageFromErr(err error) string

+ type Client struct

+ func NewClient(natsURL string, opts ...ClientOption) (*Client, error)

+ func (c *Client) Close()

+ func (c *Client) Do(ctx context.Context, r Request) Response

+ type ClientOption interface

+ type Error struct

+ Code ErrorCode

+ Message string

+ func Errorf(code ErrorCode, format string, args ...any) *Error

+ func (e Error) Error() string

+ type ErrorCode int

+ const ErrorCodeInternal

+ const ErrorCodeNotFound

+ const ErrorCodeUnknown

+ func CodeFromErr(err error) ErrorCode

+ func (c ErrorCode) String() string

+ type ErrorHandler func(context.Context, error)

+ type HandlerFunc func(ctx context.Context, r Request) Response

+ type Middleware func(next HandlerFunc) HandlerFunc

+ type Request struct

+ func NewRequest(subject string, body any, opts ...RequestOption) (Request, error)

+ func (r *Request) Decode(v any) error

+ func (r *Request) Subject() string

+ type RequestOption interface

+ func WithEncodeMsgpack() RequestOption

+ func WithEncodeProto() RequestOption

+ type Response struct

+ Err error

+ func NewErrorResponse(reply string, err error) Response

+ func NewResponse(reply string, body any, opts ...ResponseOption) (Response, error)

+ func (r *Response) Decode(v any) error

+ type ResponseOption RequestOption

+ type Server struct

+ func NewServer(name, natsURL string, opts ...ServerOption) (*Server, error)

+ func (s *Server) Handle(subject string, fn HandlerFunc)

+ func (s *Server) Run() error

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

+ func (s *Server) Subjects() []string

+ func (s *Server) Use(mw ...Middleware)

+ type ServerOption interface

+ func WithErrorHandler(fn ErrorHandler) ServerOption