record

Documentation

Index

• type Data
• type Position
  • func (p Position) String() string
• type RawData
  • func (c RawData) Bytes() []byte
• type Record
• type StructuredData
  • func (c StructuredData) Bytes() []byte

Types

type Data

type Data interface {
	Bytes() []byte
}

Data ...

type Position

type Position []byte

Position is a unique identifier for a record being process. It's a Source's responsibility to choose and assign record positions, as they will be used by the Source in subsequent pipeline runs.

func (Position) String

func (p Position) String() string

String is used when displaying the position in logs.

type RawData

type RawData struct {
	Raw    []byte
	Schema schema.Schema
}

func (RawData) Bytes

func (c RawData) Bytes() []byte

type Record

type Record struct {
	Position Position
	Metadata map[string]string

	// SourceID contains the source connector ID.
	SourceID string

	// CreatedAt represents the time when the change occurred in the source system.
	// If that's impossible to find out, then it should be the time the change was detected by Conduit.
	CreatedAt time.Time
	// ReadAt represents the time at which Conduit read the record.
	ReadAt time.Time

	// Key and payload are guaranteed to be non-nil, always.
	// However, they may be 'empty', i.e. not contain any real data.
	Key     Data
	Payload Data
}

Record ...

type StructuredData

type StructuredData map[string]interface{}

func (StructuredData) Bytes

func (c StructuredData) Bytes() []byte