destinationmockserver

Documentation

Index

• func NewRouter(entityStore EntityStore) http.Handler
• type DestinationMockServer
  • func New(config DestinationMockServerConfig) DestinationMockServer
  • func (s *DestinationMockServer) Run(ctx context.Context) error
• type DestinationMockServerConfig
• type EntityStore
  • func NewEntityStore() EntityStore
• type Event
• type Handlers
  • func (h *Handlers) ClearEvents(c *gin.Context)
  • func (h *Handlers) DeleteDestination(c *gin.Context)
  • func (h *Handlers) ListDestination(c *gin.Context)
  • func (h *Handlers) ListEvent(c *gin.Context)
  • func (h *Handlers) ReceiveWebhookEvent(c *gin.Context)
  • func (h *Handlers) UpsertDestination(c *gin.Context)

Functions

func NewRouter

func NewRouter(entityStore EntityStore) http.Handler

Types

type DestinationMockServer

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

func New

func New(config DestinationMockServerConfig) DestinationMockServer

func (*DestinationMockServer) Run

func (s *DestinationMockServer) Run(ctx context.Context) error

type DestinationMockServerConfig

type DestinationMockServerConfig struct {
	Port int
}

type EntityStore

type EntityStore interface {
	ListDestination(ctx context.Context) ([]models.Destination, error)
	RetrieveDestination(ctx context.Context, id string) (*models.Destination, error)
	UpsertDestination(ctx context.Context, destination models.Destination) error
	DeleteDestination(ctx context.Context, id string) error

	ReceiveEvent(ctx context.Context, destinationID string, payload map[string]interface{}, metadata map[string]string) (*Event, error)
	ListEvent(ctx context.Context, destinationID string) ([]Event, error)
	ClearEvents(ctx context.Context, destinationID string) error
}

func NewEntityStore

func NewEntityStore() EntityStore

type Event

type Event struct {
	Success  bool                   `json:"success"`
	Verified bool                   `json:"verified"`
	Payload  map[string]interface{} `json:"payload"`
}

type Handlers

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

func (*Handlers) ClearEvents

func (h *Handlers) ClearEvents(c *gin.Context)

func (*Handlers) DeleteDestination

func (h *Handlers) DeleteDestination(c *gin.Context)

func (*Handlers) ListDestination

func (h *Handlers) ListDestination(c *gin.Context)

func (*Handlers) ListEvent

func (h *Handlers) ListEvent(c *gin.Context)

func (*Handlers) ReceiveWebhookEvent

func (h *Handlers) ReceiveWebhookEvent(c *gin.Context)

func (*Handlers) UpsertDestination

func (h *Handlers) UpsertDestination(c *gin.Context)