kv

Documentation

Index

• func CreateOrBindKVBucket(handle *events.NatsJetstream, bucketName string, opts ...Option) (nats.KeyValue, error)
• func DefaultKVConfig(bucketName string) *nats.KeyValueConfig
• type Option
  • func WithDescription(desc string) Option
  • func WithReplicas(replicas int) Option
  • func WithStorageType(st nats.StorageType) Option
  • func WithTTL(d time.Duration) Option

Functions

func CreateOrBindKVBucket

func CreateOrBindKVBucket(handle *events.NatsJetstream, bucketName string,
	opts ...Option) (nats.KeyValue, error)

func DefaultKVConfig

func DefaultKVConfig(bucketName string) *nats.KeyValueConfig

DefaultKVConfig returns a configuration with "mostly sane" defaults. Override with the following Option functions

Types

type Option

type Option func(c *nats.KeyValueConfig)

func WithDescription

func WithDescription(desc string) Option

func WithReplicas

func WithReplicas(replicas int) Option

func WithStorageType

func WithStorageType(st nats.StorageType) Option

XXX: Not really sure we'd ever change this but...

func WithTTL

func WithTTL(d time.Duration) Option