cannon

Oct 27, 2023

Changes in this version

+ type Cannon struct

+ Config *Config

+ func New(ctx context.Context, log logrus.FieldLogger, config *Config) (*Cannon, error)

+ func (c *Cannon) ServeMetrics(ctx context.Context) error

+ func (c *Cannon) ServePProf(ctx context.Context) error

+ func (c *Cannon) Shutdown(ctx context.Context) error

+ func (c *Cannon) Start(ctx context.Context) error

+ type Config struct

+ Coordinator coordinator.Config

+ Derivers deriver.Config

+ Ethereum ethereum.Config

+ Labels map[string]string

+ LoggingLevel string

+ MetricsAddr string

+ NTPServer string

+ Name string

+ Outputs []output.Config

+ PProfAddr *string

+ Tracing observability.TracingConfig

+ func (c *Config) CreateSinks(log logrus.FieldLogger) ([]output.Sink, error)

+ func (c *Config) Validate() error

+ type Metrics struct

+ func NewMetrics(namespace string) *Metrics

+ func (m *Metrics) AddDecoratedEvent(count int, eventType *xatu.DecoratedEvent, network string)