Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type InMemoryStorage ¶
type InMemoryStorage struct {
Storage
// contains filtered or unexported fields
}
func (*InMemoryStorage) EvictMessages ¶
func (*InMemoryStorage) GetMessages ¶
func (s *InMemoryStorage) GetMessages(topic string, partition models.Partition) (models.MessageList, error)
func (*InMemoryStorage) StoreMessage ¶
func (s *InMemoryStorage) StoreMessage(msg *models.Message) error
type Storage ¶
type Storage interface {
StoreMessage(msg *models.Message) error
GetMessages(topic string, partition models.Partition) (models.MessageList, error)
EvictMessages(topic string, partition models.Partition, ttl time.Duration) error
}
Storage defines methods to be implemented by each storage backend.
func GetStorage ¶
func GetStorage(config *models.BrokerConfig) Storage
func NewInMemoryStorage ¶
func NewInMemoryStorage() Storage
Source Files
Click to show internal directories.
Click to hide internal directories.