natsstreaming

Documentation

Index

• Constants
• func NewConnector(metadata protocol.Metadata, logger logger.Logger) (driver.Connector, error)
• func NewNatsStreamingDriver(logger logger.Logger) driver.Driver
• type PubSubDriver
  • func (d *PubSubDriver) Features() map[string]bool
  • func (d *PubSubDriver) Open(metadata protocol.Metadata) (driver.Conn, error)
  • func (d *PubSubDriver) OpenConnector(m protocol.Metadata) (driver.Connector, error)
  • func (d *PubSubDriver) SatisfyFeatures(m protocol.Metadata) ([]string, bool)

Constants

const (
	NatsURL                = "natsURL"
	NatsStreamingClusterID = "natsStreamingClusterID"
)

compulsory options

const (
	ConsumerID       = "consumerID" // passed in by Dapr runtime
	SubscriptionType = "subscriptionType"
)

const (
	DriverName = "natsstreaming"
)

Nats url format with user credentials: DefaultURL = "nats://nats_client:W64f8c6vG6@192.168.0.253:31476"

Functions

func NewConnector

func NewConnector(metadata protocol.Metadata, logger logger.Logger) (driver.Connector, error)

func NewNatsStreamingDriver

func NewNatsStreamingDriver(logger logger.Logger) driver.Driver

NewNatsStreamingDriver returns a new NATS Streaming pub-sub implementation

Types

type PubSubDriver

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

NatsStreamingPubSubDriver -

func (*PubSubDriver) Features

func (d *PubSubDriver) Features() map[string]bool

Todo: natsstreaming realized ack, queue sub but not ordering. Features design from dapr components-contrib.

func (*PubSubDriver) Open

func (d *PubSubDriver) Open(metadata protocol.Metadata) (driver.Conn, error)

Connect initializes the driver and init the connection to the server.

func (*PubSubDriver) OpenConnector

func (d *PubSubDriver) OpenConnector(m protocol.Metadata) (driver.Connector, error)

func (*PubSubDriver) SatisfyFeatures

func (d *PubSubDriver) SatisfyFeatures(m protocol.Metadata) ([]string, bool)