exporters

Documentation

Index

• Constants
• Variables
• func ExportToJSON(ctx context.Context, path, filename string, value interface{}) error
• func ExportToRedisStream(ctx context.Context, rdb *redis.Client, key, address string, ...) error
• func GetRedisDbClient(ctx context.Context) *redis.Client
• type Exporter

Constants

const (
	// JSONFILE ...
	JSONFILE = "json"
	// REDIS ...
	REDIS = "redis"
)

const (
	// TXS_STREAM_KEY ...
	TXS_STREAM_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(ctx context.Context, path, filename string, value interface{}) error

ExportToJSON ...

func ExportToRedisStream

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

ExportToRedisStream ...

func GetRedisDbClient

func GetRedisDbClient(ctx context.Context) *redis.Client

GetRedisDbClient ...

Types

type Exporter

type Exporter interface {
	ExportData(ctx context.Context, data interface{}) error
}

Exporter ...