longpollclient

Documentation

Index

• type Event
• type LongPollClient
  • func NewLongPollClient(config LongPollClientConfig) (*LongPollClient, error)
  • func (c *LongPollClient) PullOnce(since time.Time) ([]Event, error)
  • func (c *LongPollClient) Start(since time.Time) chan Event
  • func (c *LongPollClient) Stop() error
• type LongPollClientConfig

Types

type Event

type Event struct {
	Timestamp int64     `json:"timestamp"`
	Category  string    `json:"category"`
	Data      string    `json:"data"`
	ID        uuid.UUID `json:"id"`
	RequestId string
}

type LongPollClient

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

func NewLongPollClient

func NewLongPollClient(config LongPollClientConfig) (*LongPollClient, error)

func (*LongPollClient) PullOnce

func (c *LongPollClient) PullOnce(since time.Time) ([]Event, error)

func (*LongPollClient) Start

func (c *LongPollClient) Start(since time.Time) chan Event

func (*LongPollClient) Stop

func (c *LongPollClient) Stop() error

type LongPollClientConfig

type LongPollClientConfig struct {
	Url        url.URL
	Logger     *log.Logger
	HttpClient *http.Client
}