cache

Documentation

Index

• Variables
• type EnvelopeCacheEntry
• type EnvelopeCacheEntryFragment
• type EnvelopeStorage
  • func NewEnvelopeStorage(backend storage.EnvelopeStorage, maxsize int64, log zerolog.Logger) *EnvelopeStorage
  • func (s *EnvelopeStorage) CheckStalled(id api.UUID, duration time.Duration) bool
  • func (s *EnvelopeStorage) GetEventTypes(id api.UUID) (types []string, exists 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(envelope api.Envelope) (storage.EnvelopeState, error)

Variables

var (
	DefaultEnvelopeCacheMaxSize = int64(1024 * 1024 * 1024)
)

Types

type EnvelopeCacheEntry

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

type EnvelopeCacheEntryFragment

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

type EnvelopeStorage

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

EnvelopeStorage implements a cache layer on top of a storage.EnvelopeStorage The cache is populated during store, NOT during read. As such it is optimized for a write followed by consecutive reads on the same instance, which should cover most the needs until we do actual load-balancing

func NewEnvelopeStorage

func NewEnvelopeStorage(backend storage.EnvelopeStorage, maxsize int64, log zerolog.Logger) *EnvelopeStorage

NewEnvelopeStorage creates a cached envelope storage.

func (*EnvelopeStorage) CheckStalled

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

func (*EnvelopeStorage) GetEventTypes

func (s *EnvelopeStorage) GetEventTypes(id api.UUID) (types []string, exists 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) 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(envelope api.Envelope) (storage.EnvelopeState, error)