inmem

Documentation

Overview

Package inmem package implements the watermark progression using in mem store as the KV store.

Index

• func NewInMemWatch(ctx context.Context, pipelineName string, bucketName string, ...) (store.WatermarkKVWatcher, error)
• func NewKVInMemKVStore(ctx context.Context, pipelineName string, bucketName string) (store.WatermarkKVStorer, chan store.WatermarkKVEntry, error)

Functions

func NewInMemWatch

func NewInMemWatch(ctx context.Context, pipelineName string, bucketName string, kvEntryCh <-chan store.WatermarkKVEntry) (store.WatermarkKVWatcher, error)

NewInMemWatch returns inMemWatch which implements the WatermarkKVWatcher interface.

func NewKVInMemKVStore

func NewKVInMemKVStore(ctx context.Context, pipelineName string, bucketName string) (store.WatermarkKVStorer, chan store.WatermarkKVEntry, error)

NewKVInMemKVStore returns inMemStore.