builtin

Documentation

Index

• func NewLogWriterTask(config map[string]interface{}) (entity.Task, error)
• func NewRequestLoggerTask(config map[string]interface{}) (entity.Task, error)
• func NewResponseLoggerTask(config map[string]interface{}) (entity.Task, error)
• type LogField
• type LogWriter
  • func (lw *LogWriter) Apply(ctx context.Context, request entity.ServiceRequest) error
  • func (lw *LogWriter) Name() string
• type RequestBodyValidator
  • func NewRequestValidator[T any](rules map[string][]string) RequestBodyValidator
• type RequestLogger
  • func (rl *RequestLogger) Apply(ctx context.Context, request entity.ServiceRequest) error
  • func (rl *RequestLogger) Name() string
• type ResponseLogger
  • func (rl *ResponseLogger) Apply(ctx context.Context, request entity.ServiceRequest) error
  • func (rl *ResponseLogger) Name() string

Functions

func NewLogWriterTask

func NewLogWriterTask(config map[string]interface{}) (entity.Task, error)

func NewRequestLoggerTask

func NewRequestLoggerTask(config map[string]interface{}) (entity.Task, error)

func NewResponseLoggerTask

func NewResponseLoggerTask(config map[string]interface{}) (entity.Task, error)

Types

type LogField

type LogField struct {
	Name  string
	Value string
}

type LogWriter

type LogWriter struct {
	LogLevel string
	Fields   []LogField
	// contains filtered or unexported fields
}

func (*LogWriter) Apply

func (lw *LogWriter) Apply(ctx context.Context, request entity.ServiceRequest) error

func (*LogWriter) Name

func (lw *LogWriter) Name() string

type RequestBodyValidator

type RequestBodyValidator interface {
}

func NewRequestValidator

func NewRequestValidator[T any](rules map[string][]string) RequestBodyValidator

type RequestLogger

type RequestLogger struct {
	LogLevel string
	// contains filtered or unexported fields
}

func (*RequestLogger) Apply

func (rl *RequestLogger) Apply(ctx context.Context, request entity.ServiceRequest) error

func (*RequestLogger) Name

func (rl *RequestLogger) Name() string

type ResponseLogger

type ResponseLogger struct {
	LogLevel string
	// contains filtered or unexported fields
}

func (*ResponseLogger) Apply

func (rl *ResponseLogger) Apply(ctx context.Context, request entity.ServiceRequest) error

func (*ResponseLogger) Name

func (rl *ResponseLogger) Name() string