base

Documentation

Index

• Constants
• type BaseLoggerPlugin
  • func (p *BaseLoggerPlugin) Consume()
  • func (p *BaseLoggerPlugin) Fire(entry map[string]any) error
  • func (p *BaseLoggerPlugin) Handler(next http.Handler) http.Handler
• type BasePlugin
  • func (p *BasePlugin) GetName() string
  • func (p *BasePlugin) GetPriority() int
  • func (p *BasePlugin) GetSchema() string

Constants

const (
	MAX_REQ_BODY  = 524288 // 512 KiB
	MAX_RESP_BODY = 524288 // 512 KiB
)

Types

type BaseLoggerPlugin

type BaseLoggerPlugin struct {
	BasePlugin

	FireChan   chan map[string]any
	AsyncBlock bool

	LogFormat map[string]string

	SendFunc func(log map[string]any)

	IncludeRequestBody  bool
	IncludeResponseBody bool
}

func (*BaseLoggerPlugin) Consume

func (p *BaseLoggerPlugin) Consume()

add a http log consumer here, to consume the log via a channel

func (*BaseLoggerPlugin) Fire

func (p *BaseLoggerPlugin) Fire(entry map[string]any) error

func (*BaseLoggerPlugin) Handler

func (p *BaseLoggerPlugin) Handler(next http.Handler) http.Handler

type BasePlugin

type BasePlugin struct {
	Name     string
	Priority int
	Schema   string
}

func (*BasePlugin) GetName

func (p *BasePlugin) GetName() string

func (*BasePlugin) GetPriority

func (p *BasePlugin) GetPriority() int

func (*BasePlugin) GetSchema

func (p *BasePlugin) GetSchema() string