context

Documentation

Index

• func FromRecord(parent context.Context, record *data.Record) context.Context
• func RecordFromContext(ctx context.Context, key []byte, val []byte) (*data.Record, error)
• type Context
• type RecordMeta
  • func Meta(ctx context.Context) *RecordMeta

Functions

func FromRecord

func FromRecord(parent context.Context, record *data.Record) context.Context

func RecordFromContext

func RecordFromContext(ctx context.Context, key []byte, val []byte) (*data.Record, error)

Types

type Context

type Context struct {
	context.Context
}

type RecordMeta

type RecordMeta struct {
	Topic     string
	Partition int32
	Offset    int64
	Timestamp time.Time
	Headers   data.RecordHeaders
}

func Meta

func Meta(ctx context.Context) *RecordMeta