Documentation ¶
Index ¶
- type Client
- func (client *Client) AddRule(streamLabel string, rule *types.Rule) (*types.RuleRequestResponse, error)
- func (client *Client) AddRules(streamLabel string, rules []*types.Rule) (*types.RuleRequestResponse, error)
- func (client *Client) ConnectPowertrack(streamLabel string) (<-chan interface{}, error)
- func (client *Client) GetRule(streamLabel string, rule *types.Rule) (*types.RuleRequestResponse, error)
- func (client *Client) GetRules(streamLabel string) (*types.RuleRequestResponse, error)
- func (client *Client) IsActive() bool
- func (client *Client) RemoveRule(streamLabel string, rule *types.Rule) (*types.RuleRequestResponse, error)
- func (client *Client) RemoveRules(streamLabel string, rules []*types.Rule) (*types.RuleRequestResponse, error)
- func (client *Client) StopPowertrack()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client ...
func (*Client) AddRule ¶
func (client *Client) AddRule(streamLabel string, rule *types.Rule) (*types.RuleRequestResponse, error)
AddRule ...
func (*Client) AddRules ¶
func (client *Client) AddRules(streamLabel string, rules []*types.Rule) (*types.RuleRequestResponse, error)
AddRules ...
func (*Client) ConnectPowertrack ¶
ConnectPowertrack ...
func (*Client) GetRule ¶
func (client *Client) GetRule(streamLabel string, rule *types.Rule) (*types.RuleRequestResponse, error)
GetRule ...
func (*Client) GetRules ¶
func (client *Client) GetRules(streamLabel string) (*types.RuleRequestResponse, error)
GetRules ...
func (*Client) RemoveRule ¶
func (client *Client) RemoveRule(streamLabel string, rule *types.Rule) (*types.RuleRequestResponse, error)
RemoveRule ...
func (*Client) RemoveRules ¶
func (client *Client) RemoveRules(streamLabel string, rules []*types.Rule) (*types.RuleRequestResponse, error)
RemoveRules ...
Click to show internal directories.
Click to hide internal directories.