exporters

Documentation

Index

• Constants
• Variables
• func ExportToJSON(path, filename string, value interface{}) error
• func ExportToPostgresql(db *sqlx.DB, blockID int, value string) error
• func ExportToRedisStream(rdb *redis.Client, key, symbol string, value map[string]interface{}) error
• func GetRedisDbClient() *redis.Client
• func PostgreSQLConnection() (*sqlx.DB, error)
• type Exporter

Constants

const (
	// JSONFILE ...
	JSONFILE = "json"
	// KAFKA ...
	KAFKA = "kafka"
	// POSTGRESQL ...
	POSTGRESQL = "postgresql"
	// REDIS ...
	REDIS = "redis"
)

const (
	// TXS_STREAM_KEY ...
	TXS_STREAM_KEY = "txs"
)

const (
	// TXS_TOPIC_KEY ...
	TXS_TOPIC_KEY = "txs"
)

Variables

var (
	// ErrRedisDbCheckConn ...
	ErrRedisDbCheckConn = errors.NewError("Redis: Fail to check connection")
	// ErrRedisXADDStreamID ...
	ErrRedisXADDStreamID = errors.NewError("ERR The ID specified in XADD is equal or smaller than the target stream top item")
)

Functions

func ExportToJSON

func ExportToJSON(path, filename string, value interface{}) error

ExportToJSON ...

func ExportToPostgresql

func ExportToPostgresql(db *sqlx.DB, blockID int, value string) error

ExportToPostgresql ...

func ExportToRedisStream

func ExportToRedisStream(rdb *redis.Client, key, symbol string, value map[string]interface{}) error

ExportToRedisStream ...

func GetRedisDbClient

func GetRedisDbClient() *redis.Client

GetRedisDbClient ...

func PostgreSQLConnection

func PostgreSQLConnection() (*sqlx.DB, error)

PostgreSQLConnection func for connection to PostgreSQL database.

Types

type Exporter

type Exporter interface {
	ExportData(data interface{}) error
}

Exporter ...