nats

Documentation

Index

• 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
  • 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
  • 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
  • func (d *DotNats) Publish(subject, message string) error
  • func (d *DotNats) Subscribe(subject string) (<-chan *nats.Msg, error)
• type DotNatsProvider
  • 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)

Functions

func WithConn

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

func WithConnOptions

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

func WithConnUrl

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

func WithKV

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

func WithKVUrl

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

Types

type DotKV

type DotKV struct {
	// contains filtered or unexported fields
}

func (*DotKV) Delete

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

func (*DotKV) Get

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

func (*DotKV) Purge

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

func (*DotKV) Put

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

func (*DotKV) Watch

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

type DotKVProvider

type DotKVProvider struct {
	KV jetstream.KeyValue
	// contains filtered or unexported fields
}

func (DotKVProvider) New

func (DotKVProvider) New() xtemplate.DotProvider

func (DotKVProvider) Type

func (DotKVProvider) Type() string

func (*DotKVProvider) UnmarshalJSON

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

func (*DotKVProvider) UnmarshalText

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

func (*DotKVProvider) Value

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

type DotNats

type DotNats struct {
	// contains filtered or unexported fields
}

func (*DotNats) Publish

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

func (*DotNats) Subscribe

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

type DotNatsProvider

type DotNatsProvider struct {
	Conn *nats.Conn
	// contains filtered or unexported fields
}

func (DotNatsProvider) New

func (DotNatsProvider) New() xtemplate.DotProvider

func (DotNatsProvider) Type

func (DotNatsProvider) Type() string

func (*DotNatsProvider) UnmarshalJSON

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

func (*DotNatsProvider) UnmarshalText

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

func (*DotNatsProvider) Value

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