nats

Documentation

Overview

Package nats implements the NATS Streaming connector.

Index

• type NatsSink
  • func NewNatsSink(conn stan.Conn, topic string) *NatsSink
  • func (ns *NatsSink) In() chan<- interface{}
• type NatsSource
  • func NewNatsSource(ctx context.Context, conn stan.Conn, subscriptionType stan.SubscriptionOption, ...) *NatsSource
  • func (ns *NatsSource) Out() <-chan interface{}
  • func (ns *NatsSource) Via(_flow streams.Flow) streams.Flow

Types

type NatsSink

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

NatsSink connector

func NewNatsSink

func NewNatsSink(conn stan.Conn, topic string) *NatsSink

NewNatsSink returns a new NatsSink instance

func (*NatsSink) In

func (ns *NatsSink) In() chan<- interface{}

In returns an input channel for receiving data

type NatsSource

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

NatsSource connector

func NewNatsSource

func NewNatsSource(ctx context.Context, conn stan.Conn, subscriptionType stan.SubscriptionOption, topics ...string) *NatsSource

NewNatsSource returns a new NatsSource instance

func (*NatsSource) Out

func (ns *NatsSource) Out() <-chan interface{}

Out returns the output channel for the data

func (*NatsSource) Via

func (ns *NatsSource) Via(_flow streams.Flow) streams.Flow

Via streams data through a given flow