natssink

Documentation

Index

• type NatsSink
  • func NewKNatsSink(cfg *NatsSinkConf) *NatsSink
  • func (s *NatsSink) Publish(msg *sink.Message) error
• type NatsSinkConf

Types

type NatsSink

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

func NewKNatsSink

func NewKNatsSink(cfg *NatsSinkConf) *NatsSink

NewKNatsSink creates a new sink object given the conf

func (*NatsSink) Publish

func (s *NatsSink) Publish(msg *sink.Message) error

Publish send a message through the sink

type NatsSinkConf

type NatsSinkConf struct {
	sink.SinkConfCommon `json:",inline" yaml:",inline"`

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