nanoMsgOutput

Documentation

Index

• type NanoMsgOutput
  • func NewNanoMsgOutput(url *string, proto Protocol) (nano *NanoMsgOutput, err error)
  • func (this *NanoMsgOutput) Close()
  • func (this *NanoMsgOutput) Connect(url string) (err error)
  • func (this *NanoMsgOutput) SendJson(eStat *ExtendedIoStats) (err error)
  • func (this *NanoMsgOutput) SendProtoBuffers(eStat *ExtendedIoStats) (err error)
  • func (this *NanoMsgOutput) SendStats(eStat *ExtendedIoStats) (err error)

Types

type NanoMsgOutput

type NanoMsgOutput struct {
}

func NewNanoMsgOutput

func NewNanoMsgOutput(url *string, proto Protocol) (nano *NanoMsgOutput, err error)

func (*NanoMsgOutput) Close

func (this *NanoMsgOutput) Close()

Close the socket

func (*NanoMsgOutput) Connect

func (this *NanoMsgOutput) Connect(url string) (err error)

Method to connect to queue

func (*NanoMsgOutput) SendJson

func (this *NanoMsgOutput) SendJson(eStat *ExtendedIoStats) (err error)

Send stats in json format

func (*NanoMsgOutput) SendProtoBuffers

func (this *NanoMsgOutput) SendProtoBuffers(eStat *ExtendedIoStats) (err error)

Send stats in protobuffer format

func (*NanoMsgOutput) SendStats

func (this *NanoMsgOutput) SendStats(eStat *ExtendedIoStats) (err error)

Send stats by given format