stream

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

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

type ClearParams struct {
	// Identifies the stream
	Stream string `json:"stream,omitempty" xml:"stream,omitempty"`
	// If true, all data for the stream(s) will be cleared
	ClearAll bool `json:"clearAll,omitempty" xml:"clearAll,omitempty"`
	// An array of tags to be matched
	WithTags []string `json:"tagsToAssign,omitempty" xml:"tagsToAssign,omitempty"`
	// An array of tags that exclude a stream from a match
	ExcludingTags []string `json:"tagsToUnassign,omitempty" xml:"tagsToUnassign,omitempty"`
	// Specifies a maximum ordinal value used to restrict the clear operation.
	MaxOrdinal int `json:"maxOrdinal,omitempty" xml:"maxOrdinal,omitempty"`
}

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

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

type IntervalStatistics struct {
	StreamKey               string
	IntervalStart           int64
	IntervalEnd             int64
	IntervalType            IntervalType
	Minimum                 float64
	Maximum                 float64
	Mean                    float64
	Count                   uint64
	Sum                     float64
	SampleMean              float64
	SampleSum               float64
	SampleCount             uint32
	SampleStandardDeviation float64
	CoefficientOfVariation  float64
}

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

type IntervalType int

type OrdinalValue struct {
	StreamKey string
	Ordinal   int64
	Value     float64
}

type PushParams struct {
	// The ordinal position within the stream
	Ordinal int `json:"ordinal,omitempty" xml:"ordinal,omitempty"`
	// Identifies the stream that the ordinal value relates to
	Stream string `json:"stream,omitempty" xml:"stream,omitempty"`
	// The value at the ordinal position
	Value float64 `json:"value,omitempty" xml:"value,omitempty"`
}

type RegisterParams struct {
	// Identifies the stream that the definition relates to
	Stream string `json:"stream,omitempty" xml:"stream,omitempty"`
	// The ordinal position within the stream
	IntervalSize int `json:"intervalSize,omitempty" xml:"intervalSize,omitempty"`
	// The value at the ordinal position
	MaxIntervalLag int `json:"maxIntervalLag,omitempty" xml:"maxIntervalLag,omitempty"`
	// A set of tag values to be assigned to the stream
	Tags []string `json:"tags,omitempty" xml:"tags,omitempty"`
	// The value at the ordinal position
	TargetSampleSize int `json:"targetSampleSize,omitempty" xml:"targetSampleSize,omitempty"`
}

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

type StatisticsParams struct {
	// Specifies a maximum date time used to restrict the interval statistics returned.  Only statistics for intervals that are for a time range up until this date time value will be returned.
	MaxDateTime time.Time `json:"maxDateTime,omitempty" xml:"maxDateTime,omitempty"`
	// Specifies a maximum ordinal value used to restrict the interval statistics returned.  Only statistics for intervals that end on or before this ordinal value will be returned.
	MaxOrdinal int `json:"maxOrdinal,omitempty" xml:"maxOrdinal,omitempty"`
	// If true, results across multiple intervals will be merged together to produce a summary result.
	MergeIntervals bool `json:"mergeIntervals,omitempty" xml:"mergeIntervals,omitempty"`
	// If true, results from multiple streams will be merged together to produce a summary result.
	MergeStreams bool `json:"mergeStreams,omitempty" xml:"mergeStreams,omitempty"`
	// Specifies a minimum date time used to restrict the interval statistics returned.  Only statistics for intervals that are for a time range on or after this date time value will be returned.
	MinDateTime time.Time `json:"minDateTime,omitempty" xml:"minDateTime,omitempty"`
	// Specifies a minimum ordinal value used to restrict the interval statistics returned.  Only statistics for intervals that begin on or after this ordinal value will be returned.
	MinOrdinal int `json:"minOrdinal,omitempty" xml:"minOrdinal,omitempty"`
	// Specifies the criteria by which streams are to be matched
	StreamMatchSearchParams streamMatchSearchParams `json:"streamMatchCriteria,omitempty" xml:"streamMatchCriteria,omitempty"`
}

type TagParams struct {
	// If true, previously assigned tags will be cleared
	ClearAll bool `json:"clearAll,omitempty" xml:"clearAll,omitempty"`
	// Identifies the stream that the definition relates to
	Stream string `json:"stream,omitempty" xml:"stream,omitempty"`
	// An array of tags to be assigned
	TagsToAssign []string `json:"tagsToAssign,omitempty" xml:"tagsToAssign,omitempty"`
	// An array of tags to be unassigned
	TagsToUnassign []string `json:"tagsToUnassign,omitempty" xml:"tagsToUnassign,omitempty"`
}

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

type UnregisterParams struct {
	// Identifies the stream
	Stream string `json:"stream,omitempty" xml:"stream,omitempty"`
	// An array of tags to be matched
	WithTags []string `json:"tagsToAssign,omitempty" xml:"tagsToAssign,omitempty"`
	// An array of tags that exclude a stream from a match
	ExcludingTags []string `json:"tagsToUnassign,omitempty" xml:"tagsToUnassign,omitempty"`
}