natssource

Documentation

Index

• type NatsSource
  • func NewNatsSource(cfg *NatsSourceConf) *NatsSource
• type NatsSourceConf
  • func (s *NatsSourceConf) IsFireAndForget() bool

Types

type NatsSource

type NatsSource struct {
	source.SourceBase
	// contains filtered or unexported fields
}

func NewNatsSource

func NewNatsSource(cfg *NatsSourceConf) *NatsSource

type NatsSourceConf

type NatsSourceConf struct {
	source.SourceConfCommon `json:",inline" yaml:",inline"`

	ServerUrl  string `json:"serverUrl" yaml:"serverUrl"`
	QueueGroup string `json:"queueGroup" yaml:"queueGroup"`
	Subject    string `json:"subject" yaml:"subject"`
}

func (*NatsSourceConf) IsFireAndForget

func (s *NatsSourceConf) IsFireAndForget() bool