rpclog

Documentation

Index

• type Logger
  • func New(in io.Writer, out io.Writer) *Logger
  • func (l *Logger) Log(ctx context.Context, uuid, method string, st time.Time, inType string, ...)
• type Reader
  • func NewReader(a io.Reader) *Reader
  • func (r *Reader) Stream() <-chan *pb.Entry

Types

type Logger

type Logger struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New(in io.Writer, out io.Writer) *Logger

func (*Logger) Log

func (l *Logger) Log(ctx context.Context, uuid, method string, st time.Time,
	inType string, in proto.Message,
	outErr error, outType string, out proto.Message)

type Reader

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

func NewReader

func NewReader(a io.Reader) *Reader

func (*Reader) Stream

func (r *Reader) Stream() <-chan *pb.Entry