sender

package

v0.7.0 Latest Latest Go to latest Published: Mar 29, 2022 License: MIT Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/dstotijn/hetty

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type Config
type FindRequestsFilter
type HTTPTransport
- func (t *HTTPTransport) RoundTrip(req *http.Request) (*http.Response, error)
type Repository
type Request
- func (req Request) MatchScope(s *scope.Scope) bool
- func (req Request) Matches(expr search.Expression) (bool, error)
type SendError
- func (e SendError) Error() string
- func (e SendError) Unwrap() error
type Service
- func NewService(cfg Config) Service

Constants ¶

View Source

const (
	HTTPProto10 = "HTTP/1.0"
	HTTPProto11 = "HTTP/1.1"
	HTTPProto20 = "HTTP/2.0"
)

Variables ¶

View Source

var (
	ErrProjectIDMustBeSet = errors.New("sender: project ID must be set")
	ErrRequestNotFound    = errors.New("sender: request not found")
)

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	Scope         *scope.Scope
	Repository    Repository
	ReqLogService reqlog.Service
	HTTPClient    *http.Client
}

type FindRequestsFilter ¶

type FindRequestsFilter struct {
	ProjectID   ulid.ULID
	OnlyInScope bool
	SearchExpr  search.Expression
}

type HTTPTransport ¶

type HTTPTransport struct{}

func (*HTTPTransport) RoundTrip ¶

func (t *HTTPTransport) RoundTrip(req *http.Request) (*http.Response, error)

RountTrip implements http.RoundTripper. Based on a context value on the HTTP request, it switches between using `http.DefaultTransport` (which attempts HTTP/2) and a HTTP/1.1 only transport that's based off `http.DefaultTransport`.

type Repository ¶

type Repository interface {
	FindSenderRequestByID(ctx context.Context, id ulid.ULID) (Request, error)
	FindSenderRequests(ctx context.Context, filter FindRequestsFilter, scope *scope.Scope) ([]Request, error)
	StoreSenderRequest(ctx context.Context, req Request) error
	StoreResponseLog(ctx context.Context, reqLogID ulid.ULID, resLog reqlog.ResponseLog) error
	DeleteSenderRequests(ctx context.Context, projectID ulid.ULID) error
}

type Request ¶

type Request struct {
	ID                 ulid.ULID
	ProjectID          ulid.ULID
	SourceRequestLogID ulid.ULID

	URL    *url.URL
	Method string
	Proto  string
	Header http.Header
	Body   []byte

	Response *reqlog.ResponseLog
}

func (Request) MatchScope ¶

func (req Request) MatchScope(s *scope.Scope) bool

func (Request) Matches ¶

func (req Request) Matches(expr search.Expression) (bool, error)

Matches returns true if the supplied search expression evaluates to true.

type SendError ¶

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

func (SendError) Error ¶

func (e SendError) Error() string

func (SendError) Unwrap ¶

func (e SendError) Unwrap() error

type Service ¶

type Service interface {
	FindRequestByID(ctx context.Context, id ulid.ULID) (Request, error)
	FindRequests(ctx context.Context) ([]Request, error)
	CreateOrUpdateRequest(ctx context.Context, req Request) (Request, error)
	CloneFromRequestLog(ctx context.Context, reqLogID ulid.ULID) (Request, error)
	DeleteRequests(ctx context.Context, projectID ulid.ULID) error
	SendRequest(ctx context.Context, id ulid.ULID) (Request, error)
	SetActiveProjectID(ulid.ULID)
	SetFindReqsFilter(filter FindRequestsFilter)
	FindReqsFilter() FindRequestsFilter
}

func NewService ¶

func NewService(cfg Config) Service

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL