bridge

Documentation

Index

• type Bridge
  • func New(log *logrus.Logger, conf *Config) *Bridge
  • func (b *Bridge) ServeMetrics(ctx context.Context) error
  • func (b *Bridge) Start(ctx context.Context) error
• type Config
  • func (c *Config) Validate() error
• type Metrics
  • func NewMetrics(namespace string) *Metrics
  • func (m *Metrics) AddTransactions(count int)

Types

type Bridge

type Bridge struct {
	Cfg Config
	// contains filtered or unexported fields
}

func New

func New(log *logrus.Logger, conf *Config) *Bridge

func (*Bridge) ServeMetrics

func (b *Bridge) ServeMetrics(ctx context.Context) error

func (*Bridge) Start

func (b *Bridge) Start(ctx context.Context) error

type Config

type Config struct {
	LoggingLevel string        `yaml:"logging" default:"info"`
	MetricsAddr  string        `yaml:"metricsAddr" default:":9090"`
	Source       source.Config `yaml:"source"`
	Target       target.Config `yaml:"target"`
}

func (*Config) Validate

func (c *Config) Validate() error

type Metrics

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

func NewMetrics

func NewMetrics(namespace string) *Metrics

func (*Metrics) AddTransactions

func (m *Metrics) AddTransactions(count int)