csv

Documentation

Index

• func New(provider *msg.Provider, bytes *buffer.Bytes) msg.Message
• type Message
  • func (m *Message) Begin()
  • func (m *Message) CompareAndSwap() bool
  • func (m *Message) End()
  • func (m *Message) Free()
  • func (m *Message) GetByteBuffer() *buffer.Bytes
  • func (m *Message) Put(bs []byte)
  • func (m *Message) PutB64EncodedBytes(key string, bytes []byte)
  • func (m *Message) PutBool(key string, value bool)
  • func (m *Message) PutBools(key string, values []bool)
  • func (m *Message) PutByte(b byte)
  • func (m *Message) PutFloat(key string, value float64)
  • func (m *Message) PutFloats(key string, values []float64)
  • func (m *Message) PutInt(key string, value int)
  • func (m *Message) PutInts(key string, values []int)
  • func (m *Message) PutNonEmptyString(key, value string)
  • func (m *Message) PutObject(key string, object io.Encoder)
  • func (m *Message) PutObjects(key string, objects []io.Encoder)
  • func (m *Message) PutString(key, value string)
  • func (m *Message) PutStrings(key string, values []string)
  • func (m *Message) PutUInts(key string, values []uint64)
  • func (m *Message) SetBorrowed()
  • func (m *Message) SetSliceDelimiter(delimiter string)
  • func (m *Message) UseQuotes(quote bool)
  • func (m *Message) WriteTo(w iow.Writer) (int64, error)

Functions

func New

func New(provider *msg.Provider, bytes *buffer.Bytes) msg.Message

Types

type Message

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

CsvMessage represents transaction CsvMessage

func (*Message) Begin

func (m *Message) Begin()

Begin begin CsvMessage

func (*Message) CompareAndSwap

func (m *Message) CompareAndSwap() bool

func (*Message) End

func (m *Message) End()

End end CsvMessage

func (*Message) Free

func (m *Message) Free()

Free returns bytes to the pool

func (*Message) GetByteBuffer

func (m *Message) GetByteBuffer() *buffer.Bytes

func (*Message) Put

func (m *Message) Put(bs []byte)

Put put bytes

func (*Message) PutB64EncodedBytes

func (m *Message) PutB64EncodedBytes(key string, bytes []byte)

PutB64EncodedBytes puts ky and bas64 encoded values

func (*Message) PutBool

func (m *Message) PutBool(key string, value bool)

PutBool put key and bool value

func (*Message) PutBools

func (m *Message) PutBools(key string, values []bool)

PutFloats put key and bool slice

func (*Message) PutByte

func (m *Message) PutByte(b byte)

PutByte put bytes

func (*Message) PutFloat

func (m *Message) PutFloat(key string, value float64)

PutFloat put key and float value

func (*Message) PutFloats

func (m *Message) PutFloats(key string, values []float64)

PutFloats put key and float slice

func (*Message) PutInt

func (m *Message) PutInt(key string, value int)

PutInt put key and int value

func (*Message) PutInts

func (m *Message) PutInts(key string, values []int)

PutInts puts key and int slice

func (*Message) PutNonEmptyString

func (m *Message) PutNonEmptyString(key, value string)

PutNonEmptyString put key and non empty value

func (*Message) PutObject

func (m *Message) PutObject(key string, object io.Encoder)

PutObject not supported for csv message

func (*Message) PutObjects

func (m *Message) PutObjects(key string, objects []io.Encoder)

PutObjects put objects

func (*Message) PutString

func (m *Message) PutString(key, value string)

PutString put key and string value

func (*Message) PutStrings

func (m *Message) PutStrings(key string, values []string)

PutStrings put key and string slice

func (*Message) PutUInts

func (m *Message) PutUInts(key string, values []uint64)

PutUInts put key and uint slice

func (*Message) SetBorrowed

func (m *Message) SetBorrowed()

func (*Message) SetSliceDelimiter

func (m *Message) SetSliceDelimiter(delimiter string)

SetDelimiter sets delimiter for csv slice

func (*Message) UseQuotes

func (m *Message) UseQuotes(quote bool)

UseQuotes applicable to only csv

func (*Message) WriteTo

func (m *Message) WriteTo(w iow.Writer) (int64, error)

WriteTo writes CsvMessage to the writer