generic

package
v0.0.0-...-3022a63 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 2, 2020 License: GPL-3.0 Imports: 1 Imported by: 0

Documentation

Overview

Package generic contains stream processing functions that * can be called on any kind of data types.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Count

type Count struct {
	// contains filtered or unexported fields
}

func NewCount

func NewCount() *Count

func (*Count) Add

func (c *Count) Add(v interface{})

func (*Count) Remove

func (c *Count) Remove(v interface{})

func (*Count) Reset

func (c *Count) Reset()

func (*Count) Result

func (c *Count) Result() (interface{}, error)

type DCount

type DCount struct {
	// contains filtered or unexported fields
}

func NewDCount

func NewDCount() *DCount

func (*DCount) Add

func (c *DCount) Add(v interface{})

func (*DCount) Remove

func (c *DCount) Remove(v interface{})

func (*DCount) Reset

func (c *DCount) Reset()

func (*DCount) Result

func (c *DCount) Result() (interface{}, error)

type IStream

type IStream interface {

	// Add adds a value to the algorithm.
	Add(v interface{})

	// Remove removes the value from the algorithm.
	Remove(v interface{})

	// Result produces result of the algorithm and error.
	Result() (interface{}, error)

	// Reset clears the stream algorithm's inner state.
	Reset()
}

IStream defines a streaming data processing math algorithm's interface.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL