connectors

Documentation

Index

• func CloseKafkaConnection(writer *kafka.Writer) error
• func SetupKafkaConnection(host string, port string, topic string) *kafka.Writer
• func SetupS3Client(cfg config.S3ConnectorConfig) (*session.Session, *s3.S3)
• type ConnectorInterface
  • func CreateConnectors(cfg config.YamlConfig) []ConnectorInterface
• type KafkaConnector
  • func (c KafkaConnector) Close() error
  • func (c KafkaConnector) GetName() string
  • func (c KafkaConnector) Send(line *tail.Line) error
• type RollbarConnector
  • func (c RollbarConnector) Close() error
  • func (c RollbarConnector) GetName() string
  • func (c RollbarConnector) Send(line *tail.Line) error
• type S3Connector
  • func (c S3Connector) Close() error
  • func (c S3Connector) GetName() string
  • func (c S3Connector) Send(line *tail.Line) error

Functions

func CloseKafkaConnection

func CloseKafkaConnection(writer *kafka.Writer) error

func SetupKafkaConnection

func SetupKafkaConnection(host string, port string, topic string) *kafka.Writer

func SetupS3Client

func SetupS3Client(cfg config.S3ConnectorConfig) (*session.Session, *s3.S3)

Sets up S3 client

Types

type ConnectorInterface

type ConnectorInterface interface {
	GetName() string
	Send(line *tail.Line) error
	Close() error
}

func CreateConnectors

func CreateConnectors(cfg config.YamlConfig) []ConnectorInterface

Create all connectors

type KafkaConnector

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

func (KafkaConnector) Close

func (c KafkaConnector) Close() error

func (KafkaConnector) GetName

func (c KafkaConnector) GetName() string

func (KafkaConnector) Send

func (c KafkaConnector) Send(line *tail.Line) error

type RollbarConnector

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

func (RollbarConnector) Close

func (c RollbarConnector) Close() error

func (RollbarConnector) GetName

func (c RollbarConnector) GetName() string

func (RollbarConnector) Send

func (c RollbarConnector) Send(line *tail.Line) error

type S3Connector

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

func (S3Connector) Close

func (c S3Connector) Close() error

func (S3Connector) GetName

func (c S3Connector) GetName() string

func (S3Connector) Send

func (c S3Connector) Send(line *tail.Line) error