daemon

Documentation

Index

• Constants
• func CORSMiddleware() mux.MiddlewareFunc
• type HttpCookie
• type HttpRequest
• type HttpResponse
• type HttpTransaction
• type WiretapService
  • func NewWiretapService(document libopenapi.Document) *WiretapService
  • 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 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 {
	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 {
	Headers    map[string]any         `json:"headers,omitempty"`
	StatusCode int                    `json:"statusCode,omitempty"`
	Body       string                 `json:"responseBody,omitempty"`
	Cookies    map[string]*HttpCookie `json:"cookies,omitempty"`
}

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) *WiretapService

func (*WiretapService) HandleServiceRequest

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

func (*WiretapService) Init

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