materialise

Documentation

Index

• Variables
• func NewBatchUpsert[T any](configurations ...runtime.Configuration[*BatchUpsert[T]]) stateless.BatchFunction
• func WithBatchUpsertMapFunction[T any](mapper MapFunction[structure.Bytes, structure.Bytes, T]) runtime.Configuration[*BatchUpsert[T]]
• func WithBatchUpsertRepository[T any](repository UpsertRepository[T]) runtime.Configuration[*BatchUpsert[T]]
• type BatchUpsert
  • func (r *BatchUpsert[T]) Apply(c context.Context, ms []flow.Message[structure.Bytes, structure.Bytes]) ([]flow.Message[structure.Bytes, structure.Bytes], error)
• type MapFunction
  • func ConvertOneToOne[IK any, IV any, T any](source MapFunction[IK, IV, T], ik format.Format[IK], iv format.Format[IV]) MapFunction[structure.Bytes, structure.Bytes, T]
• type UpsertRepository

Variables

var ErrorUpsertMapper = errors.New("upsert mapper")

var ErrorUpsertRepository = errors.New("upsert repository")

Functions

func NewBatchUpsert

func NewBatchUpsert[T any](configurations ...runtime.Configuration[*BatchUpsert[T]]) stateless.BatchFunction

constructor

func WithBatchUpsertMapFunction

func WithBatchUpsertMapFunction[T any](mapper MapFunction[structure.Bytes, structure.Bytes, T]) runtime.Configuration[*BatchUpsert[T]]

func WithBatchUpsertRepository

func WithBatchUpsertRepository[T any](repository UpsertRepository[T]) runtime.Configuration[*BatchUpsert[T]]

configuration

Types

type BatchUpsert

type BatchUpsert[T any] struct {
	// contains filtered or unexported fields
}

func (*BatchUpsert[T]) Apply

func (r *BatchUpsert[T]) Apply(c context.Context, ms []flow.Message[structure.Bytes, structure.Bytes]) ([]flow.Message[structure.Bytes, structure.Bytes], error)

type MapFunction

type MapFunction[K any, V any, T any] func(context.Context, flow.Message[K, V]) ([]T, error)

func ConvertOneToOne

func ConvertOneToOne[IK any, IV any, T any](
	source MapFunction[IK, IV, T],
	ik format.Format[IK],
	iv format.Format[IV],
) MapFunction[structure.Bytes, structure.Bytes, T]

type UpsertRepository

type UpsertRepository[T any] interface {
	Upsert(context.Context, []T) error
}