unstaked

Documentation

Index

• type EngineCollector
  • func NewUnstakedEngineCollector(metrics module.EngineMetrics) *EngineCollector
  • func (ec *EngineCollector) InboundMessageDropped(engine string, message string)
  • func (ec *EngineCollector) MessageHandled(engine string, message string)
  • func (ec *EngineCollector) MessageReceived(engine string, message string)
  • func (ec *EngineCollector) MessageSent(engine string, message string)
  • func (ec *EngineCollector) OutboundMessageDropped(engine string, message string)

Types

type EngineCollector

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

func NewUnstakedEngineCollector

func NewUnstakedEngineCollector(metrics module.EngineMetrics) *EngineCollector

func (*EngineCollector) InboundMessageDropped

func (ec *EngineCollector) InboundMessageDropped(engine string, message string)

func (*EngineCollector) MessageHandled

func (ec *EngineCollector) MessageHandled(engine string, message string)

func (*EngineCollector) MessageReceived

func (ec *EngineCollector) MessageReceived(engine string, message string)

func (*EngineCollector) MessageSent

func (ec *EngineCollector) MessageSent(engine string, message string)

func (*EngineCollector) OutboundMessageDropped

func (ec *EngineCollector) OutboundMessageDropped(engine string, message string)