Documentation ¶
Overview ¶
************************************************************************
- Copyright 2018 Gravwell, Inc. All rights reserved.
- Contact: <legal@gravwell.io> *
- This software may be modified and distributed under the terms of the
- BSD 2-clause license. See the LICENSE file for details. *************************************************************************
************************************************************************
- Copyright 2018 Gravwell, Inc. All rights reserved.
- Contact: <legal@gravwell.io> *
- This software may be modified and distributed under the terms of the
- BSD 2-clause license. See the LICENSE file for details. *************************************************************************
************************************************************************
- Copyright 2018 Gravwell, Inc. All rights reserved.
- Contact: <legal@gravwell.io> *
- This software may be modified and distributed under the terms of the
- BSD 2-clause license. See the LICENSE file for details. *************************************************************************
Index ¶
- Constants
- func OneShot(conn GeneratorConn, tag entry.EntryTag, src net.IP, cfg GeneratorConfig, ...) (totalCount, totalBytes uint64, err error)
- func Stream(conn GeneratorConn, tag entry.EntryTag, src net.IP, cfg GeneratorConfig, ...) (totalCount, totalBytes uint64, err error)
- type DataGen
- type Finalizer
- type GeneratorConfig
- type GeneratorConn
- type RawConn
- func (rc *RawConn) Close() (err error)
- func (rc *RawConn) GetTag(v string) (tag entry.EntryTag, err error)
- func (rc *RawConn) LookupTag(tag entry.EntryTag) (string, bool)
- func (rc *RawConn) NegotiateTag(v string) (tag entry.EntryTag, err error)
- func (rc *RawConn) SourceIP() (net.IP, error)
- func (rc *RawConn) Sync(time.Duration) error
- func (rc *RawConn) WaitForHot(time.Duration) error
- func (rc *RawConn) Write(ts entry.Timestamp, tag entry.EntryTag, data []byte) error
- func (rc *RawConn) WriteBatch(ents []*entry.Entry) error
- func (rc *RawConn) WriteEntry(ent *entry.Entry) error
Constants ¶
View Source
const (
TS_SIZE int = 12
)
Variables ¶
This section is empty.
Functions ¶
Types ¶
type GeneratorConfig ¶
type GeneratorConfig struct { ChaosTimestamps bool ChaosMode bool ChaosWorkers int Raw string HEC string Streaming bool Compression bool Tag string ConnSet []string Auth string Tenant string Count uint64 Duration time.Duration Start time.Time SRC net.IP Logger *log.Logger LogLevel log.Level // contains filtered or unexported fields }
func GetGeneratorConfig ¶
func GetGeneratorConfig(defaultTag string) (gc GeneratorConfig, err error)
type GeneratorConn ¶
type GeneratorConn interface { Close() error GetTag(string) (entry.EntryTag, error) NegotiateTag(string) (entry.EntryTag, error) LookupTag(entry.EntryTag) (string, bool) WaitForHot(time.Duration) error Write(entry.Timestamp, entry.EntryTag, []byte) error WriteBatch([]*entry.Entry) error WriteEntry(*entry.Entry) error Sync(time.Duration) error SourceIP() (net.IP, error) }
func NewIngestMuxer ¶
func NewIngestMuxer(name, guid string, gc GeneratorConfig, to time.Duration) (conn GeneratorConn, src net.IP, err error)
Click to show internal directories.
Click to hide internal directories.