webhooks

Oct 10, 2024

Changes in this version

type MockWebhookManager

+ func (_m *MockWebhookManager) IsEventConfigured(_a0 EventType) bool

+ type WebhookError struct

+ func NewWebhookError(err error) *WebhookError

+ func (e *WebhookError) Error() string

+ func (e *WebhookError) Is(target error) bool

+ func (e *WebhookError) Unwrap() error

Jun 5, 2024

Changes in this version

+ func NoOpCallback([]byte) error

+ func NoOpErrorHandler(err error) error

+ type Config struct

+ Config map[EventType][]WebhookConfig

+ Enabled bool

+ type EventType string

+ type MockWebhookClient struct

+ func NewMockWebhookClient(t interface{ ... }) *MockWebhookClient

+ func (_m *MockWebhookClient) GetName() string

+ func (_m *MockWebhookClient) GetUseDataFrom() string

+ func (_m *MockWebhookClient) Invoke(_a0 context.Context, _a1 []byte) ([]byte, error)

+ func (_m *MockWebhookClient) IsAsync() bool

+ func (_m *MockWebhookClient) IsFinalResponse() bool

+ type MockWebhookManager struct

+ func NewMockWebhookManager(t interface{ ... }) *MockWebhookManager

+ func (_m *MockWebhookManager) InvokeWebhooks(_a0 context.Context, _a1 EventType, _a2 interface{}, _a3 func([]byte) error, ...) error

+ type ServiceType string

+ type SimpleWebhookManager struct

+ AsyncClients map[EventType][]WebhookClient

+ SyncClients map[EventType][]WebhookClient

+ func (w *SimpleWebhookManager) InvokeWebhooks(ctx context.Context, event EventType, p interface{}, ...) error

+ func (w *SimpleWebhookManager) IsEventConfigured(event EventType) bool

+ type WebhookClient interface

+ GetName func() string

+ GetUseDataFrom func() string

+ Invoke func(context.Context, []byte) ([]byte, error)

+ IsAsync func() bool

+ IsFinalResponse func() bool

+ type WebhookConfig struct

+ Async bool

+ AuthEnabled bool

+ AuthToken string

+ FinalResponse bool

+ Method string

+ Name string

+ NumRetries int

+ Timeout *int

+ URL string

+ UseDataFrom string

+ type WebhookManager interface

+ InvokeWebhooks func(context.Context, EventType, interface{}, func(payload []byte) error, ...) error

+ IsEventConfigured func(EventType) bool

+ func InitializeWebhooks(cfg *Config, eventList []EventType) (WebhookManager, error)

+ type WebhookType string

+ const Async

+ const Sync