nats

Apr 9, 2024

Changes in this version

type DotNats

+ func (d *DotNats) Request(subject, data string, timeout_ ...time.Duration) (*nats.Msg, error)

Apr 7, 2024

Changes in this version

+ func WithConn(name string, conn *nats.Conn) xtemplate.Option

+ func WithConnOptions(name string, options *nats.Options) xtemplate.Option

+ func WithConnUrl(name string, url string, opts ...nats.Option) xtemplate.Option

+ func WithKV(name string, kv jetstream.KeyValue) xtemplate.Option

+ func WithKVUrl(name, bucket, url string, opts ...nats.Option) xtemplate.Option

+ type DotKV struct

+ func (d *DotKV) Delete(key string) error

+ func (d *DotKV) Get(key string) (string, error)

+ func (d *DotKV) Purge(key string) error

+ func (d *DotKV) Put(key, value string) error

+ func (d *DotKV) Watch(keys string) (<-chan jetstream.KeyValueEntry, error)

+ type DotKVProvider struct

+ KV jetstream.KeyValue

+ func (DotKVProvider) New() xtemplate.DotProvider

+ func (DotKVProvider) Type() string

+ func (d *DotKVProvider) UnmarshalJSON(b []byte) error

+ func (d *DotKVProvider) UnmarshalText(b []byte) error

+ func (d *DotKVProvider) Value(r xtemplate.Request) (any, error)

+ type DotNats struct

+ func (d *DotNats) Publish(subject, message string) error

+ func (d *DotNats) Subscribe(subject string) (<-chan *nats.Msg, error)

+ type DotNatsProvider struct

+ Conn *nats.Conn

+ func (DotNatsProvider) New() xtemplate.DotProvider

+ func (DotNatsProvider) Type() string

+ func (d *DotNatsProvider) UnmarshalJSON(b []byte) error

+ func (d *DotNatsProvider) UnmarshalText(b []byte) error

+ func (d *DotNatsProvider) Value(r xtemplate.Request) (any, error)