transformer

Documentation

Index

• Constants
• Variables
• func Transform(ctx context.Context, jd *types.PlatformPulseData) ([]*types.JetDrop, error)
• type MainNetTransformer
  • func NewMainNetTransformer(ch <-chan *types.PlatformPulseData, queueLen uint32) *MainNetTransformer
  • func (m *MainNetTransformer) GetJetDropsChannel() <-chan *types.JetDrop
  • func (m *MainNetTransformer) Start(ctx context.Context) error
  • func (m *MainNetTransformer) Stop(ctx context.Context) error
• type Metrics
  • func (s Metrics) Metrics(p *metrics.Prometheus) []prometheus.Collector
  • func (s Metrics) Refresh()

Constants

const (
	UnsupportedRecordTypeError = constError("Record does not support")
)

Variables

var (
	FromTransformerDataQueue = prometheus.NewGauge(prometheus.GaugeOpts{
		Name: "gbe_transformer_data_queue",
		Help: "The number of jetdrops in transformer export data queue",
	})
	TransformedPulses = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "gbe_transformer_pulses",
		Help: "The number of transformed pulses",
	})
	TransformedRecords = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "gbe_transformer_records",
		Help: "The number of transformed records",
	})
	Errors = prometheus.NewCounter(prometheus.CounterOpts{
		Name: "gbe_transformer_errors",
		Help: "The number of errors received during data transforming",
	})
)

Functions

func Transform

func Transform(ctx context.Context, jd *types.PlatformPulseData) ([]*types.JetDrop, error)

Transform transforms thr row JetDrops to canonical JetDrops

Types

type MainNetTransformer

type MainNetTransformer struct {
	// contains filtered or unexported fields
}

func NewMainNetTransformer

func NewMainNetTransformer(ch <-chan *types.PlatformPulseData, queueLen uint32) *MainNetTransformer

func (*MainNetTransformer) GetJetDropsChannel

func (m *MainNetTransformer) GetJetDropsChannel() <-chan *types.JetDrop

func (*MainNetTransformer) Start

func (m *MainNetTransformer) Start(ctx context.Context) error

func (*MainNetTransformer) Stop

func (m *MainNetTransformer) Stop(ctx context.Context) error

type Metrics

type Metrics struct{}

func (Metrics) Metrics

func (s Metrics) Metrics(p *metrics.Prometheus) []prometheus.Collector

func (Metrics) Refresh

func (s Metrics) Refresh()