Documentation
¶
Index ¶
- type WebHookServiceImpl
- func (i *WebHookServiceImpl) DescribeWebHook(ctx context.Context, in *webhook.DescribeWebHookRequest) (*webhook.WebHook, error)
- func (i *WebHookServiceImpl) Init() error
- func (i *WebHookServiceImpl) Name() string
- func (i *WebHookServiceImpl) QueryWebHook(ctx context.Context, in *webhook.QueryWebHookRequest) (*types.Set[*webhook.WebHook], error)
- func (i *WebHookServiceImpl) Run(ctx context.Context, in *webhook.WebHookSpec) (*webhook.WebHook, error)
- func (i *WebHookServiceImpl) RunWebHookConsumer(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WebHookServiceImpl ¶
type WebHookServiceImpl struct { ioc.ObjectImpl // 当前这个消费者 配置的topic WebhookQueue string `toml:"webhook_topic" json:"webhook_topic" yaml:"webhook_topic" env:"WEBHOOK_TOPIC"` // contains filtered or unexported fields }
func (*WebHookServiceImpl) DescribeWebHook ¶ added in v0.0.21
func (i *WebHookServiceImpl) DescribeWebHook(ctx context.Context, in *webhook.DescribeWebHookRequest) (*webhook.WebHook, error)
查询WebHook具体执行状态
func (*WebHookServiceImpl) Init ¶
func (i *WebHookServiceImpl) Init() error
func (*WebHookServiceImpl) Name ¶
func (i *WebHookServiceImpl) Name() string
func (*WebHookServiceImpl) QueryWebHook ¶
func (i *WebHookServiceImpl) QueryWebHook(ctx context.Context, in *webhook.QueryWebHookRequest) (*types.Set[*webhook.WebHook], error)
QueryWebHook implements webhook.Service.
func (*WebHookServiceImpl) Run ¶
func (i *WebHookServiceImpl) Run(ctx context.Context, in *webhook.WebHookSpec) (*webhook.WebHook, error)
Run implements webhook.Service.
func (*WebHookServiceImpl) RunWebHookConsumer ¶ added in v0.0.21
func (i *WebHookServiceImpl) RunWebHookConsumer(ctx context.Context) error
Click to show internal directories.
Click to hide internal directories.