Skip to content

StreamingQuery🔗

Definition🔗

type StreamingQuery struct {
    Bands *int64 `json:"bands,omitempty"`
    Noise float64 `json:"noise"`
    Speed float64 `json:"speed"`
    Spread float64 `json:"spread"`
    // Possible enum values:
    //  - `"fetch"` 
    //  - `"logs"` 
    //  - `"signal"` 
    //  - `"traces"` 
    Type testdata.StreamingQueryType `json:"type"`
    Url *string `json:"url,omitempty"`
}

Methods🔗

UnmarshalJSONStrict🔗

UnmarshalJSONStrict implements a custom JSON unmarshalling logic to decode StreamingQuery from JSON.

Note: the unmarshalling done by this function is strict. It will fail over required fields being absent from the input, fields having an incorrect type, unexpected fields being present, …

func (streamingQuery *StreamingQuery) UnmarshalJSONStrict(raw []byte) error

Equals🔗

Equals tests the equality of two StreamingQuery objects.

func (streamingQuery *StreamingQuery) Equals(other StreamingQuery) bool

Validate🔗

Validate checks all the validation constraints that may be defined on StreamingQuery fields for violations and returns them.

func (streamingQuery *StreamingQuery) Validate() error

See also🔗

StreamingQueryBuilder