fifo

Documentation

Overview

Package fifo provides Group, which is a list of modifiers that are executed consecutively. By default, when an error is returned by a modifier, the execution of the modifiers is halted, and the error is returned. Optionally, when errror aggregation is enabled (by calling SetAggretateErrors(true)), modifier execution is not halted, and errors are aggretated and returned after all modifiers have been executed.

Index

• type Group
  • func NewGroup() *Group
  • func (g *Group) AddRequestModifier(reqmod martian.RequestModifier)
  • func (g *Group) AddResponseModifier(resmod martian.ResponseModifier)
  • func (g *Group) ModifyRequest(req *http.Request) error
  • func (g *Group) ModifyResponse(res *http.Response) error
  • func (g *Group) SetAggregateErrors(aggerr bool)

Types

type Group

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

Group is a martian.RequestResponseModifier that maintains lists of request and response modifiers executed on a first-in, first-out basis.

func NewGroup

func NewGroup() *Group

NewGroup returns a modifier group.

func (*Group) AddRequestModifier

func (g *Group) AddRequestModifier(reqmod martian.RequestModifier)

AddRequestModifier adds a RequestModifier to the group's list of request modifiers.

func (*Group) AddResponseModifier

func (g *Group) AddResponseModifier(resmod martian.ResponseModifier)

AddResponseModifier adds a ResponseModifier to the group's list of response modifiers.

func (*Group) ModifyRequest

func (g *Group) ModifyRequest(req *http.Request) error

ModifyRequest modifies the request. By default, aggregateErrors is false; if an error is returned by a RequestModifier the error is returned and no further modifiers are run. When aggregateErrors is set to true, the errors returned by each modifier in the group are aggregated.

func (*Group) ModifyResponse

func (g *Group) ModifyResponse(res *http.Response) error

ModifyResponse modifies the request. By default, aggregateErrors is false; if an error is returned by a RequestModifier the error is returned and no further modifiers are run. When aggregateErrors is set to true, the errors returned by each modifier in the group are aggregated.

func (*Group) SetAggregateErrors

func (g *Group) SetAggregateErrors(aggerr bool)

SetAggregateErrors sets the error behavior for the Group. When true, the Group will continue to execute consecutive modifiers when a modifier in the group encounters an error. The Group will then return all errors returned by each modifier after all modifiers have been executed. When false, if an error is returned by a modifier, the error is returned by ModifyRequest/Response and no further modifiers are run. By default, error aggregation is disabled.