proxytest

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

type HostEmulator interface {
	Done()

	// Root
	StartVM()
	StartPlugin()
	FinishVM()

	GetCalloutAttributesFromContext(contextID uint32) []HttpCalloutAttribute
	PutCalloutResponse(contextID uint32, headers types.Headers, trailers types.Trailers, body []byte)

	GetLogs(level types.LogLevel) []string
	GetTickPeriod() uint32
	Tick()
	GetQueueSize(queueID uint32) int

	// network
	InitializeConnection() (contextID uint32)
	CallOnUpstreamData(contextID uint32, data []byte)
	CallOnDownstreamData(contextID uint32, data []byte)
	CloseUpstreamConnection(contextID uint32)
	CloseDownstreamConnection(contextID uint32)
	CompleteConnection(contextID uint32)

	// http
	InitializeHttpContext() (contextID uint32)
	CallOnResponseHeaders(contextID uint32, headers types.Headers, endOfStream bool)
	CallOnResponseBody(contextID uint32, body []byte, endOfStream bool)
	CallOnResponseTrailers(contextID uint32, trailers types.Trailers)
	CallOnRequestHeaders(contextID uint32, headers types.Headers, endOfStream bool)
	CallOnRequestTrailers(contextID uint32, trailers types.Trailers)
	CallOnRequestBody(contextID uint32, body []byte, endOfStream bool)
	CompleteHttpContext(contextID uint32)
	GetCurrentHttpStreamAction(contextID uint32) types.Action
	GetSentLocalResponse(contextID uint32) *LocalHttpResponse
	CallOnLogForAccessLogger(requestHeaders, responseHeaders types.Headers)
}

type HttpCalloutAttribute struct {
	CalloutID uint32
	Upstream  string
	Headers   types.Headers
	Trailers  types.Trailers
	Body      []byte
}

type LocalHttpResponse struct {
	StatusCode       uint32
	StatusCodeDetail string
	Data             []byte
	Headers          types.Headers
	GRPCStatus       int32
}