adapter

Documentation

Index

• type AdapterConnector
  • func NewAdapterConnector(options *Options) *AdapterConnector
  • func NewAdapterConnectorWithClient(client *core.Client, options *Options) *AdapterConnector
  • func (ac *AdapterConnector) BatchPublish(requests []*Request) (bool, int32, error)
  • func (ac *AdapterConnector) Connect(host string, options *core.Options) error
  • func (ac *AdapterConnector) Disconnect() error
  • func (ac *AdapterConnector) Publish(eventName string, payload []byte, meta map[string]interface{}) error
  • func (ac *AdapterConnector) Register(component string, adapterID string, name string) error
• 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
• type Request
• type RequestBuffer
  • func NewRequestBuffer(size int) *RequestBuffer
  • func (rb *RequestBuffer) Flush() error
  • func (rb *RequestBuffer) Push(req *Request)
  • func (rb *RequestBuffer) SetSize(size int)

Types

type AdapterConnector

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

func NewAdapterConnector

func NewAdapterConnector(options *Options) *AdapterConnector

func NewAdapterConnectorWithClient

func NewAdapterConnectorWithClient(client *core.Client, options *Options) *AdapterConnector

func (*AdapterConnector) BatchPublish

func (ac *AdapterConnector) BatchPublish(requests []*Request) (bool, int32, error)

func (*AdapterConnector) Connect

func (ac *AdapterConnector) Connect(host string, options *core.Options) error

func (*AdapterConnector) Disconnect

func (ac *AdapterConnector) Disconnect() error

func (*AdapterConnector) Publish

func (ac *AdapterConnector) Publish(eventName string, payload []byte, meta map[string]interface{}) error

func (*AdapterConnector) Register

func (ac *AdapterConnector) Register(component string, adapterID string, name string) error

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 {
	BatchSize           int
	PingInterval        time.Duration
	MaxPingsOutstanding int
	MaxReconnects       int
	ReconnectHandler    func()
	DisconnectHandler   func()
	Verbose             bool
}

func NewOptions

func NewOptions() *Options

type Request

type Request struct {
	IsCompleted bool
	Key         []byte
	EventName   string
	Payload     []byte
}

type RequestBuffer

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

func NewRequestBuffer

func NewRequestBuffer(size int) *RequestBuffer

func (*RequestBuffer) Flush

func (rb *RequestBuffer) Flush() error

func (*RequestBuffer) Push

func (rb *RequestBuffer) Push(req *Request)

func (*RequestBuffer) SetSize

func (rb *RequestBuffer) SetSize(size int)