syslog

Documentation

Index

• Constants
• type Source
  • func (s *Source) Chunks(ctx context.Context, chunksChan chan *sources.Chunk, ...) error
  • func (s *Source) Init(_ context.Context, name string, jobId sources.JobID, sourceId sources.SourceID, ...) error
  • func (s *Source) InjectConnection(conn *sourcespb.Syslog)
  • func (s *Source) JobID() sources.JobID
  • func (s *Source) SourceID() sources.SourceID
  • func (s *Source) Type() sourcespb.SourceType
  • func (s *Source) Validate(ctx context.Context) []error
• type Syslog
  • func NewSyslog(sourceType sourcespb.SourceType, jobID sources.JobID, ...) *Syslog

Constants

const (
	SourceType = sourcespb.SourceType_SOURCE_TYPE_SYSLOG
)

Types

type Source

type Source struct {
	sources.Progress
	// contains filtered or unexported fields
}

func (*Source) Chunks

func (s *Source) Chunks(ctx context.Context, chunksChan chan *sources.Chunk, _ ...sources.ChunkingTarget) error

Chunks emits chunks of bytes over a channel.

func (*Source) Init

func (s *Source) Init(_ context.Context, name string, jobId sources.JobID, sourceId sources.SourceID, verify bool, connection *anypb.Any, concurrency int) error

Init returns an initialized Syslog source.

func (*Source) InjectConnection

func (s *Source) InjectConnection(conn *sourcespb.Syslog)

func (*Source) JobID

func (s *Source) JobID() sources.JobID

func (*Source) SourceID

func (s *Source) SourceID() sources.SourceID

func (*Source) Type

func (s *Source) Type() sourcespb.SourceType

Type returns the type of source. It is used for matching source types in configuration and job input.

func (*Source) Validate

func (s *Source) Validate(ctx context.Context) []error

Validate validates the configuration of the source.

type Syslog

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

func NewSyslog

func NewSyslog(sourceType sourcespb.SourceType, jobID sources.JobID, sourceID sources.SourceID, sourceName string, verify bool, concurrency int,
	sourceMetadataFunc func(hostname, appname, procid, timestamp, facility, client string) *source_metadatapb.MetaData,
) *Syslog