codec

type Column ¶

type Column interface {
	ColumnName() string
	ColumnType() reflect.Type
	FieldName() string
}

Column is the reduced public column metadata contract.

type ColumnsSource ¶

type ColumnsSource interface {
	Column(key string) (Column, bool)
	ColumnName(key string) (string, error)
}

ColumnsSource is the reduced public column metadata ask surface.

type Config ¶

type Config struct {
	Body                 string
	SourceType           reflect.Type `json:"-" yaml:"-"`
	DestinationType      reflect.Type `json:"-" yaml:"-"`
	Args                 []string
	OutputTypeExpression string
}

Config describes the exact source and destination contract for a codec.

type Factory ¶

type Factory interface {
	New(codecConfig *Config, options ...Option) (Instance, error)
}

Factory creates codec instances from config plus options during registration.

type Instance ¶

type Instance interface {
	Value(ctx context.Context, raw interface{}, options ...Option) (interface{}, error)
}

Instance is the reduced public codec execution contract. Registered instances may be shared by concurrent invocations: Value must be concurrency-safe and must not retain invocation context, record pointers, or lookup options.

type Option ¶

type Option func(o *Options)

Option mutates codec options.

func WithColumnsSource(columnSource ColumnsSource) Option

func WithOptions(options ...interface{}) Option

func WithRecord(record interface{}) Option

func WithResourceFS(resources fs.FS) Option

func WithSelector(selector Selector) Option

func WithTypeLookup(fn func(name string) (reflect.Type, error)) Option

func WithValueGetter(valueGetter ValueGetter) Option

func WithValueLookup(fn func(ctx context.Context, name string) (interface{}, error)) Option

type Options ¶

type Options struct {
	LookupType  func(name string) (reflect.Type, error)
	Record      interface{}
	LookupValue func(ctx context.Context, name string) (interface{}, error)
	ResourceFS  fs.FS
	ColumnsSource
	Selector
	ValueGetter
	Options []interface{}
}

Options is the reduced public codec option bag.

It exists to support codec construction and execution only. It must not turn into a general-purpose runtime dependency transport for unrelated services.

func NewOptions(opts []Option) *Options

func (o *Options) Apply(opts []Option)

type Selector ¶

type Selector interface {
	IgnoreRead()
}

Selector is the reduced public selector ask contract.

type ValueGetter ¶

type ValueGetter interface {
	Value(ctx context.Context, paramName string) (interface{}, error)
}

ValueGetter is the reduced public value lookup contract.