daemon

Documentation

Index

• Constants
• func CORSMiddleware() mux.MiddlewareFunc
• type CloneRequest
• type FormFile
• type FormPart
• type HttpCookie
• type HttpRequest
• type HttpResponse
• type HttpTransaction
• type WiretapService
  • func NewWiretapService(document libopenapi.Document, config *shared.WiretapConfiguration) *WiretapService
  • func (ws *WiretapService) HandleHttpRequest(request *model.Request)
  • func (ws *WiretapService) HandleServiceRequest(request *model.Request, core service.FabricServiceCore)
  • func (ws *WiretapService) Init(core service.FabricServiceCore) error

Constants

const (
	WiretapServiceChan   = "wiretap"
	WiretapBroadcastChan = "wiretap-broadcast"
	IncomingHttpRequest  = "incoming-http-request"
)

Functions

func CORSMiddleware

func CORSMiddleware() mux.MiddlewareFunc

Types

type CloneRequest

type CloneRequest struct {
	Request     *http.Request
	Protocol    string
	Host        string
	Port        string
	DropHeaders []string
}

type FormFile

type FormFile struct {
	Name    string               `json:"name,omitempty"`
	Headers textproto.MIMEHeader `json:"headers,omitempty"`
	Data    string               `json:"data,omitempty"`
}

type FormPart

type FormPart struct {
	Name  string      `json:"name,omitempty"`
	Value []string    `json:"value,omitempty"`
	Files []*FormFile `json:"files,omitempty"`
}

type HttpCookie

type HttpCookie struct {
	Value   string `json:"value,omitempty"`
	Path    string `json:"path,omitempty"`
	Domain  string `json:"domain,omitempty"`
	Expires string `json:"expires,omitempty"`
	// MaxAge=0 means no 'Max-Age' attribute specified.
	// MaxAge<0 means delete cookie now, equivalently 'Max-Age: 0'
	// MaxAge>0 means Max-Age attribute present and given in seconds
	MaxAge   int  `json:"maxAge,omitempty"`
	Secure   bool `json:"secure,omitempty"`
	HttpOnly bool `json:"httpOnly,omitempty"`
}

type HttpRequest

type HttpRequest struct {
	Timestamp int64                  `json:"timestamp,omitempty"`
	URL       string                 `json:"url,omitempty"`
	Method    string                 `json:"method,omitempty"`
	Path      string                 `json:"path,omitempty"`
	Query     string                 `json:"query,omitempty"`
	Headers   map[string]any         `json:"headers,omitempty"`
	Body      string                 `json:"requestBody,omitempty"`
	Cookies   map[string]*HttpCookie `json:"cookies,omitempty"`
}

type HttpResponse

type HttpResponse struct {
	Timestamp  int64                  `json:"timestamp,omitempty"`
	Headers    map[string]any         `json:"headers,omitempty"`
	StatusCode int                    `json:"statusCode,omitempty"`
	Body       string                 `json:"responseBody,omitempty"`
	Cookies    map[string]*HttpCookie `json:"cookies,omitempty"`
	Time       time.Time              `json:"-"`
}

type HttpTransaction

type HttpTransaction struct {
	Request            *HttpRequest              `json:"httpRequest,omitempty"`
	RequestValidation  []*errors.ValidationError `json:"requestValidation,omitempty"`
	Response           *HttpResponse             `json:"httpResponse,omitempty"`
	ResponseValidation []*errors.ValidationError `json:"responseValidation,omitempty"`
	Id                 string                    `json:"id,omitempty"`
}

type WiretapService

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

func NewWiretapService

func NewWiretapService(document libopenapi.Document, config *shared.WiretapConfiguration) *WiretapService

func (*WiretapService) HandleHttpRequest

func (ws *WiretapService) HandleHttpRequest(request *model.Request)

func (*WiretapService) HandleServiceRequest

func (ws *WiretapService) HandleServiceRequest(request *model.Request, core service.FabricServiceCore)

func (*WiretapService) Init

func (ws *WiretapService) Init(core service.FabricServiceCore) error