common

Documentation

Index

• func BindRequestPayload[S any](c *fiber.Ctx) *S
• func FiberConfig(disableStartupMsg bool) fiber.Config
• func GrpcConfig(p any) (err error)
• func Validate(s interface{}) []*common.ErrorResponse
• type ErrorHandlingBehavior
  • func NewErrorHandlingBehavior(prometheusMetricService metrics.PrometheusMetricService, log *zerolog.Logger, ...) ErrorHandlingBehavior
  • func (p ErrorHandlingBehavior) Process(ctx context.Context, msg mediator.Message, next mediator.Next) (interface{}, error)
• type LoggingBehavior
  • func NewLoggingBehavior(log *zerolog.Logger, settings *config.Settings) LoggingBehavior
  • func (p LoggingBehavior) Process(ctx context.Context, msg mediator.Message, next mediator.Next) (interface{}, error)
• type ProblemDetails
• type ValidationBehavior
  • func NewValidationBehavior(log *zerolog.Logger, settings *config.Settings) ValidationBehavior
  • func (p ValidationBehavior) Process(ctx context.Context, msg mediator.Message, next mediator.Next) (interface{}, error)

Functions

func BindRequestPayload

func BindRequestPayload[S any](c *fiber.Ctx) *S

func FiberConfig

func FiberConfig(disableStartupMsg bool) fiber.Config

func GrpcConfig

func GrpcConfig(p any) (err error)

func Validate

func Validate(s interface{}) []*common.ErrorResponse

Types

type ErrorHandlingBehavior

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

func NewErrorHandlingBehavior

func NewErrorHandlingBehavior(prometheusMetricService metrics.PrometheusMetricService, log *zerolog.Logger, settings *config.Settings) ErrorHandlingBehavior

func (ErrorHandlingBehavior) Process

func (p ErrorHandlingBehavior) Process(ctx context.Context, msg mediator.Message, next mediator.Next) (interface{}, error)

Process checks for errors in the pipeline to increment metrics and log in standard fashion

type LoggingBehavior

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

func NewLoggingBehavior

func NewLoggingBehavior(log *zerolog.Logger, settings *config.Settings) LoggingBehavior

func (LoggingBehavior) Process

func (p LoggingBehavior) Process(ctx context.Context, msg mediator.Message, next mediator.Next) (interface{}, error)

type ProblemDetails

type ProblemDetails struct {
	Type   string      `json:"type"`
	Title  string      `json:"title"`
	Status int         `json:"status"`
	Detail interface{} `json:"detail"`
}

type ValidationBehavior

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

func NewValidationBehavior

func NewValidationBehavior(log *zerolog.Logger, settings *config.Settings) ValidationBehavior

func (ValidationBehavior) Process

func (p ValidationBehavior) Process(ctx context.Context, msg mediator.Message, next mediator.Next) (interface{}, error)

Process validation check for all requests going through mediator. Logs if validation fails.