message

Documentation

Index

• type Message
  • func (m *Message) GetErrorCount() uint64
  • func (m *Message) GetId() string
  • func (m *Message) GetPrefix() (prefix string)
  • func (m *Message) GetRoutingKey() string
  • func (m *Message) GetValues() map[string]interface{}
  • func (m *Message) SetErrorCount(count uint64)
  • func (m *Message) SetErrorIncr()
  • func (m *Message) SetId(id string)
  • func (m *Message) SetPrefix(prefix string)
  • func (m *Message) SetRoutingKey(routingKey string)
  • func (m *Message) SetValues(values map[string]interface{})

Types

type Message

type Message struct {
	Id         string
	RoutingKey string
	Values     map[string]interface{}
	GroupId    string
	ErrorCount uint64
}

func (*Message) GetErrorCount

func (m *Message) GetErrorCount() uint64

func (*Message) GetId

func (m *Message) GetId() string

func (*Message) GetPrefix

func (m *Message) GetPrefix() (prefix string)

func (*Message) GetRoutingKey

func (m *Message) GetRoutingKey() string

func (*Message) GetValues

func (m *Message) GetValues() map[string]interface{}

func (*Message) SetErrorCount

func (m *Message) SetErrorCount(count uint64)

func (*Message) SetErrorIncr

func (m *Message) SetErrorIncr()

func (*Message) SetId

func (m *Message) SetId(id string)

func (*Message) SetPrefix

func (m *Message) SetPrefix(prefix string)

func (*Message) SetRoutingKey

func (m *Message) SetRoutingKey(routingKey string)

func (*Message) SetValues

func (m *Message) SetValues(values map[string]interface{})