stream

package

v1.4.1 Latest Latest Go to latest Published: Jun 5, 2025 License: Apache-2.0 Imports: 2 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/openGemini/openGemini

Links

Documentation ¶

Index ¶

func BuildConcurrencyFunc(fieldCall *FieldCall) error
func BuildSingleThreadFunc(fieldCall *FieldCall) error
type FieldCall
- func NewFieldCall(inFieldType, outFieldType int32, name, alias, call string, concurrency bool) (*FieldCall, error)
type FieldCalls

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func BuildConcurrencyFunc ¶

func BuildConcurrencyFunc(fieldCall *FieldCall) error

func BuildSingleThreadFunc ¶

func BuildSingleThreadFunc(fieldCall *FieldCall) error

Types ¶

type FieldCall ¶

type FieldCall struct {
	Name             string
	Alias            string
	Call             string
	InFieldType      int32
	OutFieldType     int32
	ConcurrencyFunc  func(*float64, float64) float64
	SingleThreadFunc func(float64, float64) float64
}

func NewFieldCall ¶

func NewFieldCall(inFieldType, outFieldType int32, name, alias, call string, concurrency bool) (*FieldCall, error)

type FieldCalls ¶

type FieldCalls []*FieldCall

func (FieldCalls) Len ¶

func (f FieldCalls) Len() int

func (FieldCalls) Less ¶

func (f FieldCalls) Less(i, j int) bool

func (FieldCalls) Swap ¶

func (f FieldCalls) Swap(i, j int)

Source Files ¶

View all Source files

stream.go

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