creator

Documentation

Index

• type Creator
  • func New() *Creator
  • func (c *Creator) NewMessage() Message
• type Message
  • func FromBytes(data []byte) (Message, error)
  • func (m Message) Bytes() ([]byte, error)
  • func (m Message) String() string

Types

type Creator

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

func New

func New() *Creator

func (*Creator) NewMessage

func (c *Creator) NewMessage() Message

type Message

type Message struct {
	Sequence    uint64
	ID          string
	CreatedTime time.Time
	Data        []byte
}

Message format for kafka message

func FromBytes

func FromBytes(data []byte) (Message, error)

FromBytes DeSerializes the bytes data to a message via gob decoder

func (Message) Bytes

func (m Message) Bytes() ([]byte, error)

Bytes Serializes the message via gob encoder

func (Message) String

func (m Message) String() string