Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ReaderContext ¶
type ReaderContext struct {
// contains filtered or unexported fields
}
func NewReaderContext ¶
func NewReaderContext(endpoint string) (*ReaderContext, error)
NewReaderContext initializes the ZMQ context and connects to the readerd at the supplied endpoint.
func (*ReaderContext) RequestFrames ¶
func (c *ReaderContext) RequestFrames(origin string, source map[string]string, start, end time.Time) ([]*dataframe.DataBurst, error)
RequestFrames makes a request to readerd for the data for a given source between start and end, returning an array of DataBursts.
type VaultaireWriter ¶
type VaultaireWriter struct {
// contains filtered or unexported fields
}
VaultaireWriter writes DataFrames to vaultaire (via libmarquise). It implements framestore.DataFrameWriter.
func NewVaultaireWriter ¶
func NewVaultaireWriter(zmqBroker string, batchPeriod float64, origin, telemetry string, debug bool) (VaultaireWriter, error)
zmqBroker is a string taking the form of a ZeroMQ URI. batchPeriod is the interval at which the worker thread will poll/empty the queue of messages.
func (VaultaireWriter) Shutdown ¶
func (w VaultaireWriter) Shutdown() error
Shutdown ensures that relevant zeromq sockets get closed - as libmarquise writes are nonblocking, this must be called in order to ensure that previous writes are safe.
func (VaultaireWriter) WriteFrame ¶
func (w VaultaireWriter) WriteFrame(frame *dataframe.DataFrame) error
WriteFrame takes a single DataFrame pointer and writes it to libmarquise, which will then write it to Vaultaire.
There is no batch-write support in the framestore package as writes are non-blocking and batched by libmarquise.
Source Files