Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
Directory string
)
Functions ¶
func BuildFromFiles ¶
Types ¶
type WaveStream ¶
type WaveStream struct {
// contains filtered or unexported fields
}
func NewWave ¶
func NewWave(dir, ts string, keys []string) *WaveStream
func (*WaveStream) Close ¶
func (s *WaveStream) Close()
func (*WaveStream) OnNewDocument ¶
func (s *WaveStream) OnNewDocument(json []byte) error
Click to show internal directories.
Click to hide internal directories.