client

Documentation

Index

• func Call[Req any, Resp any](client *UnixRPC, method string, data Req) (Resp, error)
• type TestTracer
  • func (self *TestTracer) Info(msg string)
  • func (self *TestTracer) Infof(msg string, args ...any)
  • func (self *TestTracer) Log(level tracer.TracerLevel, msg string)
  • func (self *TestTracer) Logf(level tracer.TracerLevel, msg string, args ...any)
  • func (self *TestTracer) Trace(msg string)
  • func (self *TestTracer) Tracef(msg string, args ...any)
• type UnixRPC
  • func NewUnix(path string) (*UnixRPC, error)
  • func (self *UnixRPC) SetEncoder(encoder encoder.JSONEncoder)
  • func (self *UnixRPC) SetTracer(tracer tracer.Tracer)

Functions

func Call

func Call[Req any, Resp any](client *UnixRPC, method string, data Req) (Resp, error)

Call invoke a JSON RPC 2.0 method call by choosing a random id from 0 to 10000

Types

type TestTracer

type TestTracer struct{}

func (*TestTracer) Info

func (self *TestTracer) Info(msg string)

func (*TestTracer) Infof

func (self *TestTracer) Infof(msg string, args ...any)

func (*TestTracer) Log

func (self *TestTracer) Log(level tracer.TracerLevel, msg string)

func (*TestTracer) Logf

func (self *TestTracer) Logf(level tracer.TracerLevel, msg string, args ...any)

func (*TestTracer) Trace

func (self *TestTracer) Trace(msg string)

func (*TestTracer) Tracef

func (self *TestTracer) Tracef(msg string, args ...any)

type UnixRPC

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

func NewUnix

func NewUnix(path string) (*UnixRPC, error)

NewUnixRPC creates a new UnixRPC instance.

func (*UnixRPC) SetEncoder

func (self *UnixRPC) SetEncoder(encoder encoder.JSONEncoder)

func (*UnixRPC) SetTracer

func (self *UnixRPC) SetTracer(tracer tracer.Tracer)