mocktunnelservice

type CommandMutator func(json.RawMessage, SharedStorage) json.RawMessage

type CommandResponse struct {
	Command           json.RawMessage
	CommandMutator    CommandMutator
	DeliverAfter      <-chan struct{}
	ExpectedResponses []ExpectedResponse
	// NoResponseExpected marks the command complete as soon as it is delivered.
	// Use it for paths where the client intentionally does not POST a response,
	// such as a dispatcher connection TTL expiring while a request is in flight.
	NoResponseExpected bool
}

type ExpectedResponse struct {
	RequestID   string
	Headers     http.Header
	Assert      func(testing.TB, ReceivedResponse)
	PostProcess ResponsePostProcessor
}

type IncomingHTTPRequest struct {
	Method   string
	Path     string
	RawQuery string
	Headers  http.Header
}

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

type Option func(*MockTunnelService)

type ReceivedResponse struct {
	RequestID       string
	JSONResponse    json.RawMessage
	ResponseHeaders http.Header
	ResponseCode    int
	ResponseType    string
	MatchedCommand  bool
}

type ResponseMatchFilter int

type ResponsePostProcessor func(ReceivedResponse, SharedStorage)

type SharedStorage interface {
	Get(key string) (string, bool)
	Set(key, value string)
	Delete(key string)
}