webhook

Documentation

Index

• func Execute(ctx context.Context, data code_data.Provider, ...) error
• type TestWebhookEndpoint
  • func NewTestWebhookEndpoint(t *testing.T) *TestWebhookEndpoint
  • func (s *TestWebhookEndpoint) GetRandomWebhookRecord(t *testing.T, webhookType webhook.Type) *webhook.Record
  • func (s *TestWebhookEndpoint) GetReceivedRequests() []string
  • func (s *TestWebhookEndpoint) Reset()
  • func (s *TestWebhookEndpoint) SimulateDelay(delay time.Duration)
  • func (s *TestWebhookEndpoint) SimulateErrors()

Functions

func Execute

func Execute(
	ctx context.Context,
	data code_data.Provider,
	messagingClient messaging.InternalMessageClient,
	record *webhook.Record,
	webhookTimeout time.Duration,
) error

Execute executes the provided webhook. It does not manage the DB record's state.

Types

type TestWebhookEndpoint

type TestWebhookEndpoint struct {
	// contains filtered or unexported fields
}

func NewTestWebhookEndpoint

func NewTestWebhookEndpoint(t *testing.T) *TestWebhookEndpoint

NewTestWebhookEndpoint returns a new server for testing webhook execution

func (*TestWebhookEndpoint) GetRandomWebhookRecord

func (s *TestWebhookEndpoint) GetRandomWebhookRecord(t *testing.T, webhookType webhook.Type) *webhook.Record

func (*TestWebhookEndpoint) GetReceivedRequests

func (s *TestWebhookEndpoint) GetReceivedRequests() []string

func (*TestWebhookEndpoint) Reset

func (s *TestWebhookEndpoint) Reset()

func (*TestWebhookEndpoint) SimulateDelay

func (s *TestWebhookEndpoint) SimulateDelay(delay time.Duration)

func (*TestWebhookEndpoint) SimulateErrors

func (s *TestWebhookEndpoint) SimulateErrors()