process

Documentation

Index

• type Flow
  • func NewFlow(ctx *icontext.Context, opts ...Option) *Flow
• type HttpFlow
• type Log
  • func NewLog(l *ast.LogStatement, scope context.Scope, message string) *Log
• type Option
  • func WithName(name string) Option
  • func WithSubroutine(sub *ast.SubroutineDeclaration) Option
  • func WithToken(tok token.Token) Option
• type Process
  • func New() *Process
  • func (p *Process) Finalize(resp *http.Response) ([]byte, error)

Types

type Flow

type Flow struct {
	File            string    `json:"file"`
	Line            int       `json:"line"`
	Position        int       `json:"position"`
	Subroutine      string    `json:"subroutine,omitempty"`
	Name            string    `json:"name,omitempty"`
	Scope           string    `json:"scope"`
	Request         *HttpFlow `json:"req,omitempty"`
	BackendRequest  *HttpFlow `json:"bereq,omitempty"`
	BackendResponse *HttpFlow `json:"beresp,omitempty"`
	Response        *HttpFlow `json:"resp,omitempty"`
	Object          *HttpFlow `json:"object,omitempty"`
}

func NewFlow

func NewFlow(ctx *icontext.Context, opts ...Option) *Flow

type HttpFlow

type HttpFlow struct {
	Method     string            `json:"method,omitempty"`
	Host       string            `json:"host,omitempty"`
	URL        string            `json:"url,omitempty"`
	Headers    map[string]string `json:"headers"`
	StatusCode int               `json:"status_code,omitempty"`
	StatusText string            `json:"status_text,omitempty"`
}

type Log

type Log struct {
	Scope    string `json:"scope"`
	File     string `json:"file"`
	Line     int    `json:"line"`
	Position int    `json:"position"`
	Message  string `json:"message"`
}

func NewLog

func NewLog(l *ast.LogStatement, scope context.Scope, message string) *Log

type Option

type Option func(f *Flow)

func WithName

func WithName(name string) Option

func WithSubroutine

func WithSubroutine(sub *ast.SubroutineDeclaration) Option

func WithToken

func WithToken(tok token.Token) Option

type Process

type Process struct {
	Flows     []*Flow
	Logs      []*Log
	Restarts  int
	Backend   *value.Backend
	Cached    bool
	Error     error
	StartTime int64
	Response  *http.Response
}

func New

func New() *Process

func (*Process) Finalize

func (p *Process) Finalize(resp *http.Response) ([]byte, error)