Versions in this module Expand all Collapse all v0 v0.0.2 Mar 8, 2023 v0.0.1 Mar 8, 2023 Changes in this version + type IStream interface + GetMessages func() <-chan StreamMessage + SetUnmarshalHook func(hook UnmarshalHook) + StartStream func(queryParams *url.Values) error + StopStream func() + func NewStream(httpClient httpclient.IHttpClient, reader IStreamResponseBodyReader) IStream + type IStreamQueryParamsBuilder interface + AddBackFillMinutes func(minutes uint) *StreamQueryParamBuilder + AddExpansion func(expansion string) *StreamQueryParamBuilder + AddMediaField func(mediaField string) *StreamQueryParamBuilder + AddPlaceField func(placeField string) *StreamQueryParamBuilder + AddPollField func(pollField string) *StreamQueryParamBuilder + AddTweetField func(tweetField string) *StreamQueryParamBuilder + AddUserField func(userField string) *StreamQueryParamBuilder + Build func() *url.Values + func NewStreamQueryParamsBuilder() IStreamQueryParamsBuilder + type IStreamResponseBodyReader interface + func NewStreamResponseBodyReader() IStreamResponseBodyReader + type Stream struct + func (s *Stream) GetMessages() <-chan StreamMessage + func (s *Stream) SetUnmarshalHook(hook UnmarshalHook) + func (s *Stream) StartStream(optionalQueryParams *url.Values) error + func (s *Stream) StopStream() + type StreamMessage struct + Data interface{} + Err error + type StreamQueryParamBuilder struct + func (s *StreamQueryParamBuilder) AddBackFillMinutes(backFillMinutes uint) *StreamQueryParamBuilder + func (s *StreamQueryParamBuilder) AddExpansion(expansion string) *StreamQueryParamBuilder + func (s *StreamQueryParamBuilder) AddMediaField(mediaField string) *StreamQueryParamBuilder + func (s *StreamQueryParamBuilder) AddPlaceField(placeField string) *StreamQueryParamBuilder + func (s *StreamQueryParamBuilder) AddPollField(pollField string) *StreamQueryParamBuilder + func (s *StreamQueryParamBuilder) AddTweetField(tweetField string) *StreamQueryParamBuilder + func (s *StreamQueryParamBuilder) AddUserField(userField string) *StreamQueryParamBuilder + func (s *StreamQueryParamBuilder) Build() *url.Values + type UnmarshalHook func([]byte) (interface{}, error)