series

package

Go to main page

Versions in this module

v0

v0.3.8

Aug 22, 2024

v0.3.7

Nov 5, 2023

v0.3.6

Aug 25, 2023

Changes in this version

type CollectorBackend

+ func PassthroughBackend(r Renderer, handler fun.Handler[string], ...) CollectorBackend

type CollectorBackendFileConf

+ Renderer Renderer

type CollectorBackendSocketConf

+ Renderer Renderer

type CollectorBakendFileOptionProvider

+ func CollectorBackendFileConfWithRenderer(r Renderer) CollectorBakendFileOptionProvider

type CollectorBakendSocketOptionProvider

+ func CollectorBackendSocketConfWithRenderer(r Renderer) CollectorBakendSocketOptionProvider

type CollectorOptionProvider

+ func CollectorConfFileBackend(opts *CollectorBackendFileConf) CollectorOptionProvider

+ func CollectorConfWithFileBacked(opts ...CollectorBakendFileOptionProvider) CollectorOptionProvider

+ type Renderer struct

+ Histogram MetricHistogramRenderer

+ Metric MetricValueRenderer

+ func MakeGraphiteRenderer() Renderer

+ func MakeJSONRenderer() Renderer

+ func MakeOpenTSBLineRenderer() Renderer

v0.3.5

Aug 15, 2023

Changes in this version

+ func GoRuntimeEventProducer(labels ...dt.Pair[string, string]) fun.Producer[[]*Event]

+ func RenderHistogramJSON(buf *bytes.Buffer, key string, labels fun.Future[[]byte], ...)

+ func RenderLabelsGraphite(builder *bytes.Buffer, labels []dt.Pair[string, string], ...)

+ func RenderLabelsJSON(buf *bytes.Buffer, labels []dt.Pair[string, string], ...)

+ func RenderLabelsOpenTSB(builder *bytes.Buffer, labels []dt.Pair[string, string], ...)

+ func RenderMetricGraphite(buf *bytes.Buffer, key string, labels fun.Future[[]byte], value int64, ...)

+ func RenderMetricJSON(buf *bytes.Buffer, key string, labels fun.Future[[]byte], value int64, ...)

+ func RenderMetricOpenTSB(buf *bytes.Buffer, key string, labels fun.Future[[]byte], value int64, ...)

+ func Sender(s send.Sender, coll *Collector) send.Sender

+ func WithMetrics(c any, events ...*Event) message.Composer

+ type Collector struct

+ func NewCollector(ctx context.Context, opts ...CollectorOptionProvider) (*Collector, error)

+ func (c *Collector) Close() error

+ func (c *Collector) Iterator() *fun.Iterator[MetricSnapshot]

+ func (c *Collector) Publish(events []*Event)

+ func (c *Collector) Push(events ...*Event)

+ func (c *Collector) PushEvent(e *Event)

+ func (c *Collector) Register(prod fun.Producer[[]*Event], dur time.Duration)

+ func (c *Collector) Stream(iter *fun.Iterator[*Event], opts ...fun.OptionProvider[*fun.WorkerGroupConf]) fun.Worker

+ type CollectorBackend fun.Processor[*fun.Iterator[MetricPublisher]]

+ func FileBackend(opts ...CollectorBakendFileOptionProvider) (CollectorBackend, error)

+ func LoggerBackend(sender send.Sender) CollectorBackend

+ func SocketBackend(opts ...CollectorBakendSocketOptionProvider) (CollectorBackend, error)

+ func (cb CollectorBackend) Worker(iter *fun.Iterator[MetricPublisher]) fun.Worker

+ type CollectorBackendFileConf struct

+ CounterPadding int

+ Directory string

+ Extension string

+ FilePrefix string

+ Gzip bool

+ Megabytes int

+ func (conf *CollectorBackendFileConf) RotatingFilePath() fun.Producer[string]

+ func (conf *CollectorBackendFileConf) RotatingFileProducer() fun.Producer[io.WriteCloser]

+ func (conf *CollectorBackendFileConf) Validate() error

+ type CollectorBackendSocketConf struct

+ Address string

+ DialErrorHandling CollectorBackendSocketErrorOption

+ DialWorkers int

+ Dialer net.Dialer

+ IdleConns int

+ MaxDialRetryDelay time.Duration

+ MaxMessageRetryDelay time.Duration

+ MessageErrorHandling CollectorBackendSocketErrorOption

+ MessageWorkers int

+ MinDialRetryDelay time.Duration

+ MinMessageRetryDelay time.Duration

+ Network string

+ NumMessageRetries int

+ func (conf *CollectorBackendSocketConf) Validate() error

+ type CollectorBackendSocketErrorOption int8

+ const CollectorBackendSocketErrorAbort

+ const CollectorBackendSocketErrorCollect

+ const CollectorBackendSocketErrorContinue

+ const CollectorBackendSocketErrorINVALID

+ const CollectorBackendSocketErrorPanic

+ const CollectorBackendSocketErrorUNSPECIFIED

+ func (co CollectorBackendSocketErrorOption) Validate() error

+ type CollectorBakendFileOptionProvider = fun.OptionProvider[*CollectorBackendFileConf]

+ func CollectorBackendFileConfCounterPadding(v int) CollectorBakendFileOptionProvider

+ func CollectorBackendFileConfDirectory(path string) CollectorBakendFileOptionProvider

+ func CollectorBackendFileConfExtension(ext string) CollectorBakendFileOptionProvider

+ func CollectorBackendFileConfPrefix(prefix string) CollectorBakendFileOptionProvider

+ func CollectorBackendFileConfRotationSizeMB(v int) CollectorBakendFileOptionProvider

+ func CollectorBackendFileConfSet(c *CollectorBackendFileConf) CollectorBakendFileOptionProvider

+ type CollectorBakendSocketOptionProvider = fun.OptionProvider[*CollectorBackendSocketConf]

+ func CollectorBackendSocketConfAddress(addr string) CollectorBakendSocketOptionProvider

+ func CollectorBackendSocketConfDialErrorHandling(eh CollectorBackendSocketErrorOption) CollectorBakendSocketOptionProvider

+ func CollectorBackendSocketConfDialWorkers(n int) CollectorBakendSocketOptionProvider

+ func CollectorBackendSocketConfDialer(d net.Dialer) CollectorBakendSocketOptionProvider

+ func CollectorBackendSocketConfIdleConns(n int) CollectorBakendSocketOptionProvider

+ func CollectorBackendSocketConfMaxDialRetryDelay(d time.Duration) CollectorBakendSocketOptionProvider

+ func CollectorBackendSocketConfMaxMessageRetryDelay(d time.Duration) CollectorBakendSocketOptionProvider

+ func CollectorBackendSocketConfMessageErrorHandling(eh CollectorBackendSocketErrorOption) CollectorBakendSocketOptionProvider

+ func CollectorBackendSocketConfMessageWorkers(n int) CollectorBakendSocketOptionProvider

+ func CollectorBackendSocketConfMinDialRetryDelay(d time.Duration) CollectorBakendSocketOptionProvider

+ func CollectorBackendSocketConfMinMessageRetryDelay(d time.Duration) CollectorBakendSocketOptionProvider

+ func CollectorBackendSocketConfNetowrkTCP() CollectorBakendSocketOptionProvider

+ func CollectorBackendSocketConfNetowrkUDP() CollectorBakendSocketOptionProvider

+ func CollectorBackendSocketConfNumMessageRetries(n int) CollectorBakendSocketOptionProvider

+ func CollectorBackendSocketConfSet(c *CollectorBackendSocketConf) CollectorBakendSocketOptionProvider

+ type CollectorConf struct

+ Backends []CollectorBackend

+ BrokerOptions pubsub.BrokerOptions

+ Buffer int

+ DefaultHistogramRender MetricHistogramRenderer

+ LabelRenderer MetricLabelRenderer

+ MetricRenderer MetricValueRenderer

+ func (conf *CollectorConf) Validate() error

+ type CollectorOptionProvider = fun.OptionProvider[*CollectorConf]

+ func CollectorConfAppendBackends(bs ...CollectorBackend) CollectorOptionProvider

+ func CollectorConfBuffer(size int) CollectorOptionProvider

+ func CollectorConfFileLoggerBackend(opts *CollectorBackendFileConf) CollectorOptionProvider

+ func CollectorConfOutputGraphite() CollectorOptionProvider

+ func CollectorConfOutputJSON() CollectorOptionProvider

+ func CollectorConfOutputOpenTSB() CollectorOptionProvider

+ func CollectorConfSet(c *CollectorConf) CollectorOptionProvider

+ func CollectorConfWithFileLogger(opts ...CollectorBakendFileOptionProvider) CollectorOptionProvider

+ func CollectorConfWithLoggerBackend(sender send.Sender) CollectorOptionProvider

+ func CollectorConfWithOutput(lr MetricLabelRenderer, mr MetricValueRenderer, hr MetricHistogramRenderer) CollectorOptionProvider

+ type Event struct

+ func Extract(c any) []*Event

+ func (e *Event) Export() Record

+ func (e *Event) MarshalJSON() ([]byte, error)

+ func (e *Event) String() string

+ type EventExtractor interface

+ Events func() []*Event

+ type HistogramConf struct

+ Interval time.Duration

+ Max int64

+ Min int64

+ OutOfRange HistogramOutOfRangeOption

+ Quantiles []float64

+ Renderer MetricHistogramRenderer

+ SignificantDigits int

+ func MakeDefaultHistogramConf() *HistogramConf

+ func (conf *HistogramConf) Apply(opts ...HistogramOptionProvider) error

+ func (conf *HistogramConf) Validate() error

+ type HistogramOptionProvider = fun.OptionProvider[*HistogramConf]

+ func HistogramConfBounds(min, max int64) HistogramOptionProvider

+ func HistogramConfInterval(dur time.Duration) HistogramOptionProvider

+ func HistogramConfLowerBound(in int64) HistogramOptionProvider

+ func HistogramConfOutOfRange(spec HistogramOutOfRangeOption) HistogramOptionProvider

+ func HistogramConfRenderer(hr MetricHistogramRenderer) HistogramOptionProvider

+ func HistogramConfReset() HistogramOptionProvider

+ func HistogramConfSet(arg *HistogramConf) HistogramOptionProvider

+ func HistogramConfSetQuantiles(quant []float64) HistogramOptionProvider

+ func HistogramConfSignifcantDigits(in int) HistogramOptionProvider

+ func HistogramConfUpperBound(in int64) HistogramOptionProvider

+ type HistogramOutOfRangeOption int8

+ const HistogramOutOfRangeINVALID

+ const HistogramOutOfRangeIgnore

+ const HistogramOutOfRangePanic

+ const HistogramOutOfRangeTruncate

+ const HistogramOutOfRangeUNSPECIFIED

+ type Metric struct

+ ID string

+ Type MetricType

+ func Collect(id string) *Metric

+ func Counter(id string) *Metric

+ func Delta(id string) *Metric

+ func Gauge(id string) *Metric

+ func Histogram(id string, opts ...HistogramOptionProvider) *Metric

+ func (m *Metric) Add(v int64) *Event

+ func (m *Metric) Annotate(pairs ...dt.Pair[string, string]) *Metric

+ func (m *Metric) Collect(fn fun.Future[int64]) *Event

+ func (m *Metric) CollectAdd(fn fun.Future[int64]) *Event

+ func (m *Metric) Dec() *Event

+ func (m *Metric) Equal(two *Metric) bool

+ func (m *Metric) Inc() *Event

+ func (m *Metric) Label(k, v string) *Metric

+ func (m *Metric) Labels(set *dt.Set[dt.Pair[string, string]]) *Metric

+ func (m *Metric) MetricType(t MetricType) *Metric

+ func (m *Metric) Periodic(dur time.Duration) *Metric

+ func (m *Metric) Set(v int64) *Event

+ type MetricHistogramRenderer func(wr *bytes.Buffer, key string, labels fun.Future[[]byte], ...)

+ func MakeDefaultHistogramMetricRenderer(mr MetricValueRenderer) MetricHistogramRenderer

+ type MetricLabelRenderer func(output *bytes.Buffer, labels []dt.Pair[string, string], ...)

+ type MetricMessage struct

+ Events []*Event

+ func Message(m message.Composer, events ...*Event) *MetricMessage

+ func (m *MetricMessage) Raw() any

+ func (m *MetricMessage) String() string

+ func (m *MetricMessage) Structured() bool

+ type MetricPublisher func(io.Writer) error

+ type MetricSnapshot struct

+ Labels string

+ Name string

+ Timestamp time.Time

+ Value int64

+ type MetricType string

+ const MetricTypeCounter

+ const MetricTypeDeltas

+ const MetricTypeGuage

+ const MetricTypeHistogram

+ type MetricValueRenderer func(writer *bytes.Buffer, key string, labels fun.Future[[]byte], value int64, ...)

+ type Record struct

+ ID string

+ Labels *dt.Pairs[string, string]

+ Value int64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL