Versions in this module Expand all Collapse all v1 v1.0.0 Aug 30, 2016 Changes in this version + func NewUUID() string + type Client struct + func NewClient(httpClient *http.Client, serverURL string) (*Client, error) + func (c *Client) DeleteHeader(key string) + func (c *Client) DeleteStream(streamName string, hardDelete bool) (*Response, error) + func (c *Client) Do(req *http.Request, v io.Writer) (*Response, error) + func (c *Client) GetEvent(url string) (*EventResponse, *Response, error) + func (c *Client) GetFeedPath(stream, direction string, version int, pageSize int) (string, error) + func (c *Client) GetMetadataURL(stream string) (string, *Response, error) + func (c *Client) NewRequest(method, urlString string, body interface{}) (*http.Request, error) + func (c *Client) NewStreamReader(streamName string) *StreamReader + func (c *Client) NewStreamWriter(streamName string) *StreamWriter + func (c *Client) ReadFeed(url string) (*atom.Feed, *Response, error) + func (c *Client) SetBasicAuth(username, password string) + func (c *Client) SetHeader(key, value string) + type ErrBadRequest struct + ErrorResponse *ErrorResponse + func (e ErrBadRequest) Error() string + type ErrConcurrencyViolation struct + ErrorResponse *ErrorResponse + func (e ErrConcurrencyViolation) Error() string + type ErrDeleted struct + ErrorResponse *ErrorResponse + func (e ErrDeleted) Error() string + type ErrNoMoreEvents struct + func (e ErrNoMoreEvents) Error() string + type ErrNotFound struct + ErrorResponse *ErrorResponse + func (e ErrNotFound) Error() string + type ErrTemporarilyUnavailable struct + ErrorResponse *ErrorResponse + func (e ErrTemporarilyUnavailable) Error() string + type ErrUnauthorized struct + ErrorResponse *ErrorResponse + func (e ErrUnauthorized) Error() string + type ErrUnexpected struct + ErrorResponse *ErrorResponse + func (e ErrUnexpected) Error() string + type ErrorResponse struct + Request *http.Request + Status string + StatusCode int + func (r *ErrorResponse) Error() string + type Event struct + Data interface{} + EventID string + EventNumber int + EventStreamID string + EventType string + Links []Link + MetaData interface{} + func NewEvent(eventID, eventType string, data interface{}, meta interface{}) *Event + func (e *Event) PrettyPrint() string + type EventAtomResponse struct + Content interface{} + ID string + Summary string + Title string + Updated TimeStr + func (e *EventAtomResponse) PrettyPrint() string + type EventResponse struct + Event *Event + ID string + Summary string + Title string + Updated TimeStr + func (e *EventResponse) PrettyPrint() string + type Link struct + Relation string + URI string + type Response struct + Status string + StatusCode int + type StreamReader struct + func (s *StreamReader) Err() error + func (s *StreamReader) EventResponse() *EventResponse + func (s *StreamReader) LongPoll(seconds int) + func (s *StreamReader) MetaData() (*EventResponse, error) + func (s *StreamReader) Next() bool + func (s *StreamReader) NextVersion(version int) + func (s *StreamReader) Scan(e interface{}, m interface{}) error + func (s *StreamReader) Version() int + type StreamWriter struct + func (s *StreamWriter) Append(expectedVersion *int, events ...*Event) error + func (s *StreamWriter) WriteMetaData(stream string, metadata interface{}) error + type TimeStr string + func Time(t time.Time) TimeStr