Documentation ¶
Index ¶
- func NewInstance(_ twitterclient.Config) twitterclient.Interface
- type Instance
- func (instance *Instance) AddStreams(streams []entity.StreamInterface)
- func (instance *Instance) DeleteStreams([]int64)
- func (instance *Instance) GetStreams() map[int64]entity.StreamInterface
- func (instance *Instance) Start() error
- func (instance *Instance) Unwatch()
- func (instance *Instance) Watch(output chan entity.TweetStreamsInterface) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewInstance ¶
func NewInstance(_ twitterclient.Config) twitterclient.Interface
NewInstance creates new twitter scrapper (void)
Types ¶
type Instance ¶
type Instance struct {
// contains filtered or unexported fields
}
Instance structure is used to store the server's state
func (*Instance) AddStreams ¶
func (instance *Instance) AddStreams(streams []entity.StreamInterface)
AddStreams adds desired stream to the current instance of twitterclient
func (*Instance) DeleteStreams ¶
DeleteStreams removes desired stream to the current instance of twitterclient
func (*Instance) GetStreams ¶
func (instance *Instance) GetStreams() map[int64]entity.StreamInterface
GetStreams returns all the streams from the current instance of twitterclient
Click to show internal directories.
Click to hide internal directories.