store

package

v1.2.0-rc4 Latest Latest Go to latest Published: Apr 18, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func JetStreamOTKVName(bucketName string) string

func JetStreamProcessorKVName(bucketName string) string

type WatermarkStore interface {
	io.Closer
	HeartbeatStore() kvs.KVStorer
	OffsetTimelineStore() kvs.KVStorer
}

WatermarkStore defines a pair of heartbeat KV store and offset timeline KV store

func BuildInmemWatermarkStore(ctx context.Context, bucket string) (WatermarkStore, error)

BuildInmemWatermarkStore returns an in-mem WatermarkStore instance, and the HB, OT entry channels

func BuildJetStreamWatermarkStore(ctx context.Context, bucket string, client *jsclient.Client) (WatermarkStore, error)

BuildJetStreamWatermarkStore returns a JetStream WatermarkStore instance

func BuildNoOpWatermarkStore() (WatermarkStore, error)

BuildNoOpWatermarkStore returns a NoOp WatermarkStore instance