Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ArrayMemoryBackend ¶
type ArrayMemoryBackend struct {
// contains filtered or unexported fields
}
ArrayMemoryBackend implements core.MemoryBackend with a simple, "in-memory" array of messages. This memory backend more or less operates like a queue where messages are stored first in, last out.
func NewArrayMemoryBackend ¶
func NewArrayMemoryBackend() *ArrayMemoryBackend
NewArrayMemoryBackend returns a new ArrayMemoryBackend
func (*ArrayMemoryBackend) Add ¶
func (a *ArrayMemoryBackend) Add(m ...*core.Message) error
Add adds messages to the ArrayMemoryBackend using "append"
func (*ArrayMemoryBackend) Dump ¶
func (a *ArrayMemoryBackend) Dump() ([]*core.Message, error)
Dump returns the whole ArrayMemoryBackend array
func (*ArrayMemoryBackend) GetMaxN ¶
func (a *ArrayMemoryBackend) GetMaxN(n int) ([]*core.Message, error)
GetMaxN returns the last N number of messages
func (*ArrayMemoryBackend) Prune ¶
func (a *ArrayMemoryBackend) Prune()
Prune resets the array in the ArrayMemoryBackend
Source Files
Click to show internal directories.
Click to hide internal directories.