materialise

Documentation

Index

• Variables
• func NewSingleUpsert[T any](configurations ...runtime.Configuration[*SingleUpsert[T]]) stateless.SingleFunction
• func WithSingleUpsertMapFunction[T any](mapper MapFunction[message.Bytes, message.Bytes, T]) runtime.Configuration[*SingleUpsert[T]]
• func WithSingleUpsertRepository[T any](repository UpsertRepository[T]) runtime.Configuration[*SingleUpsert[T]]
• type BatchUpsert
  • func (r *BatchUpsert[T]) Apply(c context.Context, ms []message.Message[message.Bytes, message.Bytes]) ([]message.Message[message.Bytes, message.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[message.Bytes, message.Bytes, T]
• type SingleUpsert
  • func (r *SingleUpsert[T]) Apply(c context.Context, m message.Message[message.Bytes, message.Bytes]) ([]message.Message[message.Bytes, message.Bytes], error)
• type UpsertRepository

Variables

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

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

Functions

func NewSingleUpsert

func NewSingleUpsert[T any](configurations ...runtime.Configuration[*SingleUpsert[T]]) stateless.SingleFunction

constructor

func WithSingleUpsertMapFunction

func WithSingleUpsertMapFunction[T any](mapper MapFunction[message.Bytes, message.Bytes, T]) runtime.Configuration[*SingleUpsert[T]]

func WithSingleUpsertRepository

func WithSingleUpsertRepository[T any](repository UpsertRepository[T]) runtime.Configuration[*SingleUpsert[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 []message.Message[message.Bytes, message.Bytes]) ([]message.Message[message.Bytes, message.Bytes], error)

type MapFunction

type MapFunction[K any, V any, T any] func(context.Context, message.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[message.Bytes, message.Bytes, T]

type SingleUpsert

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

implementation

func (*SingleUpsert[T]) Apply

func (r *SingleUpsert[T]) Apply(c context.Context, m message.Message[message.Bytes, message.Bytes]) ([]message.Message[message.Bytes, message.Bytes], error)

type UpsertRepository

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