store

Documentation

Index

• func JetStreamOTKVName(bucketName string) string
• func JetStreamProcessorKVName(bucketName string) string
• type WatermarkStore
  • func BuildInmemWatermarkStore(ctx context.Context, bucket string) (WatermarkStore, error)
  • func BuildJetStreamWatermarkStore(ctx context.Context, bucket string, client *jsclient.Client) (WatermarkStore, error)
  • func BuildNoOpWatermarkStore() (WatermarkStore, error)

Functions

func JetStreamOTKVName

func JetStreamOTKVName(bucketName string) string

func JetStreamProcessorKVName

func JetStreamProcessorKVName(bucketName string) string

Types

type WatermarkStore

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

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

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

func BuildJetStreamWatermarkStore

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

BuildJetStreamWatermarkStore returns a JetStream WatermarkStore instance

func BuildNoOpWatermarkStore

func BuildNoOpWatermarkStore() (WatermarkStore, error)

BuildNoOpWatermarkStore returns a NoOp WatermarkStore instance