headers

Documentation

Index

• Constants
• func AddCaller(header http.Header, ref *schema.VerbRef)
• func GetCaller(header http.Header) (optional.Option[*schema.VerbRef], error)
• func GetCallers(header http.Header) ([]*schema.VerbRef, error)
• func GetRequestName(header http.Header) (model.RequestName, bool, error)
• func IsDirectRouted(header http.Header) bool
• func SetCallers(header http.Header, refs []*schema.VerbRef)
• func SetDirectRouted(header http.Header)
• func SetRequestName(header http.Header, key model.RequestName)

Constants

const (
	DirectRoutingHeader = "FTL-Direct"
	// VerbHeader is the header used to pass the module.verb of the current request.
	//
	// One header will be present for each hop in the request path.
	VerbHeader = "FTL-Verb"
	// RequestIDHeader is the header used to pass the inbound request ID.
	RequestIDHeader = "FTL-Request-ID"
)

Headers used by the internal RPC system.

Functions

func AddCaller

func AddCaller(header http.Header, ref *schema.VerbRef)

AddCaller to an outgoing request.

func GetCaller

func GetCaller(header http.Header) (optional.Option[*schema.VerbRef], error)

GetCaller returns the module.verb of the caller, if any.

Will return an error if the header is malformed.

func GetCallers

func GetCallers(header http.Header) ([]*schema.VerbRef, error)

GetCallers history from an incoming request.

func GetRequestName

func GetRequestName(header http.Header) (model.RequestName, bool, error)

GetRequestName from an incoming request.

Will return ("", false, nil) if no request key is present.

func IsDirectRouted

func IsDirectRouted(header http.Header) bool

func SetCallers

func SetCallers(header http.Header, refs []*schema.VerbRef)

func SetDirectRouted

func SetDirectRouted(header http.Header)

func SetRequestName

func SetRequestName(header http.Header, key model.RequestName)