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
Constants ¶
This section is empty.
Variables ¶
View Source
var Logger = zerolog.Logger{}
View Source
var SMITH_CONF = SmithConf{}
Functions ¶
func GetFileMD5 ¶
func GetGlobalCache ¶
func GetHostName ¶
func GetHostName() string
func KafkaProducer ¶
func KafkaProducerRun ¶
func KafkaStatusCheck ¶
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()
Click to show internal directories.
Click to hide internal directories.