nats

Documentation

Index

• Constants
• func NewGoCV(opts ...options.Option) (pipeline.Step, error)
• func WithCredentials(creds string) options.Option
• func WithKeys(key ...store.FQDNType) options.Option
• func WithPublish(topic string) options.Option
• func WithSubscribe(topic string) options.Option
• func WithUrls(urls string) options.Option
• type Options

Constants

const NAME = "nats"

Functions

func NewGoCV

func NewGoCV(opts ...options.Option) (pipeline.Step, error)

func WithCredentials

func WithCredentials(creds string) options.Option

func WithKeys

func WithKeys(key ...store.FQDNType) options.Option

func WithPublish

func WithPublish(topic string) options.Option

func WithSubscribe

func WithSubscribe(topic string) options.Option

func WithUrls

func WithUrls(urls string) options.Option

Types

type Options

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