2021-12-07 16:45:15 +00:00
|
|
|
package server
|
|
|
|
|
|
|
|
import (
|
2021-12-09 15:23:17 +00:00
|
|
|
"github.com/stretchr/testify/assert"
|
2021-12-07 16:45:15 +00:00
|
|
|
"testing"
|
|
|
|
)
|
|
|
|
|
|
|
|
func TestMemCache_Messages(t *testing.T) {
|
|
|
|
testCacheMessages(t, newMemCache())
|
|
|
|
}
|
2021-12-09 03:57:31 +00:00
|
|
|
|
2021-12-10 16:31:42 +00:00
|
|
|
func TestMemCache_MessagesScheduled(t *testing.T) {
|
|
|
|
testCacheMessagesScheduled(t, newMemCache())
|
|
|
|
}
|
|
|
|
|
2021-12-09 03:57:31 +00:00
|
|
|
func TestMemCache_Topics(t *testing.T) {
|
|
|
|
testCacheTopics(t, newMemCache())
|
|
|
|
}
|
|
|
|
|
2021-12-07 16:45:15 +00:00
|
|
|
func TestMemCache_MessagesTagsPrioAndTitle(t *testing.T) {
|
|
|
|
testCacheMessagesTagsPrioAndTitle(t, newMemCache())
|
|
|
|
}
|
2021-12-09 03:57:31 +00:00
|
|
|
|
|
|
|
func TestMemCache_Prune(t *testing.T) {
|
|
|
|
testCachePrune(t, newMemCache())
|
|
|
|
}
|
2021-12-09 15:23:17 +00:00
|
|
|
|
|
|
|
func TestMemCache_NopCache(t *testing.T) {
|
|
|
|
c := newNopCache()
|
|
|
|
assert.Nil(t, c.AddMessage(newDefaultMessage("mytopic", "my message")))
|
|
|
|
|
2021-12-10 16:31:42 +00:00
|
|
|
messages, err := c.Messages("mytopic", sinceAllMessages, false)
|
2021-12-09 15:23:17 +00:00
|
|
|
assert.Nil(t, err)
|
|
|
|
assert.Empty(t, messages)
|
|
|
|
|
|
|
|
topics, err := c.Topics()
|
|
|
|
assert.Nil(t, err)
|
|
|
|
assert.Empty(t, topics)
|
|
|
|
}
|