rpc

Documentation

Index

• Constants
• func NewServer(ctx context.Context, rpcOpts ...RpcServerOptions) (err error)
• type BaseRpc
  • func (r *BaseRpc) Call(serviceMethod string, args any, reply any) (err error)
  • func (r *BaseRpc) Go(serviceMethod string, args any, reply any, done interface{}) interface{}
• type Message
• type Reply
• type RpcClientOptions
  • func WithClientAddress(address string) RpcClientOptions
  • func WithClientNetwork(network string) RpcClientOptions
  • func WithClientType(t connType) RpcClientOptions
• type RpcServerOptions
  • func WithServerAddress(address string) RpcServerOptions
  • func WithServerNetwork(network string) RpcServerOptions
  • func WithServerType(t connType) RpcServerOptions
• type Session
  • func NewClient(ctx context.Context, rpcOpts ...RpcClientOptions) (session Session, err error)

Constants

const (
	Base      connType = "Base"
	HTTP      connType = "Http"
	JSON_HTTP connType = "Json-Http"
)

Functions

func NewServer

func NewServer(ctx context.Context, rpcOpts ...RpcServerOptions) (err error)

Types

type BaseRpc

type BaseRpc struct {
	// contains filtered or unexported fields
}

func (*BaseRpc) Call

func (r *BaseRpc) Call(serviceMethod string, args any, reply any) (err error)

func (*BaseRpc) Go

func (r *BaseRpc) Go(serviceMethod string, args any, reply any, done interface{}) interface{}

type Message

type Message struct {
	Id     int    `json:"id"`
	Method string `json:"method"`
	Params []any  `json:"params"`
}

type Reply

type Reply struct {
	Id     int    `json:"id"`
	Result any    `json:"result"`
	Error  string `json:"error"`
}

type RpcClientOptions

type RpcClientOptions func(r *BaseRpc)

func WithClientAddress

func WithClientAddress(address string) RpcClientOptions

func WithClientNetwork

func WithClientNetwork(network string) RpcClientOptions

func WithClientType

func WithClientType(t connType) RpcClientOptions

type RpcServerOptions

type RpcServerOptions func(r *BaseRpc)

func WithServerAddress

func WithServerAddress(address string) RpcServerOptions

func WithServerNetwork

func WithServerNetwork(network string) RpcServerOptions

func WithServerType

func WithServerType(t connType) RpcServerOptions

type Session

type Session interface {
	Call(serviceMethod string, args any, reply any) error
	Go(serviceMethod string, args any, reply any, done interface{}) interface{}
}

func NewClient

func NewClient(ctx context.Context, rpcOpts ...RpcClientOptions) (session Session, err error)