producer

Documentation

Index

• Variables
• func GetDatabases(db *sql.DB) ([]model.Database, error)
• func GetJsonMetrics() ([]byte, error)
• func GetPromMetrics(res http.ResponseWriter, req *http.Request)
• func GetStatements(db *sql.DB) ([]model.Statement, error)
• func GetTablesInfo(db *sql.DB) ([]model.Table, error)
• func NewConnection() (nc *nats.Conn, err error)
• func Publish()
• func PublishEvent(nc *nats.Conn, subject string, data []byte) error

Variables

var (
	DBConnectionConfig string
)

Functions

func GetDatabases

func GetDatabases(db *sql.DB) ([]model.Database, error)

func GetJsonMetrics

func GetJsonMetrics() ([]byte, error)

func GetPromMetrics

func GetPromMetrics(res http.ResponseWriter, req *http.Request)

func GetStatements

func GetStatements(db *sql.DB) ([]model.Statement, error)

func GetTablesInfo

func GetTablesInfo(db *sql.DB) ([]model.Table, error)

func NewConnection

func NewConnection() (nc *nats.Conn, err error)

func Publish

func Publish()

func PublishEvent

func PublishEvent(nc *nats.Conn, subject string, data []byte) error