core

Documentation

Index

• type Client
  • func NewClient() *Client
  • func (client *Client) Connect(host string, options *Options) error
  • func (client *Client) ConnectToEndpoint(name string, domain string, options *EndpointOptions) (*Endpoint, error)
  • func (client *Client) Disconnect()
  • func (client *Client) GetConnection() *nats.Conn
  • func (client *Client) GetEndpoint(name string) *Endpoint
• type Endpoint
  • func NewEndpoint(client *Client, name string, domain string, options *EndpointOptions) *Endpoint
  • func (endpoint *Endpoint) Channel(channelName string) string
  • func (endpoint *Endpoint) Connect() error
  • func (endpoint *Endpoint) GetConnection() *nats.Conn
• type EndpointOptions
  • func NewEndpointOptions() *EndpointOptions
• type EventBus
  • func NewEventBus(host string, handler EventBusHandler, options EventBusOptions) *EventBus
  • func (eb *EventBus) Close()
  • func (eb *EventBus) Connect() error
  • func (eb *EventBus) GetConnection() *nats.Conn
  • func (eb *EventBus) ReconnectHandler(natsConn *nats.Conn)
• type EventBusHandler
• type EventBusOptions
• type Options
  • func NewOptions() *Options

Types

type Client

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

func NewClient

func NewClient() *Client

func (*Client) Connect

func (client *Client) Connect(host string, options *Options) error

func (*Client) ConnectToEndpoint

func (client *Client) ConnectToEndpoint(name string, domain string, options *EndpointOptions) (*Endpoint, error)

func (*Client) Disconnect

func (client *Client) Disconnect()

func (*Client) GetConnection

func (client *Client) GetConnection() *nats.Conn

func (*Client) GetEndpoint

func (client *Client) GetEndpoint(name string) *Endpoint

type Endpoint

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

func NewEndpoint

func NewEndpoint(client *Client, name string, domain string, options *EndpointOptions) *Endpoint

func (*Endpoint) Channel

func (endpoint *Endpoint) Channel(channelName string) string

func (*Endpoint) Connect

func (endpoint *Endpoint) Connect() error

func (*Endpoint) GetConnection

func (endpoint *Endpoint) GetConnection() *nats.Conn

type EndpointOptions

type EndpointOptions struct {
}

func NewEndpointOptions

func NewEndpointOptions() *EndpointOptions

type EventBus

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

func NewEventBus

func NewEventBus(host string, handler EventBusHandler, options EventBusOptions) *EventBus

func (*EventBus) Close

func (eb *EventBus) Close()

func (*EventBus) Connect

func (eb *EventBus) Connect() error

func (*EventBus) GetConnection

func (eb *EventBus) GetConnection() *nats.Conn

func (*EventBus) ReconnectHandler

func (eb *EventBus) ReconnectHandler(natsConn *nats.Conn)

type EventBusHandler

type EventBusHandler struct {
	Reconnect  func(natsConn *nats.Conn)
	Disconnect func(natsConn *nats.Conn)
}

type EventBusOptions

type EventBusOptions struct {
	PingInterval        time.Duration
	MaxPingsOutstanding int
	MaxReconnects       int
}

type Options

type Options struct {
	PingInterval        time.Duration
	MaxPingsOutstanding int
	MaxReconnects       int
	ReconnectHandler    func()
	DisconnectHandler   func()
}

func NewOptions

func NewOptions() *Options