moduls

package

v0.0.0-...-a55f869 Latest Latest Go to latest Published: Oct 23, 2019 License: MIT Imports: 12 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/meongbego/bgin

Links

Open Source Insights

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)

Constants ¶

This section is empty.

Variables ¶

View Source

var Conn *gorm.DB

Conn For Global Connect

View Source

var ElConn *elastic.Client

ElConn | Global Var to conn

View Source

var Etcd client.KeysAPI

Etcd to use all object client

View Source

var Kafka sarama.SyncProducer

Kafka Connect to global

View Source

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

Source Files ¶

View all Source files

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