Versions in this module Expand all Collapse all v0 v0.2.0 Mar 31, 2017 v0.1.0 Mar 29, 2017 Changes in this version + type Client struct + func New(confCtx *config.Context) *Client + func (c *Client) Append(req *wtypes.AppendToStreamRequest) (*wtypes.AppendToStreamOutput, error) + func (c *Client) CreateStream(req *wtypes.CreateStreamRequest) (*wtypes.CreateStreamOutput, error) + func (c *Client) LiveRead(input *wtypes.LiveReadInput) (reader io.Reader, wasFileNotExist bool, err error) + func (c *Client) SubscribeToStream(req *wtypes.SubscribeToStreamRequest) error + func (c *Client) UnsubscribeFromStream(req *wtypes.UnsubscribeFromStreamRequest) error
Go to main page