streams

Documentation

Index

• Constants
• type Client
  • func NewClient(event string) *Client
  • func (client *Client) GetStreamData(stream string, handlerFunc interface{}) error
  • func (client *Client) LastTimestamp() string
  • func (client *Client) Match(attribute string, value interface{}) *Client
  • func (client *Client) UnmarshalJSONBasedOnStream(stream string, handlerFunc interface{}, lastSub *time.Time) error

Constants

const (
	// DefaultURL is the URL of the Wikimedia EventStreams service (sans any stream endpoints)
	DefaultURL string = "https://stream.wikimedia.org/v2/stream"
)

Types

type Client

type Client struct {
	BaseURL    string
	Predicates map[string]interface{}
	Since      string
	// contains filtered or unexported fields
}

Client is used to subscribe to the Wikimedia EventStreams service

func NewClient

func NewClient(event string) *Client

NewClient returns an initialized Client

func (*Client) GetStreamData

func (client *Client) GetStreamData(stream string, handlerFunc interface{}) error

RecentChanges subscribes to the recent changes feed. The handler is invoked with a RecentChangeEvent once for every matching event received.

func (*Client) LastTimestamp

func (client *Client) LastTimestamp() string

LastTimestamp returns the ISO8601 formatted timestamp of the last event received.

func (*Client) Match

func (client *Client) Match(attribute string, value interface{}) *Client

Match adds a new predicate. Predicates are used to used to establish a match based on the JSON attribute name. Events match only when all predicates do.

func (*Client) UnmarshalJSONBasedOnStream

func (client *Client) UnmarshalJSONBasedOnStream(stream string, handlerFunc interface{}, lastSub *time.Time) error