cache

Documentation

Index

• type Cache
• type MemoryCache
  • func (c *MemoryCache) Read() (msg []string, lastTime int64)
  • func (c *MemoryCache) ReadFrom(startTime int64) (msg []string, lastTime int64)
  • func (c *MemoryCache) Write(b []byte) (n int, err error)
• type Message

Types

type Cache

type Cache interface {
	Read() (cache []string, epoch int64)

	ReadFrom(startTime int64) (cache []string, epoch int64)

	Write(b []byte) (n int, err error)
}

type MemoryCache

type MemoryCache struct {
	Cache
	Buffer   []Message
	Capacity int
}

func (*MemoryCache) Read

func (c *MemoryCache) Read() (msg []string, lastTime int64)

func (*MemoryCache) ReadFrom

func (c *MemoryCache) ReadFrom(startTime int64) (msg []string, lastTime int64)

func (*MemoryCache) Write

func (c *MemoryCache) Write(b []byte) (n int, err error)

type Message

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