message

Documentation

Index

• Variables
• type FieldType
  • func TypeByString(t string) FieldType
  • func (t FieldType) Cast(v any) any
  • func (t FieldType) CastExt(v any, length int, format string) any
  • func (t FieldType) String() string
• type Formater
• type MapMessage
  • func MapMessageDecode(data []byte, converter unmarshalel) (msg MapMessage, err error)
  • func (m MapMessage) Get(name string) (any, error)
  • func (m MapMessage) Item(key string, def any) any
  • func (m MapMessage) ItemCast(key string, fieldType FieldType, length int, format string) any
  • func (m MapMessage) JSON() string
  • func (m MapMessage) Map() map[string]any
  • func (m MapMessage) Str(key, def string) string
• type Message

Variables

var (
	ErrUndefinedDataType       = errors.New("undefined message data types")
	ErrInvalidMessageFieldType = errors.New("invalid message field type")
	ErrFieldNotFound           = errors.New("field not found")
)

Errors set

Types

type FieldType

type FieldType int

FieldType of data represents scalar types supported by eventstream message processing

const (
	FieldTypeString FieldType = iota
	FieldTypeFixed
	FieldTypeUUID
	FieldTypeInt
	FieldTypeInt8
	FieldTypeInt32
	FieldTypeInt64
	FieldTypeUint
	FieldTypeUint8
	FieldTypeUint32
	FieldTypeUint64
	FieldTypeFloat
	FieldTypeBoolean
	FieldTypeIP
	FieldTypeDate
	FieldTypeUnixnano
	FieldTypeArrayInt32
	FieldTypeArrayInt64
)

Field scalar types enum

func TypeByString

func TypeByString(t string) FieldType

TypeByString name

func (FieldType) Cast

func (t FieldType) Cast(v any) any

Cast value into the fieldType

func (FieldType) CastExt

func (t FieldType) CastExt(v any, length int, format string) any

CastExt with additional conditions

func (FieldType) String

func (t FieldType) String() string

String implementaion of fmt.Stringer

type Formater

type Formater interface {
	Format(msg Message) (any, error)
}

Formater processor

type MapMessage

type MapMessage map[string]any

Map object

func MapMessageDecode

func MapMessageDecode(data []byte, converter unmarshalel) (msg MapMessage, err error)

MessageDecode from bytes

func (MapMessage) Get

func (m MapMessage) Get(name string) (any, error)

Get returns the value by key name

func (MapMessage) Item

func (m MapMessage) Item(key string, def any) any

Item returns the value by key name or default

func (MapMessage) ItemCast

func (m MapMessage) ItemCast(key string, fieldType FieldType, length int, format string) any

ItemCast converts any key value into the field_type

func (MapMessage) JSON

func (m MapMessage) JSON() string

JSON data string

func (MapMessage) Map

func (m MapMessage) Map() map[string]any

Map returns the message as map[string]any

func (MapMessage) Str

func (m MapMessage) Str(key, def string) string

Str returns the string value by key name or default

type Message

type Message interface {
	Get(name string) (any, error)
	Item(key string, def any) any
	ItemCast(key string, fieldType FieldType, length int, format string) any
	Str(key, def string) string
	JSON() string
	Map() map[string]any
}

Message interface TODO: refactor this interface

var EmptyMessage Message = (*dummyMessage)(nil)