Documentation
¶
Index ¶
- Constants
- func GetResponseResultMap(resp *http.Response) (result map[string]any, err error)
- func GetResponseResultTextAndMap(resp *http.Response) (body []byte, result map[string]any, err error)
- func GetResponseText(resp *http.Response) (string, error)
- func TryAssert(count int, interval time.Duration, tryFunc func() bool) bool
- type SDK
- func (sdk *SDK) AddRuleTags(name string, tags []string) (resp *http.Response, err error)
- func (sdk *SDK) BatchRequest(reqs []*server.EachRequest) ([]*server.EachResponse, error)
- func (sdk *SDK) CreateConf(confpath string, conf map[string]any) (resp *http.Response, err error)
- func (sdk *SDK) CreateRule(ruleJson string) (resp *http.Response, err error)
- func (sdk *SDK) CreateStream(streamJson string) (resp *http.Response, err error)
- func (sdk *SDK) CreateTable(tableJson string) (resp *http.Response, err error)
- func (sdk *SDK) Delete(command string) (resp *http.Response, err error)
- func (sdk *SDK) DeleteRule(name string) (resp *http.Response, err error)
- func (sdk *SDK) DeleteStream(name string) (resp *http.Response, err error)
- func (sdk *SDK) DeleteTables(name string) (resp *http.Response, err error)
- func (sdk *SDK) Get(command string) (resp *http.Response, err error)
- func (sdk *SDK) GetRuleSchema(name string) (map[string]any, error)
- func (sdk *SDK) GetRuleStatus(name string) (map[string]any, error)
- func (sdk *SDK) GetRulesByTags(tags []string) (list []string, err error)
- func (sdk *SDK) GetStreamSchema(name string) (map[string]any, error)
- func (sdk *SDK) Import(content string) (resp *http.Response, err error)
- func (sdk *SDK) Post(command string, body string) (resp *http.Response, err error)
- func (sdk *SDK) PostWithParam(command string, param string, body string) (resp *http.Response, err error)
- func (sdk *SDK) RemoveRuleTags(name string, keys []string) (resp *http.Response, err error)
- func (sdk *SDK) Req(command string, method string, body string) (resp *http.Response, err error)
- func (sdk *SDK) ResetRuleTags(name string, tags []string) (resp *http.Response, err error)
- func (sdk *SDK) RestartRule(ruleId string) (resp *http.Response, err error)
- func (sdk *SDK) StartRule(ruleId string) (resp *http.Response, err error)
- func (sdk *SDK) StopRule(ruleId string) (resp *http.Response, err error)
- func (sdk *SDK) UpdateRule(name, ruleJson string) (resp *http.Response, err error)
Constants ¶
View Source
const ContentTypeJson = "application/json"
Variables ¶
This section is empty.
Functions ¶
func GetResponseResultMap ¶
Types ¶
type SDK ¶
type SDK struct {
// contains filtered or unexported fields
}
func (*SDK) AddRuleTags ¶ added in v2.2.0
func (*SDK) BatchRequest ¶ added in v2.2.0
func (sdk *SDK) BatchRequest(reqs []*server.EachRequest) ([]*server.EachResponse, error)
func (*SDK) CreateConf ¶
func (*SDK) CreateRule ¶
func (*SDK) CreateStream ¶
func (*SDK) CreateTable ¶ added in v2.3.0
func (*SDK) DeleteStream ¶
func (*SDK) DeleteTables ¶ added in v2.3.0
func (*SDK) GetRuleSchema ¶ added in v2.3.0
func (*SDK) GetRulesByTags ¶ added in v2.2.0
func (*SDK) GetStreamSchema ¶ added in v2.3.0
func (*SDK) PostWithParam ¶
func (*SDK) RemoveRuleTags ¶ added in v2.2.0
func (*SDK) ResetRuleTags ¶ added in v2.2.1
func (*SDK) RestartRule ¶
Source Files
Click to show internal directories.
Click to hide internal directories.