withfallback

Documentation

Index

• type EnvelopeStorage
  • func NewEnvelopeStorage(primary, fallback storage.EnvelopeStorage) EnvelopeStorage
  • 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) Stat() ([]control.StorageStat_Entry, error)

Types

type EnvelopeStorage

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

func NewEnvelopeStorage

func NewEnvelopeStorage(
	primary, fallback storage.EnvelopeStorage,
) EnvelopeStorage

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)

func (EnvelopeStorage) Stat

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