moduls

Documentation

Index

• Variables
• func GetKafkaConfig() *sarama.Config
• func GetRowsCached(keys string) (string, error)
• func InitDB() *gorm.DB
• func InitElastic() *elastic.Client
• func InitRedis() redis.Conn
• func Initetcd() client.KeysAPI
• func Initkafka() sarama.SyncProducer
• func RowsCached(keys string, d []byte, ttl int) ([]byte, error)
• type Data
• type KafkaProducer
• type Respons
  • func SendMessage(p sarama.SyncProducer, topic string, msg string) (Respons, error)

Variables

var Conn *gorm.DB

Conn For Global Connect

var ElConn *elastic.Client

ElConn | Global Var to conn

var Etcd client.KeysAPI

Etcd to use all object client

var Kafka sarama.SyncProducer

Kafka Connect to global

var Store redis.Conn

Store for global connect to cache

Functions

func GetKafkaConfig

func GetKafkaConfig() *sarama.Config

GetKafkaConfig Get Config From kafka

func GetRowsCached

func GetRowsCached(keys string) (string, error)

GetRowsCached func

func InitDB

func InitDB() *gorm.DB

InitDB Database Connection

func InitElastic

func InitElastic() *elastic.Client

InitElastic Init To Connect

func InitRedis

func InitRedis() redis.Conn

InitRedis func

func Initetcd

func Initetcd() client.KeysAPI

Initetcd Function

func Initkafka

func Initkafka() sarama.SyncProducer

Initkafka Function

func RowsCached

func RowsCached(keys string, d []byte, ttl int) ([]byte, error)

RowsCached func

Types

type Data

type Data struct{}

Data type

type KafkaProducer

type KafkaProducer struct {
	Producer sarama.SyncProducer
}

KafkaProducer Methods

type Respons

type Respons struct {
	Topic  interface{} `json:"topic"`
	Task   interface{} `json:"task"`
	Offset interface{} `json:"offset"`
}

Respons Data

func SendMessage

func SendMessage(p sarama.SyncProducer, topic string, msg string) (Respons, error)

SendMessage function to send message into kafka