sinks

package

v0.3.1 Latest Latest Go to latest Published: Jul 6, 2025 License: GPL-3.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/tarungka/wire

Links

Open Source Insights

Documentation ¶

Index ¶

type ElasticSink
type FileSink
type KafkaSink
type SinkConfig

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ElasticSink ¶

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

func (*ElasticSink) Connect ¶

func (e *ElasticSink) Connect(ctx context.Context) error

func (*ElasticSink) Disconnect ¶

func (e *ElasticSink) Disconnect() error

func (*ElasticSink) Info ¶

func (e *ElasticSink) Info() string

func (*ElasticSink) Init ¶

func (e *ElasticSink) Init(args SinkConfig) error

func (*ElasticSink) Key ¶

func (e *ElasticSink) Key() (string, error)

func (*ElasticSink) Name ¶

func (e *ElasticSink) Name() string

func (*ElasticSink) Write ¶

func (e *ElasticSink) Write(ctx context.Context, wg *sync.WaitGroup, dataChan <-chan []byte, initialDataChan <-chan []byte) error

Accepts a byte array of json data and writes to elastic search index

type FileSink ¶

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

func (*FileSink) Connect ¶

func (f *FileSink) Connect(ctx context.Context) error

func (*FileSink) Disconnect ¶

func (f *FileSink) Disconnect() error

func (*FileSink) Info ¶

func (f *FileSink) Info() string

func (*FileSink) Init ¶

func (f *FileSink) Init(args SinkConfig) error

func (*FileSink) Key ¶

func (f *FileSink) Key() (string, error)

func (*FileSink) Name ¶

func (f *FileSink) Name() string

func (*FileSink) Write ¶

func (f *FileSink) Write(ctx context.Context, wg *sync.WaitGroup, dataChan <-chan *models.Job, initialDataChan <-chan *models.Job) error

type KafkaSink ¶

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

func (*KafkaSink) Connect ¶

func (k *KafkaSink) Connect(ctx context.Context) error

func (*KafkaSink) Disconnect ¶

func (k *KafkaSink) Disconnect() error

func (*KafkaSink) Info ¶

func (k *KafkaSink) Info() string

func (*KafkaSink) Init ¶

func (k *KafkaSink) Init(args SinkConfig) error

func (*KafkaSink) Key ¶

func (k *KafkaSink) Key() (string, error)

func (*KafkaSink) Name ¶

func (k *KafkaSink) Name() string

func (*KafkaSink) Write ¶

func (k *KafkaSink) Write(ctx context.Context, wg *sync.WaitGroup, dataChan <-chan *models.Job, initialDataChan <-chan *models.Job) error

BUG: There is an error when trying to clean up/ close this channel/ function; unsure what the error is

type SinkConfig ¶

type SinkConfig struct {
	Name           string            `koanf:"name" json:"name"`
	ConnectionType string            `koanf:"type" json:"type"`
	Config         map[string]string `koanf:"config" json:"config"`
	Key            string            `koanf:"key" json:"key"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL