nats

Documentation

Index

• Variables
• type BrokerOption
• type BrokerOptions
• type WithOption
  • func (WithOption) Default() BrokerOption
  • func (WithOption) FastAddresses(addrs ...string) BrokerOption
  • func (WithOption) FastAuth(username, password string) BrokerOption
  • func (WithOption) NatsClient(cli *nats.Conn) BrokerOption
  • func (WithOption) QueuePrefix(prefix string) BrokerOption
  • func (WithOption) TopicPrefix(prefix string) BrokerOption

Variables

var Install = definePlugin.Install

Install 安装插件

var Uninstall = definePlugin.Uninstall

Uninstall 卸载插件

Types

type BrokerOption

type BrokerOption func(options *BrokerOptions)

type BrokerOptions

type BrokerOptions struct {
	NatsClient    *nats.Conn
	TopicPrefix   string
	QueuePrefix   string
	FastAddresses []string
	FastUsername  string
	FastPassword  string
}

type WithOption

type WithOption struct{}

func (WithOption) Default

func (WithOption) Default() BrokerOption

func (WithOption) FastAddresses

func (WithOption) FastAddresses(addrs ...string) BrokerOption

func (WithOption) FastAuth

func (WithOption) FastAuth(username, password string) BrokerOption

func (WithOption) NatsClient

func (WithOption) NatsClient(cli *nats.Conn) BrokerOption

func (WithOption) QueuePrefix

func (WithOption) QueuePrefix(prefix string) BrokerOption

func (WithOption) TopicPrefix

func (WithOption) TopicPrefix(prefix string) BrokerOption