common

Documentation

Index

• func EnsureBuckets(js nats.JetStreamContext, storageType nats.StorageType, names []string) error
• func Load(wf nats.KeyValue, k string) ([]byte, error)
• func LoadObj(wf nats.KeyValue, k string, v proto.Message) error
• func Save(wf nats.KeyValue, k string, v []byte) error
• func SaveObj(ctx context.Context, wf nats.KeyValue, k string, v proto.Message) error
• func UpdateKV(wf nats.KeyValue, k string, msg proto.Message, ...) error
• func UpdateObj[T proto.Message](wf nats.KeyValue, k string, msg T, updateFn func(v T) (T, error)) error
• type NatsConn

Functions

func EnsureBuckets

func EnsureBuckets(js nats.JetStreamContext, storageType nats.StorageType, names []string) error

func Load

func Load(wf nats.KeyValue, k string) ([]byte, error)

func LoadObj

func LoadObj(wf nats.KeyValue, k string, v proto.Message) error

func Save

func Save(wf nats.KeyValue, k string, v []byte) error

func SaveObj

func SaveObj(ctx context.Context, wf nats.KeyValue, k string, v proto.Message) error

func UpdateKV

func UpdateKV(wf nats.KeyValue, k string, msg proto.Message, updateFn func(v []byte, msg proto.Message) ([]byte, error)) error

func UpdateObj

func UpdateObj[T proto.Message](wf nats.KeyValue, k string, msg T, updateFn func(v T) (T, error)) error

Types

type NatsConn

type NatsConn interface {
	JetStream(opts ...nats.JSOpt) (nats.JetStreamContext, error)
	Subscribe(subject string, fn nats.MsgHandler) (*nats.Subscription, error)
}