ekuiperclient

Documentation

Index

• Constants
• type EkuiperClient
  • func New(baseUrl string, lc logger.LoggingClient) EkuiperClient

Constants

const (
	ApiRuleInfoRoute    = "/rules/%s"
	ApiRuleStatusRoute  = "/rules/%s/status"
	ApiRuleCreateRoute  = "/rules"
	ApiRuleStopRoute    = "/rules/%s/stop"
	ApiRuleStartRoute   = "/rules/%s/start"
	ApiRuleRestartRoute = "/rules/%s/restart"
	ApiRuleDeleteRoute  = "/rules/%s"
	ApiRuleUpdateRoute  = "/rules/%s"
)

Types

type EkuiperClient

type EkuiperClient interface {
	RuleExist(ctx context.Context, ruleId string) (bool, error)
	CreateRule(ctx context.Context, actions []dtos.Actions, ruleId string, sql string) error
	UpdateRule(ctx context.Context, actions []dtos.Actions, ruleId string, sql string) error
	GetRuleStats(ctx context.Context, ruleId string) (map[string]interface{}, error)
	StartRule(ctx context.Context, ruleId string) error
	StopRule(ctx context.Context, ruleId string) error
	RestartRule(ctx context.Context, ruleId string) error
	DeleteRule(ctx context.Context, ruleId string) error
}

func New

func New(baseUrl string, lc logger.LoggingClient) EkuiperClient