contentexthandler

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 1, 2026 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Handler

type Handler[TRequest any, TResponse any] struct {
	// contains filtered or unexported fields
}

func New

func New[TRequest any, TResponse any](options Options[TRequest, TResponse]) *Handler[TRequest, TResponse]

func (*Handler[TRequest, TResponse]) Checkpoint

func (h *Handler[TRequest, TResponse]) Checkpoint(ctx *workflow.Context) error

func (*Handler[TRequest, TResponse]) ConfigureRoutes

func (h *Handler[TRequest, TResponse]) ConfigureRoutes(rb *workflow.RouteBuilder) *workflow.RouteBuilder

func (*Handler[TRequest, TResponse]) DispatchRequest

func (h *Handler[TRequest, TResponse]) DispatchRequest(ctx *workflow.Context, request TRequest) error

func (*Handler[TRequest, TResponse]) HandleExternalResponse

func (h *Handler[TRequest, TResponse]) HandleExternalResponse(ctx *workflow.Context, resp *workflow.ExternalResponse) (bool, error)

func (*Handler[TRequest, TResponse]) HasPending

func (h *Handler[TRequest, TResponse]) HasPending(ctx *workflow.Context) (bool, error)

func (*Handler[TRequest, TResponse]) MarkRequestAsHandled

func (h *Handler[TRequest, TResponse]) MarkRequestAsHandled(ctx *workflow.Context, response TResponse) (bool, error)

func (*Handler[TRequest, TResponse]) Reset

func (h *Handler[TRequest, TResponse]) Reset() error

func (*Handler[TRequest, TResponse]) Restore

func (h *Handler[TRequest, TResponse]) Restore(ctx *workflow.Context) error

func (*Handler[TRequest, TResponse]) TrackRequest

func (h *Handler[TRequest, TResponse]) TrackRequest(ctx *workflow.Context, request TRequest) (bool, error)

type Options

type Options[TRequest any, TResponse any] struct {
	Port              workflow.RequestPort
	PendingRequestsID string
	Intercepted       bool
	RequestID         func(TRequest) string
	ResponseID        func(TResponse) string
	ResponseHandler   func(*workflow.Context, TResponse) error
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL