adapter

Documentation

Index

• Variables
• 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) GetEndpoint() (*core.Endpoint, error)
  • func (ac *AdapterConnector) Publish(eventName string, payload []byte, meta map[string]interface{}) error
  • func (ac *AdapterConnector) PublishComplete() <-chan struct{}
  • func (ac *AdapterConnector) PublishPending() int
  • func (ac *AdapterConnector) Register(component string, adapterID string, name string) error
  • func (ac *AdapterConnector) Release()
• 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

Variables

var (
	ErrInvalidPacket = errors.New("adapter: invalid packet")
)

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) GetEndpoint

func (ac *AdapterConnector) GetEndpoint() (*core.Endpoint, error)

func (*AdapterConnector) Publish

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

func (*AdapterConnector) PublishComplete

func (ac *AdapterConnector) PublishComplete() <-chan struct{}

func (*AdapterConnector) PublishPending

func (ac *AdapterConnector) PublishPending() int

func (*AdapterConnector) Register

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

func (*AdapterConnector) Release

func (ac *AdapterConnector) Release()

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 {
	Endpoint            string
	Domain              string
	Key                 *keyring.KeyInfo
	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
}