model

Documentation

Index

• type DefaultMessage
  • func (m DefaultMessage) Get(key string) (value any, ok bool)
  • func (m DefaultMessage) Range(f func(key string, value any) bool)
  • func (m DefaultMessage) ToMap() map[string]any
• type DefaultSourceTuple
  • func NewDefaultRawTuple(raw []byte, meta api.ReadonlyMessage, ts time.Time) *DefaultSourceTuple
  • func NewDefaultSourceTuple(message api.ReadonlyMessage, meta api.ReadonlyMessage, timestamp time.Time) *DefaultSourceTuple
  • func (t *DefaultSourceTuple) Message() api.ReadonlyMessage
  • func (t *DefaultSourceTuple) Meta() api.ReadonlyMessage
  • func (t *DefaultSourceTuple) Raw() []byte
  • func (t *DefaultSourceTuple) Timestamp() time.Time
• type StreamWriter

Types

type DefaultMessage

type DefaultMessage map[string]interface{}

DefaultMessage is a valuer that substitutes values for the mapped interface. It is the basic type for data events.

func (DefaultMessage) Get

func (m DefaultMessage) Get(key string) (value any, ok bool)

func (DefaultMessage) Range

func (m DefaultMessage) Range(f func(key string, value any) bool)

func (DefaultMessage) ToMap

func (m DefaultMessage) ToMap() map[string]any

type DefaultSourceTuple

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

func NewDefaultRawTuple

func NewDefaultRawTuple(raw []byte, meta api.ReadonlyMessage, ts time.Time) *DefaultSourceTuple

NewDefaultRawTuple creates a new DefaultSourceTuple with raw data. Use this when extend source connector

func NewDefaultSourceTuple

func NewDefaultSourceTuple(message api.ReadonlyMessage, meta api.ReadonlyMessage, timestamp time.Time) *DefaultSourceTuple

func (*DefaultSourceTuple) Message

func (t *DefaultSourceTuple) Message() api.ReadonlyMessage

func (*DefaultSourceTuple) Meta

func (t *DefaultSourceTuple) Meta() api.ReadonlyMessage

func (*DefaultSourceTuple) Raw

func (t *DefaultSourceTuple) Raw() []byte

func (*DefaultSourceTuple) Timestamp

func (t *DefaultSourceTuple) Timestamp() time.Time

type StreamWriter

type StreamWriter interface {
	CreateWriter(ctx api.StreamContext, currWriter io.Writer, compression string, encryption string) (io.Writer, error)
}