webhook

Sep 7, 2025

Changes in this version

+ type DescribeWebHookRequest struct

+ Id string

+ func NewDescribeWebHookRequest(id string) *DescribeWebHookRequest

type Service

+ DescribeWebHook func(context.Context, *DescribeWebHookRequest) (*WebHook, error)

type WebHook

+ Id string

+ func (e *WebHook) LoadFromEvent(event *bus.Event) error

+ func (e *WebHook) ToBusEvent(topic string) *bus.Event

type WebHookSpec

+ func NewWebHookSpec() *WebHookSpec

type WebHookStatus

+ UpdateAt *time.Time

+ func (w *WebHookStatus) SetUpdateAt(v time.Time) *WebHookStatus

+ func (w WebHookStatus) String() string

+ func (w WebHookStatus) TableName() string

Jul 6, 2025

Changes in this version

+ const APP_NAME

+ type QueryWebHookRequest struct

+ RefTaskId string

+ func NewQueryWebHookRequest() *QueryWebHookRequest

+ func (r *QueryWebHookRequest) SetRefTaskId(taskId string) *QueryWebHookRequest

+ type STATUS int

+ const STATUS_CANCELED

+ const STATUS_FAILED

+ const STATUS_PENDING

+ const STATUS_RUNNING

+ const STATUS_SUCCESS

+ type Service interface

+ QueryWebHook func(context.Context, *QueryWebHookRequest) (*types.Set[*WebHook], error)

+ Run func(context.Context, *WebHookSpec) *WebHook

+ func GetService() Service

+ type WebHook struct

+ CreatedAt time.Time

+ ID string

+ func NewWebHook(spec WebHookSpec) *WebHook

+ func (h *WebHook) Run(ctx context.Context)

+ func (h *WebHook) SetDefault()

+ func (h *WebHook) TableName() string

+ func (w *WebHook) Failed(err error) *WebHook

+ func (w *WebHook) Success() *WebHook

+ type WebHookSpec struct

+ Conditions []string

+ ContentType string

+ Description string

+ Headers map[string]string

+ Method string

+ Name string

+ Payload string

+ RefTaskId string

+ RetryCount int

+ Secret string

+ SignatureHeader string

+ TargetURL string

+ Timeout int

+ func (s *WebHookSpec) AddCondtion(conditions ...string)

+ func (s *WebHookSpec) IsCondtionOk(condition string) bool

+ type WebHookStatus struct

+ Message string

+ Status STATUS

+ func NewWebHookStatus() *WebHookStatus