reqlog

Documentation

Index

• Constants
• Variables
• type Config
• type FindRequestsFilter
• type Repository
• type RepositoryProvider
• type Request
• type Response
• type Service
  • func NewService(cfg Config) *Service
  • func (svc *Service) FindRequestLogByID(ctx context.Context, id int64) (Request, error)
  • func (svc *Service) FindRequests(ctx context.Context) ([]Request, error)
  • func (svc *Service) RequestModifier(next proxy.RequestModifyFunc) proxy.RequestModifyFunc
  • func (svc *Service) ResponseModifier(next proxy.ResponseModifyFunc) proxy.ResponseModifyFunc
  • func (svc *Service) SetRequestLogFilter(ctx context.Context, filter FindRequestsFilter) error

Constants

const LogBypassedKey contextKey = 0

Variables

var (
	ErrRequestNotFound = errors.New("reqlog: request not found")
)

Types

type Config

type Config struct {
	Scope                    *scope.Scope
	Repository               Repository
	ProjectService           *proj.Service
	BypassOutOfScopeRequests bool
}

type FindRequestsFilter

type FindRequestsFilter struct {
	OnlyInScope bool
}

type Repository

type Repository interface {
	FindRequestLogs(ctx context.Context, filter FindRequestsFilter, scope *scope.Scope) ([]Request, error)
	FindRequestLogByID(ctx context.Context, id int64) (Request, error)
	AddRequestLog(ctx context.Context, req http.Request, body []byte, timestamp time.Time) (*Request, error)
	AddResponseLog(ctx context.Context, reqID int64, res http.Response, body []byte, timestamp time.Time) (*Response, error)
	UpsertSettings(ctx context.Context, module string, settings interface{}) error
	FindSettingsByModule(ctx context.Context, module string, settings interface{}) error
}

type RepositoryProvider

type RepositoryProvider interface {
	Repository() Repository
}

type Request

type Request struct {
	ID        int64
	Request   http.Request
	Body      []byte
	Timestamp time.Time
	Response  *Response
}

type Response

type Response struct {
	ID        int64
	RequestID int64
	Response  http.Response
	Body      []byte
	Timestamp time.Time
}

type Service

type Service struct {
	BypassOutOfScopeRequests bool
	FindReqsFilter           FindRequestsFilter
	// contains filtered or unexported fields
}

func NewService

func NewService(cfg Config) *Service

func (*Service) FindRequestLogByID

func (svc *Service) FindRequestLogByID(ctx context.Context, id int64) (Request, error)

func (*Service) FindRequests

func (svc *Service) FindRequests(ctx context.Context) ([]Request, error)

func (*Service) RequestModifier

func (svc *Service) RequestModifier(next proxy.RequestModifyFunc) proxy.RequestModifyFunc

func (*Service) ResponseModifier

func (svc *Service) ResponseModifier(next proxy.ResponseModifyFunc) proxy.ResponseModifyFunc

func (*Service) SetRequestLogFilter

func (svc *Service) SetRequestLogFilter(ctx context.Context, filter FindRequestsFilter) error