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

rpc

package

Go to main page

Versions in this module

v0

v0.1.25

Jan 22, 2024

v0.1.24

Jan 22, 2024

v0.1.23

Jan 22, 2024

v0.1.22

Jan 22, 2024

v0.1.21

Jan 19, 2024

v0.1.20

Jan 13, 2024

Changes in this version

+ var ErrMethodResultCountMismatch = errors.New("rpc: method result count mismatch")

+ var ErrMethodResultTypeMismatch = errors.New("rpc: method result type mismatch")

+ func Result10[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, error)

+ func Result11[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, error)

+ func Result12[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, error)

+ func Result13[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, error)

+ func Result14[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, error)

+ func Result15[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, error)

+ func Result16[T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, error)

+ func Result1[T1 any](ret runtime.Ret) (T1, error)

+ func Result2[T1, T2 any](ret runtime.Ret) (T1, T2, error)

+ func Result3[T1, T2, T3 any](ret runtime.Ret) (T1, T2, T3, error)

+ func Result4[T1, T2, T3, T4 any](ret runtime.Ret) (T1, T2, T3, T4, error)

+ func Result5[T1, T2, T3, T4, T5 any](ret runtime.Ret) (T1, T2, T3, T4, T5, error)

+ func Result6[T1, T2, T3, T4, T5, T6 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, error)

+ func Result7[T1, T2, T3, T4, T5, T6, T7 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, error)

+ func Result8[T1, T2, T3, T4, T5, T6, T7, T8 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, error)

+ func Result9[T1, T2, T3, T4, T5, T6, T7, T8, T9 any](ret runtime.Ret) (T1, T2, T3, T4, T5, T6, T7, T8, T9, error)

+ func ResultVoid(ret runtime.Ret) error

v0.1.19

Jan 13, 2024

Changes in this version

+ var ErrComponentNotFound = errors.New("rpc: component not found")

+ var ErrMethodNotFound = errors.New("rpc: method not found")

+ var ErrMethodParameterCountMismatch = errors.New("rpc: method parameter count mismatch")

+ var ErrMethodParameterTypeMismatch = errors.New("rpc: method parameter type mismatch")

+ var ErrNoDeliverer = errors.New("rpc: no deliverer")

+ var ErrPluginNotFound = errors.New("rpc: plugin not found")

+ var Install = plugin.Install

+ var Name = plugin.Name

+ var Uninstall = plugin.Uninstall

+ var Using = plugin.Using

+ func OneWayRPC(servCtx service.Context, dst, path string, args ...any) error

+ func RPC(servCtx service.Context, dst, path string, args ...any) runtime.AsyncRet

+ func Result(ret runtime.Ret) (any, error)

+ func Results(ret runtime.Ret) ([]any, error)

+ type DistributedDeliverer struct

+ func (d *DistributedDeliverer) Init(ctx service.Context)

+ func (d *DistributedDeliverer) Match(ctx service.Context, dst, path string, oneWay bool) bool

+ func (d *DistributedDeliverer) Notify(ctx service.Context, dst, path string, args []any) error

+ func (d *DistributedDeliverer) Request(ctx service.Context, dst, path string, args []any) runtime.AsyncRet

+ func (d *DistributedDeliverer) Shut(ctx service.Context)

+ type DistributedDispatcher struct

+ func (d *DistributedDispatcher) Init(ctx service.Context)

+ func (d *DistributedDispatcher) Shut(ctx service.Context)

+ type IDeliverer interface

+ Match func(ctx service.Context, dst, path string, oneWay bool) bool

+ Notify func(ctx service.Context, dst, path string, args []any) error

+ Request func(ctx service.Context, dst, path string, args []any) runtime.AsyncRet

+ type IDispatcher any

+ type IRPC interface

+ OneWayRPC func(dst, path string, args ...any) error

+ RPC func(dst, path string, args ...any) runtime.AsyncRet

+ type LifecycleInit interface

+ Init func(ctx service.Context)

+ type LifecycleShut interface

+ Shut func(ctx service.Context)

+ type Option struct

+ func (Option) Default() option.Setting[RPCOptions]

+ func (Option) Deliverers(deliverers ...IDeliverer) option.Setting[RPCOptions]

+ func (Option) Dispatchers(dispatchers ...IDispatcher) option.Setting[RPCOptions]

+ type RPCOptions struct

+ Deliverers []IDeliverer

+ Dispatchers []IDispatcher