Documentation ¶
Index ¶
- type Client
- func (c *Client) Append(req *wtypes.AppendToStreamRequest) (*wtypes.AppendToStreamOutput, error)
- func (c *Client) CreateStream(req *wtypes.CreateStreamRequest) (*wtypes.CreateStreamOutput, error)
- func (c *Client) SubscribeToStream(req *wtypes.SubscribeToStreamRequest) error
- func (c *Client) UnsubscribeFromStream(req *wtypes.UnsubscribeFromStreamRequest) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct { }
func (*Client) Append ¶
func (c *Client) Append(req *wtypes.AppendToStreamRequest) (*wtypes.AppendToStreamOutput, error)
func (*Client) CreateStream ¶
func (c *Client) CreateStream(req *wtypes.CreateStreamRequest) (*wtypes.CreateStreamOutput, error)
func (*Client) SubscribeToStream ¶
func (c *Client) SubscribeToStream(req *wtypes.SubscribeToStreamRequest) error
func (*Client) UnsubscribeFromStream ¶
func (c *Client) UnsubscribeFromStream(req *wtypes.UnsubscribeFromStreamRequest) error
Click to show internal directories.
Click to hide internal directories.