client

Documentation

Index

• func CheckResourceTypeFilterString(s string) error
• type Client
  • func New(config Config, fileWatcher *fsnotify.Watcher, logger log.Logger) (*Client, error)
  • func (c *Client) AddCloseFunc(f func())
  • func (c *Client) Close()
  • func (c *Client) GetConn() *nats.Conn
• type Config
  • func (c *Config) Validate() error
• type ConfigPublisher
  • func (c *ConfigPublisher) Validate() error
• type ConfigSubscriber
• type LeadResourceTypeFilter
• type LeadResourceTypePublisherConfig
  • func (c *LeadResourceTypePublisherConfig) GetCompiledRegexFilter() []*regexp.Regexp
  • func (c *LeadResourceTypePublisherConfig) IsEnabled() bool
  • func (c *LeadResourceTypePublisherConfig) Validate() error
• type LeadResourceTypeSubscriberConfig
  • func (c *LeadResourceTypeSubscriberConfig) IsEnabled() bool
• type PendingLimitsConfig
  • func (c *PendingLimitsConfig) Validate() error

Functions

func CheckResourceTypeFilterString

func CheckResourceTypeFilterString(s string) error

Types

type Client

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

func New

func New(config Config, fileWatcher *fsnotify.Watcher, logger log.Logger) (*Client, error)

func (*Client) AddCloseFunc

func (c *Client) AddCloseFunc(f func())

func (*Client) Close

func (c *Client) Close()

func (*Client) GetConn

func (c *Client) GetConn() *nats.Conn

type Config

type Config struct {
	URL            string              `yaml:"url" json:"url"`
	FlusherTimeout time.Duration       `yaml:"flusherTimeout" json:"flusherTimeout"`
	PendingLimits  PendingLimitsConfig `yaml:"pendingLimits" json:"pendingLimits"`
	TLS            client.Config       `yaml:"tls" json:"tls"`
	Options        []nats.Option       `yaml:"-" json:"-"`
}

func (*Config) Validate

func (c *Config) Validate() error

type ConfigPublisher

type ConfigPublisher struct {
	Config           `yaml:",inline" json:",inline"`
	JetStream        bool                             `yaml:"jetstream" json:"jetstream"`
	LeadResourceType *LeadResourceTypePublisherConfig `yaml:"leadResourceType,omitempty" json:"leadResourceType,omitempty"`
}

func (*ConfigPublisher) Validate

func (c *ConfigPublisher) Validate() error

type ConfigSubscriber

type ConfigSubscriber struct {
	Config           `yaml:",inline" json:",inline"`
	LeadResourceType *LeadResourceTypeSubscriberConfig `yaml:"leadResourceType,omitempty" json:"leadResourceType,omitempty"`
}

type LeadResourceTypeFilter

type LeadResourceTypeFilter string

const (
	LeadResourceTypeFilter_None  LeadResourceTypeFilter = ""
	LeadResourceTypeFilter_First LeadResourceTypeFilter = "first"
	LeadResourceTypeFilter_Last  LeadResourceTypeFilter = "last"
)

type LeadResourceTypePublisherConfig

type LeadResourceTypePublisherConfig struct {
	Enabled     bool                   `yaml:"enabled" json:"enabled"`
	RegexFilter []string               `yaml:"regexFilter" json:"regexFilter"`
	Filter      LeadResourceTypeFilter `yaml:"filter" json:"filter"`
	UseUUID     bool                   `yaml:"useUUID" json:"useUUID"`
	// contains filtered or unexported fields
}

func (*LeadResourceTypePublisherConfig) GetCompiledRegexFilter

func (c *LeadResourceTypePublisherConfig) GetCompiledRegexFilter() []*regexp.Regexp

func (*LeadResourceTypePublisherConfig) IsEnabled

func (c *LeadResourceTypePublisherConfig) IsEnabled() bool

func (*LeadResourceTypePublisherConfig) Validate

func (c *LeadResourceTypePublisherConfig) Validate() error

type LeadResourceTypeSubscriberConfig

type LeadResourceTypeSubscriberConfig struct {
	Enabled bool `yaml:"enabled" json:"enabled"`
}

func (*LeadResourceTypeSubscriberConfig) IsEnabled

func (c *LeadResourceTypeSubscriberConfig) IsEnabled() bool

type PendingLimitsConfig

type PendingLimitsConfig struct {
	MsgLimit   int `yaml:"msgLimit" json:"msgLimit"`
	BytesLimit int `yaml:"bytesLimit" json:"bytesLimit"`
}

func (*PendingLimitsConfig) Validate

func (c *PendingLimitsConfig) Validate() error