common

package

v0.0.0-...-98127d3 Latest Latest Go to latest Published: Nov 28, 2019 License: GPL-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/EBWi11/AgentSmith-HIDS

Documentation ¶

Index ¶

Variables
func GetFileMD5(path string) string
func GetGlobalCache() *bigcache.BigCache
func GetHostName() string
func KafkaProducer(host string, topic string, upStream chan string, ctx context.Context, ...)
func KafkaProducerRun(host string, topic string, upStream chan string, ctx context.Context, ...)
func KafkaStatusCheck(host string, otherConf map[string]interface{}, kafkaType string) error
func LogInit()
func NewCache(ttl int, MaxEntrySize int, HardMaxCacheSize int) (*bigcache.BigCache, error)
func SmithConfInit() error
type SmithConf
- func (s *SmithConf) SetCtx(ctx context.Context, cancelButten context.CancelFunc)
- func (s *SmithConf) StopSender()

Constants ¶

This section is empty.

Variables ¶

View Source

var Logger = zerolog.Logger{}

View Source

var SMITH_CONF = SmithConf{}

Functions ¶

func GetFileMD5 ¶

func GetFileMD5(path string) string

func GetGlobalCache ¶

func GetGlobalCache() *bigcache.BigCache

func GetHostName ¶

func GetHostName() string

func KafkaProducer ¶

func KafkaProducer(host string, topic string, upStream chan string, ctx context.Context, kafkaWorkerSize int, KafkaOtherConf map[string]interface{})

func KafkaProducerRun ¶

func KafkaProducerRun(host string, topic string, upStream chan string, ctx context.Context, KafkaOtherConf map[string]interface{})

func KafkaStatusCheck ¶

func KafkaStatusCheck(host string, otherConf map[string]interface{}, kafkaType string) error

func LogInit ¶

func LogInit()

func NewCache ¶

func NewCache(ttl int, MaxEntrySize int, HardMaxCacheSize int) (*bigcache.BigCache, error)

func SmithConfInit ¶

func SmithConfInit() error

Types ¶

type SmithConf ¶

type SmithConf struct {
	DataTransferType string

	DataChan chan string

	KafkaBootstrapServers string                 `json:"KafkaBootstrapServers"`
	KafkaTopic            string                 `json:"KafkaTopic"`
	KafkaWorkerSize       int                    `json:"KafkaWorkerSize"`
	KafkaCompression      string                 `json:"KafkaCompression"`
	KafkaOtherConf        map[string]interface{} `json:"KafkaOtherConf"`
	// contains filtered or unexported fields
}

func (*SmithConf) SetCtx ¶

func (s *SmithConf) SetCtx(ctx context.Context, cancelButten context.CancelFunc)

func (*SmithConf) StopSender ¶

func (s *SmithConf) StopSender()

Source Files ¶

View all Source files

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