metrics

Documentation

Index

• type EnvelopeStorage
  • func NewEnvelopeStorage(name, implementation string, backend storage.EnvelopeStorage) *EnvelopeStorage
  • func (s EnvelopeStorage) CheckStalled(id api.UUID, duration time.Duration) bool
  • func (s EnvelopeStorage) GetEventTypes(id api.UUID) ([]string, bool)
  • func (s EnvelopeStorage) Purge(filter storage.EnvelopeFilter)
  • func (s EnvelopeStorage) ReadEnvelope(id api.UUID, position storage.EnvelopeReadPos, maxsize int) (api.Envelope, storage.EnvelopeReadPos, error)
  • func (s EnvelopeStorage) ReceptionStatus(id api.UUID) (storage.EnvelopeStorageReceptionStatus, error)
  • func (s EnvelopeStorage) SetEventHandler(handler storage.EnvelopeStorageEventHandler)
  • func (s EnvelopeStorage) Stat() ([]control.StorageStat_Entry, error)
  • func (s EnvelopeStorage) StoreEnvelope(id api.Envelope) (storage.EnvelopeState, error)
• type StorageTimer
  • func NewStorageTimer(storage, name, implementation string) StorageTimer
  • func (t *StorageTimer) Time(function string) func(success bool)

Types

type EnvelopeStorage

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

func NewEnvelopeStorage

func NewEnvelopeStorage(name, implementation string, backend storage.EnvelopeStorage) *EnvelopeStorage

func (EnvelopeStorage) CheckStalled

func (s EnvelopeStorage) CheckStalled(id api.UUID, duration time.Duration) bool

func (EnvelopeStorage) GetEventTypes

func (s EnvelopeStorage) GetEventTypes(id api.UUID) ([]string, bool)

func (EnvelopeStorage) Purge

func (s EnvelopeStorage) Purge(filter storage.EnvelopeFilter)

func (EnvelopeStorage) ReadEnvelope

func (s EnvelopeStorage) ReadEnvelope(
	id api.UUID, position storage.EnvelopeReadPos, maxsize int,
) (api.Envelope, storage.EnvelopeReadPos, error)

func (EnvelopeStorage) ReceptionStatus

func (s EnvelopeStorage) ReceptionStatus(id api.UUID) (
	storage.EnvelopeStorageReceptionStatus, error,
)

ReceptionStatus returns the envelope reception status

func (EnvelopeStorage) SetEventHandler

func (s EnvelopeStorage) SetEventHandler(handler storage.EnvelopeStorageEventHandler)

func (EnvelopeStorage) Stat

func (s EnvelopeStorage) Stat() ([]control.StorageStat_Entry, error)

func (EnvelopeStorage) StoreEnvelope

func (s EnvelopeStorage) StoreEnvelope(id api.Envelope) (storage.EnvelopeState, error)

type StorageTimer

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

func NewStorageTimer

func NewStorageTimer(storage, name, implementation string) StorageTimer

func (*StorageTimer) Time

func (t *StorageTimer) Time(function string) func(success bool)