Documentation ¶
Index ¶
- type FileQueue
- func (q *FileQueue) Close() error
- func (q *FileQueue) Consume(group, topic string, id int64, limit int64, w http.ResponseWriter) (int, error)
- func (q *FileQueue) CreateTopic(topic string) error
- func (q *FileQueue) DeleteTopic(topic string) error
- func (q *FileQueue) ListTopics(regex *regexp.Regexp) ([]string, error)
- func (q *FileQueue) ModifyTopic(topic string, request headers.ModifyRequest) (*headers.TopicInfo, error)
- func (q *FileQueue) Produce(topic string, msgSizes []int64, timestamp uint64, r io.Reader) error
- func (q *FileQueue) RootDir() string
- func (q *FileQueue) WatchTopics(topics []string) (written, deleted chan string, closer io.Closer, err error)
- type MultiWriteAtCloser
- type WriteAtCloser
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FileQueue ¶
type FileQueue struct {
// contains filtered or unexported fields
}
FileQueue implements the haraqa queue by storing messages in log files, under topic based directories
func (*FileQueue) Consume ¶
func (q *FileQueue) Consume(group, topic string, id int64, limit int64, w http.ResponseWriter) (int, error)
Consume copies messages from a log to the writer
func (*FileQueue) CreateTopic ¶
CreateTopic creates a new topic if it does not already exist
func (*FileQueue) DeleteTopic ¶
DeleteTopic deletes the topic and any nested topic within
func (*FileQueue) ListTopics ¶
ListTopics returns all of the topic names in the queue
func (*FileQueue) ModifyTopic ¶
func (q *FileQueue) ModifyTopic(topic string, request headers.ModifyRequest) (*headers.TopicInfo, error)
ModifyTopic updates the topic to truncate/remove messages and return the topic offset info
type MultiWriteAtCloser ¶
type MultiWriteAtCloser []WriteAtCloser
MultiWriteAtCloser provides methods for a slice of WriteAtCloser
func (MultiWriteAtCloser) Close ¶
func (mw MultiWriteAtCloser) Close() error
Close closes all writers in the slice
Click to show internal directories.
Click to hide internal directories.