meteredrwc

Documentation

Index

• func New(rwc io.ReadWriteCloser, syncBytes *uint64) io.ReadWriteCloser
• type MRWC
  • func (mRWC *MRWC) Close() error
  • func (mRWC *MRWC) Read(p []byte) (n int, err error)
  • func (mRWC *MRWC) Write(p []byte) (n int, err error)

Functions

func New

func New(rwc io.ReadWriteCloser, syncBytes *uint64) io.ReadWriteCloser

Types

type MRWC

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

*

Updates:
- synced *uint64 + internal int on read
- prometheus telemetry (duration + bytes) on close [ToDo]

*

func (*MRWC) Close

func (mRWC *MRWC) Close() error

func (*MRWC) Read

func (mRWC *MRWC) Read(p []byte) (n int, err error)

func (*MRWC) Write

func (mRWC *MRWC) Write(p []byte) (n int, err error)