sink

Documentation

Index

• type Message
• type Sink
• type SinkConf
• type SinkConfCommon
  • func (s *SinkConfCommon) GetKind() string

Types

type Message

type Message struct {
	Key   string
	Value []byte
}

Message is the sink message.

type Sink

type Sink interface {
	// Publish publishes a message to the sink
	Publish(msg *Message) error
}

Sink the sink interface that needs to be implemented from each sink

type SinkConf

type SinkConf interface {
	GetKind() string
}

SinkConf all sinks should implement this interfaces

type SinkConfCommon

type SinkConfCommon struct {
	Kind string `json:"kind" yaml:"kind"`
}

func (*SinkConfCommon) GetKind

func (s *SinkConfCommon) GetKind() string