vsrpclog

Documentation

Index

• type Observer
  • func (o Observer) GetLogger() *zerolog.Logger
  • func (o Observer) OnAccept(conn *vsrpc.Conn)
  • func (o Observer) OnAcceptError(err error)
  • func (o Observer) OnBegin(call *vsrpc.Call)
  • func (o Observer) OnCancel(call *vsrpc.Call)
  • func (o Observer) OnClose(conn *vsrpc.Conn, err error)
  • func (o Observer) OnDial(conn *vsrpc.Conn)
  • func (o Observer) OnDialError(err error)
  • func (o Observer) OnEnd(call *vsrpc.Call, status *vsrpc.Status)
  • func (o Observer) OnGlobalClose()
  • func (o Observer) OnGlobalShutdown()
  • func (o Observer) OnGoAway(conn *vsrpc.Conn)
  • func (o Observer) OnHalfClose(call *vsrpc.Call)
  • func (o Observer) OnReadError(conn *vsrpc.Conn, err error)
  • func (o Observer) OnRequest(call *vsrpc.Call, payload *anypb.Any)
  • func (o Observer) OnResponse(call *vsrpc.Call, payload *anypb.Any)
  • func (o Observer) OnShutdown(conn *vsrpc.Conn)
  • func (o Observer) OnWriteError(conn *vsrpc.Conn, err error)

Types

type Observer

type Observer struct {
	Logger *zerolog.Logger
}

func (Observer) GetLogger

func (o Observer) GetLogger() *zerolog.Logger

func (Observer) OnAccept

func (o Observer) OnAccept(conn *vsrpc.Conn)

func (Observer) OnAcceptError

func (o Observer) OnAcceptError(err error)

func (Observer) OnBegin

func (o Observer) OnBegin(call *vsrpc.Call)

func (Observer) OnCancel

func (o Observer) OnCancel(call *vsrpc.Call)

func (Observer) OnClose

func (o Observer) OnClose(conn *vsrpc.Conn, err error)

func (Observer) OnDial

func (o Observer) OnDial(conn *vsrpc.Conn)

func (Observer) OnDialError

func (o Observer) OnDialError(err error)

func (Observer) OnEnd

func (o Observer) OnEnd(call *vsrpc.Call, status *vsrpc.Status)

func (Observer) OnGlobalClose

func (o Observer) OnGlobalClose()

func (Observer) OnGlobalShutdown

func (o Observer) OnGlobalShutdown()

func (Observer) OnGoAway

func (o Observer) OnGoAway(conn *vsrpc.Conn)

func (Observer) OnHalfClose

func (o Observer) OnHalfClose(call *vsrpc.Call)

func (Observer) OnReadError

func (o Observer) OnReadError(conn *vsrpc.Conn, err error)

func (Observer) OnRequest

func (o Observer) OnRequest(call *vsrpc.Call, payload *anypb.Any)

func (Observer) OnResponse

func (o Observer) OnResponse(call *vsrpc.Call, payload *anypb.Any)

func (Observer) OnShutdown

func (o Observer) OnShutdown(conn *vsrpc.Conn)

func (Observer) OnWriteError

func (o Observer) OnWriteError(conn *vsrpc.Conn, err error)