metrics

Documentation

Index

• func CommandReceiverCollector(namespace string, serviceName string, r prometheus.Registerer) wrapper.CommandReceiverFunc
• func EventHandlerCollector(namespace string, serviceName string, r prometheus.Registerer) wrapper.EventHandlerFunc
• func MessageHandlerCollector(namespace string, serviceName string, r prometheus.Registerer) wrapper.MessageHandlerFunc
• func NewSnapshotCollector(namespace string, serviceName string, r prometheus.Registerer) wrapper.SnapshotFunc
• func NewStoreCollector(namespace string, serviceName string, r prometheus.Registerer) wrapper.StoreFunc
• func ReplyReceiverCollector(namespace string, serviceName string, r prometheus.Registerer) wrapper.ReplyReceiverFunc
• type SnapshotCollector
  • func (s *SnapshotCollector) Collect(ch chan<- prometheus.Metric)
  • func (s *SnapshotCollector) Describe(ch chan<- *prometheus.Desc)
  • func (s *SnapshotCollector) Load(ctx context.Context, streamID uuid.UUID, streamType string) (stream es.Stream, err error)
  • func (s *SnapshotCollector) Remove(ctx context.Context, streamType string, streamID uuid.UUID) (err error)
  • func (s *SnapshotCollector) Reset(ctx context.Context, streamType string) (err error)
  • func (s *SnapshotCollector) Should(ctx context.Context, es es.Stream) bool
  • func (s *SnapshotCollector) Take(ctx context.Context, es es.Stream) (err error)
• type StoreCollector
  • func (s *StoreCollector) Append(ctx context.Context, streamID uuid.UUID, streamType string, events []es.Event, ...) (err error)
  • func (s *StoreCollector) Collect(ch chan<- prometheus.Metric)
  • func (s *StoreCollector) Describe(ch chan<- *prometheus.Desc)
  • func (s *StoreCollector) Iter(ctx context.Context, streamType string, ...) error
  • func (s *StoreCollector) Load(ctx context.Context, streamID uuid.UUID, streamType string, fromVersion int) (events []es.Event, err error)

Functions

func CommandReceiverCollector

func CommandReceiverCollector(namespace string, serviceName string, r prometheus.Registerer) wrapper.CommandReceiverFunc

func EventHandlerCollector

func EventHandlerCollector(namespace string, serviceName string, r prometheus.Registerer) wrapper.EventHandlerFunc

func MessageHandlerCollector

func MessageHandlerCollector(namespace string, serviceName string, r prometheus.Registerer) wrapper.MessageHandlerFunc

func NewSnapshotCollector

func NewSnapshotCollector(namespace string, serviceName string, r prometheus.Registerer) wrapper.SnapshotFunc

func NewStoreCollector

func NewStoreCollector(namespace string, serviceName string, r prometheus.Registerer) wrapper.StoreFunc

func ReplyReceiverCollector

func ReplyReceiverCollector(namespace string, serviceName string, r prometheus.Registerer) wrapper.ReplyReceiverFunc

Types

type SnapshotCollector

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

func (*SnapshotCollector) Collect

func (s *SnapshotCollector) Collect(ch chan<- prometheus.Metric)

func (*SnapshotCollector) Describe

func (s *SnapshotCollector) Describe(ch chan<- *prometheus.Desc)

func (*SnapshotCollector) Load

func (s *SnapshotCollector) Load(ctx context.Context, streamID uuid.UUID, streamType string) (stream es.Stream, err error)

func (*SnapshotCollector) Remove

func (s *SnapshotCollector) Remove(ctx context.Context, streamType string, streamID uuid.UUID) (err error)

func (*SnapshotCollector) Reset

func (s *SnapshotCollector) Reset(ctx context.Context, streamType string) (err error)

func (*SnapshotCollector) Should

func (s *SnapshotCollector) Should(ctx context.Context, es es.Stream) bool

func (*SnapshotCollector) Take

func (s *SnapshotCollector) Take(ctx context.Context, es es.Stream) (err error)

type StoreCollector

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

func (*StoreCollector) Append

func (s *StoreCollector) Append(ctx context.Context, streamID uuid.UUID, streamType string, events []es.Event, expectedVersion int) (err error)

func (*StoreCollector) Collect

func (s *StoreCollector) Collect(ch chan<- prometheus.Metric)

func (*StoreCollector) Describe

func (s *StoreCollector) Describe(ch chan<- *prometheus.Desc)

func (*StoreCollector) Iter

func (s *StoreCollector) Iter(ctx context.Context, streamType string, fn func(streamID uuid.UUID, version int, events []es.Event) error) error

func (*StoreCollector) Load

func (s *StoreCollector) Load(ctx context.Context, streamID uuid.UUID, streamType string, fromVersion int) (events []es.Event, err error)