integrationsimpl

Documentation

Overview

Package integrationsimpl implements the integrations component interface

Index

• type Logsintegration
  • func NewLogsIntegration() *Logsintegration
  • func (li *Logsintegration) RegisterIntegration(id string, config integration.Config)
  • func (li *Logsintegration) SendLog(log, integrationID string)
  • func (li *Logsintegration) Subscribe() chan integrations.IntegrationLog
  • func (li *Logsintegration) SubscribeIntegration() chan integrations.IntegrationConfig

Types

type Logsintegration

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

Logsintegration is the integrations component implementation

func NewLogsIntegration

func NewLogsIntegration() *Logsintegration

NewLogsIntegration creates a new integrations instance

func (*Logsintegration) RegisterIntegration

func (li *Logsintegration) RegisterIntegration(id string, config integration.Config)

RegisterIntegration registers an integration with the integrations component

func (*Logsintegration) SendLog

func (li *Logsintegration) SendLog(log, integrationID string)

SendLog sends a log to any subscribers

func (*Logsintegration) Subscribe

func (li *Logsintegration) Subscribe() chan integrations.IntegrationLog

Subscribe returns the channel that receives logs from integrations. Currently the integrations component only supports one subscriber, but can be extended later by making a new channel for any number of subscribers.

func (*Logsintegration) SubscribeIntegration

func (li *Logsintegration) SubscribeIntegration() chan integrations.IntegrationConfig

SubscribeIntegration returns the channel that receives integration configurations